Versions in this module Expand all Collapse all v0 v0.0.5 Nov 29, 2024 v0.0.1 Nov 26, 2024 Changes in this version + const DeviceValidation + type Device struct + Attributes map[string]string + ID string + LoggedInAt time.Time + func (d Device) ToProto() *pushv1.Device + type GetClientActiveDevicesRequest struct + func (g *GetClientActiveDevicesRequest) PopulateFromProto(ctx context.Context, proto *pushv1.GetClientActiveDevicesRequest) error + type SendEventToClientChannelRequest struct + func (smu *SendEventToClientChannelRequest) PopulateFromProto(ctx context.Context, protoRequest *pushv1.SendEventToClientChannelRequest) error + type SendEventToClientDeviceChannelRequest struct + func (smu *SendEventToClientDeviceChannelRequest) PopulateFromProto(ctx context.Context, ...) error + type SendEventToTopicRequest struct + Event []byte + EventName string + Topic string + func (smt *SendEventToTopicRequest) PopulateFromProto(ctx context.Context, protoRequest *pushv1.SendEventToTopicRequest) error + type SendEventToTopicsRequest struct + func (sm *SendEventToTopicsRequest) PopulateFromProto(ctx context.Context, proto *pushv1.SendEventToTopicsRequest) error + type Service struct + func NewService(pubSub pubsub.IPubSub, kv kv.IKV, config config.Config) *Service + func (c *Service) AsyncClientSubscribe(ctx context.Context, clientID string, device *Device) (*subscription.Subscription, error) + func (c *Service) ClientUnsubscribe(ctx context.Context, clientID string, subscription *subscription.Subscription, ...) error + func (c *Service) ConfirmEventReceipt(ctx context.Context, eventName string) + func (c *Service) GetClientActiveDevices(ctx context.Context, req GetClientActiveDevicesRequest) ([]Device, error) + func (c *Service) IsDeviceValidationMessage(eventName string) bool + func (c *Service) PublishToClient(ctx context.Context, req SendEventToClientChannelRequest) error + func (c *Service) PublishToClientWithDevice(ctx context.Context, req SendEventToClientDeviceChannelRequest) error + func (c *Service) PublishToTopic(ctx context.Context, req SendEventToTopicRequest) error + func (c *Service) PublishToTopics(ctx context.Context, req SendEventToTopicsRequest) error + func (c *Service) TopicSubscribe(ctx context.Context, topic string, ...) error + func (c *Service) TopicUnsubscribe(ctx context.Context, topic string, ...) error + func (c *Service) TriggerTestPayloadToTopic(ctx context.Context, topic string) + type TopicSubscriptionRequest struct + type TopicUnSubscriptionRequest struct
Go to main page