eventchannel

Documentation

Index

• type EventChannel
  • func NewEventChannel(sender Sender, clock clock.Clock, maxByteSize, maxEventCount int64, ...) *EventChannel
  • func (c *EventChannel) Close()
  • func (c *EventChannel) Push(event []byte)
• type Limit
• type Metrics
• type Sender
  • func BuildEndpointSender(client *http.Client, baseUrl string, module string) Sender
  • func NewHttpSender(client *http.Client, endpoint string) Sender

Types

type EventChannel

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

func NewEventChannel

func NewEventChannel(sender Sender, clock clock.Clock, maxByteSize, maxEventCount int64, maxTime time.Duration) *EventChannel

func (*EventChannel) Close

func (c *EventChannel) Close()

func (*EventChannel) Push

func (c *EventChannel) Push(event []byte)

type Limit

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

type Metrics

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

type Sender

type Sender = func(payload []byte) error

func BuildEndpointSender

func BuildEndpointSender(client *http.Client, baseUrl string, module string) Sender

func NewHttpSender

func NewHttpSender(client *http.Client, endpoint string) Sender