tmgr

Documentation

Index

• Constants
• type DataToPublish
• type TopicManager
  • func TM() *TopicManager
  • func (tm *TopicManager) CreateTopic(topicName string) string
  • func (tm *TopicManager) DeleteTopic(topicArn string) bool
  • func (tm *TopicManager) ListTopics(offset int) ([]string, int)
  • func (tm *TopicManager) Publish(data *DataToPublish)
  • func (tm *TopicManager) Subscribe(topicArn, protocol, endpoint string) string

Constants

const ReturnBatchSize = 5

const TopicDataPrefix = ":tdata:"

const TopicListPrefix = ":tlist:"

Types

type DataToPublish

type DataToPublish struct {
	TopicArn          string
	TargetArn         string
	Message           string
	Subject           string
	MessageStructure  string
	MessageAttributes map[string]map[string]string
}

type TopicManager

type TopicManager struct {
	sync.Mutex
	Topics     map[string]*dbdata.Topic
	TargetArns map[string]*dbdata.Subscription
	TopicList  []string
}

func TM

func TM() *TopicManager

func (*TopicManager) CreateTopic

func (tm *TopicManager) CreateTopic(topicName string) string

func (*TopicManager) DeleteTopic

func (tm *TopicManager) DeleteTopic(topicArn string) bool

func (*TopicManager) ListTopics

func (tm *TopicManager) ListTopics(offset int) ([]string, int)

func (*TopicManager) Publish

func (tm *TopicManager) Publish(data *DataToPublish)

func (*TopicManager) Subscribe

func (tm *TopicManager) Subscribe(topicArn, protocol, endpoint string) string