pb

package

v2.18.0 Latest Latest Go to latest Published: Apr 17, 2024 License: Apache-2.0 Imports: 36 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/plgd-dev/hub

Links

Open Source Insights

Documentation ¶

Index ¶

func AssertCmpEvents(t *testing.T, expected, got []*pb.Event)
func CheckGetEventsResponse(t *testing.T, got []*pb.GetEventsResponse)
func CleanResourceDeleted(e *events.ResourceDeleted, resetCorrelationID bool) *events.ResourceDeleted
func CleanUpDeviceMetadataSnapshotTaken(e *events.DeviceMetadataSnapshotTaken, resetCorrelationID bool)
func CleanUpDeviceMetadataUpdatePending(e *events.DeviceMetadataUpdatePending, resetCorrelationID bool) *events.DeviceMetadataUpdatePending
func CleanUpDeviceMetadataUpdated(e *events.DeviceMetadataUpdated, resetCorrelationID bool) *events.DeviceMetadataUpdated
func CleanUpDeviceRegistered(deviceRegistered *pb.Event_DeviceRegistered)
func CleanUpDeviceUnregistered(deviceUnregistered *pb.Event_DeviceUnregistered)
func CleanUpEvent(t *testing.T, ev *pb.Event)
func CleanUpEventStoreEvent(t *testing.T, ev eventstore.Event)
func CleanUpResourceChanged(e *events.ResourceChanged, resetCorrelationID bool) *events.ResourceChanged
func CleanUpResourceCreatePending(e *events.ResourceCreatePending, resetCorrelationID bool) *events.ResourceCreatePending
func CleanUpResourceCreated(e *events.ResourceCreated, resetCorrelationID bool) *events.ResourceCreated
func CleanUpResourceDeletePending(e *events.ResourceDeletePending, resetCorrelationID bool) *events.ResourceDeletePending
func CleanUpResourceLinksPublished(e *events.ResourceLinksPublished, resetCorrelationID bool) *events.ResourceLinksPublished
func CleanUpResourceLinksSnapshotTaken(e *events.ResourceLinksSnapshotTaken) *events.ResourceLinksSnapshotTaken
func CleanUpResourceLinksUnpublished(e *events.ResourceLinksUnpublished, resetCorrelationID bool) *events.ResourceLinksUnpublished
func CleanUpResourceRetrievePending(e *events.ResourceRetrievePending, resetCorrelationID bool) *events.ResourceRetrievePending
func CleanUpResourceRetrieved(e *events.ResourceRetrieved, resetCorrelationID bool) *events.ResourceRetrieved
func CleanUpResourceStateSnapshotTaken(e *events.ResourceStateSnapshotTaken, resetCorrelationID bool) *events.ResourceStateSnapshotTaken
func CleanUpResourceUpdatePending(e *events.ResourceUpdatePending, resetCorrelationID bool) *events.ResourceUpdatePending
func CleanUpResourceUpdated(e *events.ResourceUpdated, resetCorrelationID bool) *events.ResourceUpdated
func CleanUpServiceEvent(t *testing.T, ev eventstore.Event)
func CleanUpServiceMetadataUpdated(e *events.ServiceMetadataUpdated, resetCorrelationID bool) *events.ServiceMetadataUpdated
func CmpCancelPendingCmdResponses(t *testing.T, want *pb.CancelPendingCommandsResponse, ...)
func CmpDeviceMetadataUpdatePending(t *testing.T, expected, got *events.DeviceMetadataUpdatePending)
func CmpDeviceMetadataUpdated(t *testing.T, expected, got *events.DeviceMetadataUpdated)
func CmpDeviceMetadataUpdatedSlice(t *testing.T, expected, got []*events.DeviceMetadataUpdated)
func CmpDeviceValues(t *testing.T, expected, got []*pbGrpc.Device)
func CmpEvent(t *testing.T, expected, got *pb.Event, cmpInterface string)
func CmpEvents(t *testing.T, expected, got []*pb.Event)
func CmpHubConfigurationResponse(t *testing.T, expected, got *pb.HubConfigurationResponse)
func CmpPendingCmds(t *testing.T, want []*pb.PendingCommand, got []*pb.PendingCommand)
func CmpResourceChanged(t *testing.T, expected, got *events.ResourceChanged, cmpInterface string)
func CmpResourceChangedData(t *testing.T, expected, got []byte)
func CmpResourceCreatePending(t *testing.T, expected, got *events.ResourceCreatePending)
func CmpResourceCreated(t *testing.T, expected, got *events.ResourceCreated)
func CmpResourceDeletePending(t *testing.T, expected, got *events.ResourceDeletePending)
func CmpResourceDeleted(t *testing.T, expected, got *events.ResourceDeleted)
func CmpResourceIds(t *testing.T, expected, got []*commands.ResourceId)
func CmpResourceRetrievePending(t *testing.T, expected, got *events.ResourceRetrievePending)
func CmpResourceRetrieved(t *testing.T, expected, got *events.ResourceRetrieved)
func CmpResourceStateSnapshotTaken(t *testing.T, expected, got *events.ResourceStateSnapshotTaken)
func CmpResourceUpdatePending(t *testing.T, expected, got *events.ResourceUpdatePending)
func CmpResourceUpdated(t *testing.T, expected, got *events.ResourceUpdated)
func CmpResourceValues(t *testing.T, expected, got []*pb.Resource)
func CmpResourceValuesBasic(t *testing.T, expected, got []*pb.Resource)
func CmpServiceMetadataUpdated(t *testing.T, expected, got *events.ServiceMetadataUpdated)
func CmpServiceMetadataUpdatedSlice(t *testing.T, expected, got []*events.ServiceMetadataUpdated)
func CmpServicesEvents(t *testing.T, expected, got []eventstore.Event)
func CmpUpGetEventsResponses(t *testing.T, expected, got []*pb.GetEventsResponse)
func FindResourceInResourceLinksPublishedByHref(e *events.ResourceLinksPublished, href string) *commands.Resource
func GetEventID(ev *pb.Event) string
func GetEventType(ev *pb.Event) string
func GetWrappedEvent(v *pb.GetEventsResponse) interface{}
func InitPendingEvents(ctx context.Context, t *testing.T) (pb.GrpcGatewayClient, []ResourcePendingEvent, []DevicePendingEvent, func())
func MakeCreateSwitchResourceResponseData(id string) map[string]interface{}
func MakeDeviceMetadataUpdatePending(deviceID string, twinEnabled bool, correlationID string) *events.DeviceMetadataUpdatePending
func MakeDeviceMetadataUpdated(deviceID string, connectionStatus commands.Connection_Status, ...) *events.DeviceMetadataUpdated
func MakeResourceChanged(t *testing.T, deviceID, href string, resourceTypes []string, ...) *events.ResourceChanged
func MakeResourceCreatePending(t *testing.T, deviceID, href string, resourceTypes []string, ...) *events.ResourceCreatePending
func MakeResourceCreated(t *testing.T, deviceID, href string, resourceTypes []string, ...) *events.ResourceCreated
func MakeResourceDeletePending(deviceID, href string, resourceTypes []string, correlationID string) *events.ResourceDeletePending
func MakeResourceDeleted(deviceID, href string, resourceTypes []string, correlationID string) *events.ResourceDeleted
func MakeResourceLinksPublished(deviceID string, resources []*commands.Resource, correlationID string) *events.ResourceLinksPublished
func MakeResourceLinksUnpublished(deviceID string, resources []string, correlationID string) *events.ResourceLinksUnpublished
func MakeResourceRetrievePending(deviceID, href string, resourceTypes []string, correlationID string) *events.ResourceRetrievePending
func MakeResourceRetrieved(t *testing.T, deviceID, href string, resourceTypes []string, ...) *events.ResourceRetrieved
func MakeResourceUpdatePending(t *testing.T, deviceID, href string, resourceTypes []string, ...) *events.ResourceUpdatePending
func MakeResourceUpdated(t *testing.T, deviceID, href string, resourceTypes []string, ...) *events.ResourceUpdated
func MakeServiceMetadataUpdated(servicesHeartbeat *events.ServicesHeartbeat, correlationID string) *events.ServiceMetadataUpdated
func OperationProcessedOK() *pb.Event_OperationProcessed_
func ResourceLinkToPublishEvent(deviceID, token string, links []schema.ResourceLink) *pb.Event
func ToEvent(data interface{}) *pb.Event
type DevicePendingEvent
type ResourcePendingEvent
type SortPendingCommand
- func (a SortPendingCommand) Len() int
- func (a SortPendingCommand) Less(i, j int) bool
- func (a SortPendingCommand) Swap(i, j int)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func AssertCmpEvents ¶ added in v2.18.0

