eventbridge

Documentation

Index

• type EventBridgeClient
• type EventBridgeProducer
  • func NewProducer(destination *backendconfig.DestinationT, o common.Opts) (*EventBridgeProducer, error)
  • func (*EventBridgeProducer) Close() error
  • func (producer *EventBridgeProducer) Produce(jsonData json.RawMessage, _ interface{}) (int, string, string)

Types

type EventBridgeClient

type EventBridgeClient interface {
	PutEvents(input *eventbridge.PutEventsInput) (*eventbridge.PutEventsOutput, error)
}

type EventBridgeProducer

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

func NewProducer

func NewProducer(destination *backendconfig.DestinationT, o common.Opts) (*EventBridgeProducer, error)

NewProducer creates a producer based on destination config

func (*EventBridgeProducer) Close

func (*EventBridgeProducer) Close() error

func (*EventBridgeProducer) Produce

func (producer *EventBridgeProducer) Produce(jsonData json.RawMessage, _ interface{}) (int, string, string)

Produce creates a producer and send data to EventBridge.