pubsub

type Channel interface {
	Context() context.Context
	SmartOps(smartOps []string) (uint32, error)
	Type() uint32
	Messaging
}

type Messaging interface {
	Config() *structureSpec.Messaging
}

type Service interface {
	components.ServiceComponent
	Subscribe(projectId, appId, channel string) error
	Publish(ctx context.Context, projectId, appId, channel string, data []byte) error
	WebSocketURL(projectId, appId, channel string) (string, error)
}

type Serviceable interface {
	components.FunctionServiceable
	HandleMessage(msg *pubsub.Message) (time.Time, error)
	Name() string
}