func AssertCmpEvents(t *testing.T, expected, got []*pb.Event)

func CheckGetEventsResponse ¶

func CheckGetEventsResponse(t *testing.T, got []*pb.GetEventsResponse)

func CleanResourceDeleted ¶

func CleanResourceDeleted(e *events.ResourceDeleted, resetCorrelationID bool) *events.ResourceDeleted

func CleanUpDeviceMetadataSnapshotTaken ¶ added in v2.16.0

func CleanUpDeviceMetadataSnapshotTaken(e *events.DeviceMetadataSnapshotTaken, resetCorrelationID bool)

func CleanUpDeviceMetadataUpdatePending ¶

func CleanUpDeviceMetadataUpdatePending(e *events.DeviceMetadataUpdatePending, resetCorrelationID bool) *events.DeviceMetadataUpdatePending

func CleanUpDeviceMetadataUpdated ¶

func CleanUpDeviceMetadataUpdated(e *events.DeviceMetadataUpdated, resetCorrelationID bool) *events.DeviceMetadataUpdated

func CleanUpDeviceRegistered ¶ added in v2.4.0

func CleanUpDeviceRegistered(deviceRegistered *pb.Event_DeviceRegistered)

func CleanUpDeviceUnregistered ¶ added in v2.4.0

func CleanUpDeviceUnregistered(deviceUnregistered *pb.Event_DeviceUnregistered)

