awssns

Documentation

Index

• Constants
• Variables
• type AWSSNS
  • func New(connOpts *opts.ConnectionOptions) (*AWSSNS, error)
  • func (a *AWSSNS) Close(_ context.Context) error
  • func (a *AWSSNS) DisplayError(msg *records.ErrorRecord) error
  • func (a *AWSSNS) DisplayMessage(cliOpts *opts.CLIOptions, msg *records.ReadRecord) error
  • func (a *AWSSNS) Name() string
  • func (a *AWSSNS) Read(ctx context.Context, readOpts *opts.ReadOptions, ...) error
  • func (a *AWSSNS) Relay(ctx context.Context, relayOpts *opts.RelayOptions, relayCh chan interface{}, ...) error
  • func (a *AWSSNS) Test(_ context.Context) error
  • func (a *AWSSNS) Tunnel(ctx context.Context, tunnelOpts *opts.TunnelOptions, tunnelSvc tunnel.ITunnel, ...) error
  • func (a *AWSSNS) Write(_ context.Context, writeOpts *opts.WriteOptions, ...) error

Constants

const BackendName = "AWSSNS"

Variables

var ErrMissingTopicARN = errors.New("--topic cannot be empty")

Types

type AWSSNS

type AWSSNS struct {
	Service  snsiface.SNSAPI
	QueueURL string
	// contains filtered or unexported fields
}

func New

func New(connOpts *opts.ConnectionOptions) (*AWSSNS, error)

func (*AWSSNS) Close

func (a *AWSSNS) Close(_ context.Context) error

func (*AWSSNS) DisplayError

func (a *AWSSNS) DisplayError(msg *records.ErrorRecord) error

func (*AWSSNS) DisplayMessage

func (a *AWSSNS) DisplayMessage(cliOpts *opts.CLIOptions, msg *records.ReadRecord) error

DisplayMessage returns nothing because SNS is a publish only backend

func (*AWSSNS) Name

func (a *AWSSNS) Name() string

func (*AWSSNS) Read

func (a *AWSSNS) Read(ctx context.Context, readOpts *opts.ReadOptions, resultsChan chan *records.ReadRecord, errorChan chan *records.ErrorRecord) error

func (*AWSSNS) Relay

func (a *AWSSNS) Relay(ctx context.Context, relayOpts *opts.RelayOptions, relayCh chan interface{}, errorCh chan<- *records.ErrorRecord) error

func (*AWSSNS) Test

func (a *AWSSNS) Test(_ context.Context) error

func (*AWSSNS) Tunnel

func (a *AWSSNS) Tunnel(ctx context.Context, tunnelOpts *opts.TunnelOptions, tunnelSvc tunnel.ITunnel, errorCh chan<- *records.ErrorRecord) error

func (*AWSSNS) Write

func (a *AWSSNS) Write(_ context.Context, writeOpts *opts.WriteOptions, errorCh chan<- *records.ErrorRecord, messages ...*records.WriteRecord) error