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) Shutdown(ctx context.Context) 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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
ConnectDataStore establishes the DynamoDB connection for the notifier server. FIX #1: Builds into a local variable first so n._ddbStore is never non-nil but unconnected. Other methods check n._ddbStore == nil as their guard — assigning before Connect() would let them pass the guard and use a broken connection.
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) Shutdown ¶ added in v1.7.0
func (n *NotifierImpl) Shutdown(ctx context.Context) error
Shutdown gracefully shuts down the notifier server It closes all client connections, removes server route from DynamoDB, and disconnects from DynamoDB
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 ¶ added in v1.0.8
func (n *NotifierImpl) UnsubscribeAllPriorSNSTopics(topicArnLimit ...string)
UnsubscribeAllPriorSNSTopics will attempt to clean up all prior SNS topic subscriptions based in the config
func (*NotifierImpl) UpdateSubscriptionArnToTopic ¶ added in v1.0.8
func (n *NotifierImpl) UpdateSubscriptionArnToTopic(topicArn string, subscriptionArn string) error
UpdateSubscriptionArnToTopic persists given subscriptionArn to the matching TopicArn in config data
Source Files