func CleanUpEvent ¶

func CleanUpEvent(t *testing.T, ev *pb.Event)

Remove fields with unpredictable values

func CleanUpEventStoreEvent ¶ added in v2.16.0

func CleanUpEventStoreEvent(t *testing.T, ev eventstore.Event)

Remove fields with unpredictable values

func CleanUpResourceChanged ¶

func CleanUpResourceChanged(e *events.ResourceChanged, resetCorrelationID bool) *events.ResourceChanged

func CleanUpResourceCreatePending ¶

func CleanUpResourceCreatePending(e *events.ResourceCreatePending, resetCorrelationID bool) *events.ResourceCreatePending

func CleanUpResourceCreated ¶

func CleanUpResourceCreated(e *events.ResourceCreated, resetCorrelationID bool) *events.ResourceCreated

func CleanUpResourceDeletePending ¶

func CleanUpResourceDeletePending(e *events.ResourceDeletePending, resetCorrelationID bool) *events.ResourceDeletePending

func CleanUpResourceLinksPublished ¶

func CleanUpResourceLinksPublished(e *events.ResourceLinksPublished, resetCorrelationID bool) *events.ResourceLinksPublished

func CleanUpResourceLinksSnapshotTaken ¶

func CleanUpResourceLinksSnapshotTaken(e *events.ResourceLinksSnapshotTaken) *events.ResourceLinksSnapshotTaken

func CleanUpResourceLinksUnpublished ¶

func CleanUpResourceLinksUnpublished(e *events.ResourceLinksUnpublished, resetCorrelationID bool) *events.ResourceLinksUnpublished

func CleanUpResourceRetrievePending ¶

func CleanUpResourceRetrievePending(e *events.ResourceRetrievePending, resetCorrelationID bool) *events.ResourceRetrievePending

func CleanUpResourceRetrieved ¶

func CleanUpResourceRetrieved(e *events.ResourceRetrieved, resetCorrelationID bool) *events.ResourceRetrieved

func CleanUpResourceStateSnapshotTaken ¶

func CleanUpResourceStateSnapshotTaken(e *events.ResourceStateSnapshotTaken, resetCorrelationID bool) *events.ResourceStateSnapshotTaken

func CleanUpResourceUpdatePending ¶

func CleanUpResourceUpdatePending(e *events.ResourceUpdatePending, resetCorrelationID bool) *events.ResourceUpdatePending

func CleanUpResourceUpdated ¶

func CleanUpResourceUpdated(e *events.ResourceUpdated, resetCorrelationID bool) *events.ResourceUpdated

func CleanUpServiceEvent ¶ added in v2.12.0

func CleanUpServiceEvent(t *testing.T, ev eventstore.Event)

func CleanUpServiceMetadataUpdated ¶ added in v2.12.0

