sns

type Client interface {
	CreateTopic(ctx context.Context, params *sns.CreateTopicInput, optFns ...func(options *sns.Options)) (*sns.CreateTopicOutput, error)
	GetSubscriptionAttributes(ctx context.Context, params *sns.GetSubscriptionAttributesInput, optFns ...func(*sns.Options)) (*sns.GetSubscriptionAttributesOutput, error)
	GetTopicAttributes(ctx context.Context, params *sns.GetTopicAttributesInput, optFns ...func(options *sns.Options)) (*sns.GetTopicAttributesOutput, error)
	ListSubscriptionsByTopic(ctx context.Context, params *sns.ListSubscriptionsByTopicInput, optFns ...func(*sns.Options)) (*sns.ListSubscriptionsByTopicOutput, error)
	ListTopics(ctx context.Context, params *sns.ListTopicsInput, optFns ...func(options *sns.Options)) (*sns.ListTopicsOutput, error)
	Publish(ctx context.Context, params *sns.PublishInput, optFns ...func(options *sns.Options)) (*sns.PublishOutput, error)
	PublishBatch(ctx context.Context, input *sns.PublishBatchInput, optFns ...func(options *sns.Options)) (*sns.PublishBatchOutput, error)
	Subscribe(ctx context.Context, params *sns.SubscribeInput, optFns ...func(options *sns.Options)) (*sns.SubscribeOutput, error)
	Unsubscribe(ctx context.Context, params *sns.UnsubscribeInput, optFns ...func(*sns.Options)) (*sns.UnsubscribeOutput, error)
}

type ClientConfig struct {
	Settings    ClientSettings
	LoadOptions []func(options *awsCfg.LoadOptions) error
}

type ClientOption func(cfg *ClientConfig)

type ClientSettings struct {
	gosoAws.ClientSettings
}

type LifecycleManager interface {
	reslife.LifeCycleer
	reslife.Creator
	reslife.Initializer
	reslife.Registerer
}

type Message struct {
	Type      string
	TopicArn  string
	MessageId string
	Message   string
}

type Service struct {
	// contains filtered or unexported fields
}

type Topic interface {
	Publish(ctx context.Context, msg string, attributes ...map[string]string) error
	PublishBatch(ctx context.Context, messages []string, attributes []map[string]string) error
}

type TopicMetadata struct {
	AwsClientName string `json:"aws_client_name"`
	TopicArn      string `json:"topic_arn"`
	TopicName     string `json:"topic_name"`
}

type TopicNameSettings struct {
	Identity   cfg.Identity
	ClientName string
	TopicId    string
}

type TopicNameSettingsAware interface {
	GetIdentity() cfg.Identity
	GetClientName() string
	GetTopicId() string
}

type TopicNamingSettings struct {
	TopicPattern   string `cfg:"topic_pattern,nodecode" default:"{app.namespace}-{topicId}"`
	TopicDelimiter string `cfg:"topic_delimiter" default:"-"`
}

type TopicSettings struct {
	TopicName  string
	ClientName string
}