wiretap

Documentation

Index

• type Wiretap
  • func New(broker, configBase string) (*Wiretap, error)
  • func (w *Wiretap) BrokerLogs(ctx context.Context) (io.ReadCloser, error)
  • func (w *Wiretap) Cleanup(ctx context.Context) error
  • func (w *Wiretap) CreateAdapter(ctx context.Context) (io.ReadCloser, error)
  • func (w *Wiretap) CreateTrigger(eventTypes []string) error

Types

type Wiretap

type Wiretap struct {
	Broker      string
	ConfigBase  string
	Destination string
	// contains filtered or unexported fields
}

func New

func New(broker, configBase string) (*Wiretap, error)

func (*Wiretap) BrokerLogs

func (w *Wiretap) BrokerLogs(ctx context.Context) (io.ReadCloser, error)

func (*Wiretap) Cleanup

func (w *Wiretap) Cleanup(ctx context.Context) error

func (*Wiretap) CreateAdapter

func (w *Wiretap) CreateAdapter(ctx context.Context) (io.ReadCloser, error)

func (*Wiretap) CreateTrigger

func (w *Wiretap) CreateTrigger(eventTypes []string) error