sns

Feb 19, 2024

Changes in this version

+ const MetadataKeyTopics

+ type TopicMetadata struct

+ AwsClientName string

+ TopicArn string

+ TopicName string

Oct 12, 2023

Changes in this version

+ const MaxBatchSize

+ func CreateTopic(ctx context.Context, logger log.Logger, client Client, topicName string) (string, error)

+ func GetTopicName(config cfg.Config, topicSettings TopicNameSettingsAware) (string, error)

+ func IsValidAttributeName(name string) bool

+ func NewClient(ctx context.Context, config cfg.Config, logger log.Logger, name string, ...) (*sns.Client, error)

+ func NewTopic(ctx context.Context, config cfg.Config, logger log.Logger, ...) (*snsTopic, error)

+ func NewTopicWithInterfaces(logger log.Logger, client Client, topicArn string) *snsTopic

+ func ProvideClient(ctx context.Context, config cfg.Config, logger log.Logger, name string, ...) (*sns.Client, error)

+ type Client interface

+ CreateTopic func(ctx context.Context, params *sns.CreateTopicInput, ...) (*sns.CreateTopicOutput, error)

+ GetSubscriptionAttributes func(ctx context.Context, params *sns.GetSubscriptionAttributesInput, ...) (*sns.GetSubscriptionAttributesOutput, error)

+ ListSubscriptionsByTopic func(ctx context.Context, params *sns.ListSubscriptionsByTopicInput, ...) (*sns.ListSubscriptionsByTopicOutput, error)

+ Publish func(ctx context.Context, params *sns.PublishInput, ...) (*sns.PublishOutput, error)

+ PublishBatch func(ctx context.Context, input *sns.PublishBatchInput, ...) (*sns.PublishBatchOutput, error)

+ Subscribe func(ctx context.Context, params *sns.SubscribeInput, ...) (*sns.SubscribeOutput, error)

+ Unsubscribe func(ctx context.Context, params *sns.UnsubscribeInput, ...) (*sns.UnsubscribeOutput, error)

+ type ClientConfig struct

+ LoadOptions []func(options *awsCfg.LoadOptions) error

+ Settings ClientSettings

+ func (c ClientConfig) GetLoadOptions() []func(options *awsCfg.LoadOptions) error

+ func (c ClientConfig) GetRetryOptions() []func(*retry.StandardOptions)

+ func (c ClientConfig) GetSettings() gosoAws.ClientSettings

+ type ClientOption func(cfg *ClientConfig)

+ type ClientSettings struct

+ type Message struct

+ Message string

+ MessageId string

+ TopicArn string

+ Type string

+ func (m Message) MarshalToBytes() ([]byte, error)

+ func (m Message) MarshalToString() (string, error)

+ type Topic interface

+ Publish func(ctx context.Context, msg string, attributes ...map[string]interface{}) error

+ PublishBatch func(ctx context.Context, messages []string, attributes []map[string]interface{}) error

+ SubscribeSqs func(ctx context.Context, queueArn string, attributes map[string]interface{}) error

+ type TopicNameSettings struct

+ AppId cfg.AppId

+ ClientName string

+ TopicId string

+ func (s TopicNameSettings) GetAppId() cfg.AppId

+ func (s TopicNameSettings) GetClientName() string

+ func (s TopicNameSettings) GetTopicId() string

+ type TopicNameSettingsAware interface

+ GetAppId func() cfg.AppId

+ GetClientName func() string

+ GetTopicId func() string

+ type TopicNamingSettings struct

+ Pattern string

+ type TopicSettings struct

+ ClientName string

+ TopicName string