func CleanUpServiceMetadataUpdated(e *events.ServiceMetadataUpdated, resetCorrelationID bool) *events.ServiceMetadataUpdated

func CmpCancelPendingCmdResponses ¶

func CmpCancelPendingCmdResponses(t *testing.T, want *pb.CancelPendingCommandsResponse, got *pb.CancelPendingCommandsResponse)

func CmpDeviceMetadataUpdatePending ¶

func CmpDeviceMetadataUpdatePending(t *testing.T, expected, got *events.DeviceMetadataUpdatePending)

func CmpDeviceMetadataUpdated ¶

func CmpDeviceMetadataUpdated(t *testing.T, expected, got *events.DeviceMetadataUpdated)

func CmpDeviceMetadataUpdatedSlice ¶

func CmpDeviceMetadataUpdatedSlice(t *testing.T, expected, got []*events.DeviceMetadataUpdated)

func CmpDeviceValues ¶

func CmpDeviceValues(t *testing.T, expected, got []*pbGrpc.Device)

func CmpEvent ¶

func CmpEvent(t *testing.T, expected, got *pb.Event, cmpInterface string)

func CmpEvents ¶

func CmpEvents(t *testing.T, expected, got []*pb.Event)

func CmpHubConfigurationResponse ¶

func CmpHubConfigurationResponse(t *testing.T, expected, got *pb.HubConfigurationResponse)

func CmpPendingCmds ¶

func CmpPendingCmds(t *testing.T, want []*pb.PendingCommand, got []*pb.PendingCommand)

func CmpResourceChanged ¶

func CmpResourceChanged(t *testing.T, expected, got *events.ResourceChanged, cmpInterface string)

func CmpResourceChangedData ¶

func CmpResourceChangedData(t *testing.T, expected, got []byte)

func CmpResourceCreatePending ¶

func CmpResourceCreatePending(t *testing.T, expected, got *events.ResourceCreatePending)

func CmpResourceCreated ¶

func CmpResourceCreated(t *testing.T, expected, got *events.ResourceCreated)

func CmpResourceDeletePending ¶

func CmpResourceDeletePending(t *testing.T, expected, got *events.ResourceDeletePending)

func CmpResourceDeleted ¶

func CmpResourceDeleted(t *testing.T, expected, got *events.ResourceDeleted)

func CmpResourceIds ¶

func CmpResourceIds(t *testing.T, expected, got []*commands.ResourceId)

func CmpResourceRetrievePending ¶

func CmpResourceRetrievePending(t *testing.T, expected, got *events.ResourceRetrievePending)

func CmpResourceRetrieved ¶

func CmpResourceRetrieved(t *testing.T, expected, got *events.ResourceRetrieved)

func CmpResourceStateSnapshotTaken ¶

func CmpResourceStateSnapshotTaken(t *testing.T, expected, got *events.ResourceStateSnapshotTaken)

func CmpResourceUpdatePending ¶

func CmpResourceUpdatePending(t *testing.T, expected, got *events.ResourceUpdatePending)

func CmpResourceUpdated ¶

func CmpResourceUpdated(t *testing.T, expected, got *events.ResourceUpdated)

func CmpResourceValues ¶

func CmpResourceValues(t *testing.T, expected, got []*pb.Resource)

func CmpResourceValuesBasic ¶

func CmpResourceValuesBasic(t *testing.T, expected, got []*pb.Resource)

compare only deviceId, href and resourceTypes

func CmpServiceMetadataUpdated ¶ added in v2.12.0

func CmpServiceMetadataUpdated(t *testing.T, expected, got *events.ServiceMetadataUpdated)

func CmpServiceMetadataUpdatedSlice ¶ added in v2.12.0

func CmpServiceMetadataUpdatedSlice(t *testing.T, expected, got []*events.ServiceMetadataUpdated)

func CmpServicesEvents ¶ added in v2.12.0

func CmpServicesEvents(t *testing.T, expected, got []eventstore.Event)

func CmpUpGetEventsResponses ¶ added in v2.16.0

func CmpUpGetEventsResponses(t *testing.T, expected, got []*pb.GetEventsResponse)

func FindResourceInResourceLinksPublishedByHref ¶ added in v2.5.0

func FindResourceInResourceLinksPublishedByHref(e *events.ResourceLinksPublished, href string) *commands.Resource

func GetEventID ¶

func GetEventID(ev *pb.Event) string

func GetEventType ¶

