Documentation
¶
Index ¶
- Constants
- Variables
- type AWSSNS
- 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 ¶
View Source
const BackendName = "AWSSNS"
Variables ¶
View Source
var ErrMissingTopicARN = errors.New("--topic cannot be empty")
Functions ¶
This section is empty.
Types ¶
type AWSSNS ¶
type AWSSNS struct {
Service snsiface.SNSAPI
QueueURL string
// contains filtered or unexported fields
}
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) 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) Tunnel ¶ added in v1.4.0
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
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.