impl

Documentation

Index

• type NotifierImpl
  • func (n *NotifierImpl) Broadcast(c context.Context, d *pb.NotificationData) (r *pb.NotificationDone, err error)
  • func (n *NotifierImpl) ConnectDataStore() error
  • func (n *NotifierImpl) ConnectSNS(awsRegionStr awsregion.AWSRegion) (err error)
  • func (n *NotifierImpl) ReadConfig(appName string, configFileName string, customConfigPath string) error
  • func (n *NotifierImpl) Subscribe(s *pb.NotificationSubscriber, serverStream pb.NotifierService_SubscribeServer) error
  • func (n *NotifierImpl) Unsubscribe(c context.Context, s *pb.NotificationSubscriber) (r *pb.NotificationDone, err error)
  • func (n *NotifierImpl) UnsubscribeAllPriorSNSTopics(topicArnLimit ...string)
  • func (n *NotifierImpl) UpdateSubscriptionArnToTopic(topicArn string, subscriptionArn string) error

Types

type NotifierImpl

type NotifierImpl struct {
	pb.UnimplementedNotifierServiceServer

	ConfigData                *config.Config
	WebServerLocalAddressFunc func() string
	// contains filtered or unexported fields
}

func (*NotifierImpl) Broadcast

func (n *NotifierImpl) Broadcast(c context.Context, d *pb.NotificationData) (r *pb.NotificationDone, err error)

Broadcast handles rpc implementation to broadcast notification data to all clients under a specific topicArn

func (*NotifierImpl) ConnectDataStore

func (n *NotifierImpl) ConnectDataStore() error

func (*NotifierImpl) ConnectSNS

func (n *NotifierImpl) ConnectSNS(awsRegionStr awsregion.AWSRegion) (err error)

func (*NotifierImpl) ReadConfig

func (n *NotifierImpl) ReadConfig(appName string, configFileName string, customConfigPath string) error

ReadConfig will read in config data

func (*NotifierImpl) Subscribe

func (n *NotifierImpl) Subscribe(s *pb.NotificationSubscriber, serverStream pb.NotifierService_SubscribeServer) error

Subscribe handles rpc implementation to subscribe a client to a topicArn, and process ongoing server stream notification to client

func (*NotifierImpl) Unsubscribe

func (n *NotifierImpl) Unsubscribe(c context.Context, s *pb.NotificationSubscriber) (r *pb.NotificationDone, err error)

Unsubscribe handles rpc implementation to unsubscribe a client to a topicArn

func (*NotifierImpl) UnsubscribeAllPriorSNSTopics

func (n *NotifierImpl) UnsubscribeAllPriorSNSTopics(topicArnLimit ...string)

UnsubscribeAllPriorSNSTopics will attempt to clean up all prior SNS topic subscriptions based in the config

func (*NotifierImpl) UpdateSubscriptionArnToTopic

func (n *NotifierImpl) UpdateSubscriptionArnToTopic(topicArn string, subscriptionArn string) error

UpdateSubscriptionArnToTopic persists given subscriptionArn to the matching TopicArn in config data