pubsub

Jul 31, 2023

Changes in this version

+ type Channel interface

+ Context func() context.Context

+ SmartOps func(smartOps []string) (uint32, error)

+ Type func() uint32

+ type Messaging interface

+ Config func() *structureSpec.Messaging

+ type Service interface

+ Publish func(ctx context.Context, projectId, appId, channel string, data []byte) error

+ Subscribe func(projectId, appId, channel string) error

+ WebSocketURL func(projectId, appId, channel string) (string, error)

+ type Serviceable interface

+ Config func() *structureSpec.Function

+ HandleMessage func(msg *pubsub.Message) (time.Time, error)

+ Name func() string