svc

Documentation

Index

• type AWSServiceProvider
  • func NewAWSServiceProvider(id string, region string) *AWSServiceProvider
  • func (p *AWSServiceProvider) CreateQueue(subject string) (string, *string, error)
  • func (p *AWSServiceProvider) PollQueueRealTime(queueName string, queueUrl *string, onEventHandler func(interface{}))
  • func (p *AWSServiceProvider) PublishEvent(subject string, region string, eventData interface{})
  • func (p *AWSServiceProvider) SubscribeEvent(subject, region string, onEventHandler func(interface{}))

Types

type AWSServiceProvider

type AWSServiceProvider struct {
	AWSId        string
	AWSRegion    string
	AWSSNSClient *sns.SNS
	AWSSQSClient *sqs.SQS
}

func NewAWSServiceProvider

func NewAWSServiceProvider(id string, region string) *AWSServiceProvider

Create instance of AWS Provider

func (*AWSServiceProvider) CreateQueue

func (p *AWSServiceProvider) CreateQueue(subject string) (string, *string, error)

Create Queue

func (*AWSServiceProvider) PollQueueRealTime

func (p *AWSServiceProvider) PollQueueRealTime(queueName string, queueUrl *string, onEventHandler func(interface{}))

Real Time SQS Poller

func (*AWSServiceProvider) PublishEvent

func (p *AWSServiceProvider) PublishEvent(subject string, region string, eventData interface{})

Publish Event on SNS

func (*AWSServiceProvider) SubscribeEvent

func (p *AWSServiceProvider) SubscribeEvent(subject, region string, onEventHandler func(interface{}))

Subscribe Event