func GetEventType(ev *pb.Event) string

func GetWrappedEvent ¶

func GetWrappedEvent(v *pb.GetEventsResponse) interface{}

func InitPendingEvents ¶

func InitPendingEvents(ctx context.Context, t *testing.T) (pb.GrpcGatewayClient, []ResourcePendingEvent, []DevicePendingEvent, func())

func MakeCreateSwitchResourceResponseData ¶

func MakeCreateSwitchResourceResponseData(id string) map[string]interface{}

func MakeDeviceMetadataUpdatePending ¶

func MakeDeviceMetadataUpdatePending(deviceID string, twinEnabled bool, correlationID string) *events.DeviceMetadataUpdatePending

func MakeDeviceMetadataUpdated ¶

func MakeDeviceMetadataUpdated(deviceID string, connectionStatus commands.Connection_Status, connectionProtocol commands.Connection_Protocol, twinEnabled bool, twinSynchronizationState commands.TwinSynchronization_State, correlationID string) *events.DeviceMetadataUpdated

func MakeResourceChanged ¶

func MakeResourceChanged(t *testing.T, deviceID, href string, resourceTypes []string, correlationID string, data interface{}) *events.ResourceChanged

func MakeResourceCreatePending ¶

func MakeResourceCreatePending(t *testing.T, deviceID, href string, resourceTypes []string, correlationID string, data interface{}) *events.ResourceCreatePending

func MakeResourceCreated ¶

func MakeResourceCreated(t *testing.T, deviceID, href string, resourceTypes []string, correlationID string, data map[string]interface{}) *events.ResourceCreated

func MakeResourceDeletePending ¶

func MakeResourceDeletePending(deviceID, href string, resourceTypes []string, correlationID string) *events.ResourceDeletePending

func MakeResourceDeleted ¶

func MakeResourceDeleted(deviceID, href string, resourceTypes []string, correlationID string) *events.ResourceDeleted

func MakeResourceLinksPublished ¶

func MakeResourceLinksPublished(deviceID string, resources []*commands.Resource, correlationID string) *events.ResourceLinksPublished

func MakeResourceLinksUnpublished ¶

func MakeResourceLinksUnpublished(deviceID string, resources []string, correlationID string) *events.ResourceLinksUnpublished

func MakeResourceRetrievePending ¶

func MakeResourceRetrievePending(deviceID, href string, resourceTypes []string, correlationID string) *events.ResourceRetrievePending

func MakeResourceRetrieved ¶

func MakeResourceRetrieved(t *testing.T, deviceID, href string, resourceTypes []string, correlationID string, data interface{}) *events.ResourceRetrieved

func MakeResourceUpdatePending ¶

func MakeResourceUpdatePending(t *testing.T, deviceID, href string, resourceTypes []string, correlationID string, data interface{}) *events.ResourceUpdatePending

func MakeResourceUpdated ¶

func MakeResourceUpdated(t *testing.T, deviceID, href string, resourceTypes []string, correlationID string, data interface{}) *events.ResourceUpdated

func MakeServiceMetadataUpdated ¶ added in v2.12.0

func MakeServiceMetadataUpdated(servicesHeartbeat *events.ServicesHeartbeat, correlationID string) *events.ServiceMetadataUpdated

func OperationProcessedOK ¶

func OperationProcessedOK() *pb.Event_OperationProcessed_

func ResourceLinkToPublishEvent ¶

func ResourceLinkToPublishEvent(deviceID, token string, links []schema.ResourceLink) *pb.Event

func ToEvent ¶

func ToEvent(data interface{}) *pb.Event

Try to create a *pb.Event which wraps the given data (data must be castable to one of pb.isEvent_Type types)

Types ¶

type DevicePendingEvent ¶

type DevicePendingEvent struct {
	DeviceID      string
	CorrelationID string
}

type ResourcePendingEvent ¶

type ResourcePendingEvent struct {
	ResourceId    *commands.ResourceId
	CorrelationID string
}

type SortPendingCommand ¶

type SortPendingCommand []*pb.PendingCommand

func (SortPendingCommand) Len ¶

func (a SortPendingCommand) Len() int

func (SortPendingCommand) Less ¶

func (a SortPendingCommand) Less(i, j int) bool

func (SortPendingCommand) Swap ¶

func (a SortPendingCommand) Swap(i, j int)

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
baseline

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL