awssns

Documentation

Index

• func Dynamic(opts *cli.Options) error
• func NewService(opts *cli.Options) (*sns.SNS, error)
• func Write(opts *cli.Options, md *desc.MessageDescriptor) error
• type AWSSNS
  • func (a *AWSSNS) Write(value []byte) error

Functions

func Dynamic

func Dynamic(opts *cli.Options) error

Dynamic starts up a new GRPC client connected to the dProxy service and receives a stream of outbound replay messages which are then written to the message bus.

func NewService

func NewService(opts *cli.Options) (*sns.SNS, error)

func Write

func Write(opts *cli.Options, md *desc.MessageDescriptor) error

Types

type AWSSNS

type AWSSNS struct {
	Options  *cli.Options
	Service  types.ISNSAPI
	QueueURL string
	MsgDesc  *desc.MessageDescriptor
	// contains filtered or unexported fields
}

func (*AWSSNS) Write

func (a *AWSSNS) Write(value []byte) error