Documentation
¶
Index ¶
- func C2CURI(uri string) string
- func GetUniqueSubscriptionID(subIDS ...string) string
- func MakeConfig(t require.TestingT) service.Config
- func MakeStorageConfig() service.StorageConfig
- func New(t require.TestingT, cfg service.Config) func()
- func NewTestListener(t *testing.T) (net.Listener, func())
- func SetUp(t require.TestingT) (tearDown func())
- type C2CSubscriber
- type Event
- type EventChan
- type EventsServer
- type SubscriptionType
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetUniqueSubscriptionID ¶
func MakeStorageConfig ¶
func MakeStorageConfig() service.StorageConfig
Types ¶
type C2CSubscriber ¶
type C2CSubscriber struct {
// contains filtered or unexported fields
}
func NewC2CSubscriber ¶
func NewC2CSubscriber(port, eventsURI string, subType SubscriptionType) *C2CSubscriber
func (*C2CSubscriber) Subscribe ¶
func (c *C2CSubscriber) Subscribe(ctx context.Context, t *testing.T, token, deviceID, href string, eventTypes events.EventTypes) string
func (*C2CSubscriber) Unsubscribe ¶
type Event ¶
type Event struct {
// contains filtered or unexported fields
}
func (*Event) GetHeader ¶
func (e *Event) GetHeader() events.EventHeader
type EventsServer ¶
type EventsServer struct {
// contains filtered or unexported fields
}
func NewEventsServer ¶
func NewEventsServer(t *testing.T, uri string) *EventsServer
func (*EventsServer) Close ¶
func (s *EventsServer) Close(t *testing.T)
func (*EventsServer) WaitForClose ¶
func (s *EventsServer) WaitForClose()
type SubscriptionType ¶
type SubscriptionType int
const ( SubscriptionType_Devices SubscriptionType = iota SubscriptionType_Device SubscriptionType_Resource )
Source Files
Click to show internal directories.
Click to hide internal directories.