topic

Documentation

Index

• type SnsEventService
  • func New(provider resource.AwsResourceProvider) (*SnsEventService, error)
  • func NewWithClient(provider resource.AwsResourceProvider, client snsiface.SNSAPI, ...) (*SnsEventService, error)
  • func (s *SnsEventService) Publish(ctx context.Context, req *topicpb.TopicPublishRequest) (*topicpb.TopicPublishResponse, error)

Types

type SnsEventService

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

func New

func New(provider resource.AwsResourceProvider) (*SnsEventService, error)

Create new SNS event service plugin

func NewWithClient

func NewWithClient(provider resource.AwsResourceProvider, client snsiface.SNSAPI, sfnClient sfniface.SFNAPI) (*SnsEventService, error)

func (*SnsEventService) Publish

func (s *SnsEventService) Publish(ctx context.Context, req *topicpb.TopicPublishRequest) (*topicpb.TopicPublishResponse, error)

Publish to a given topic