collection

Documentation

Index

• type AckFunc
• type ChannelCollector
  • func (c *ChannelCollector) Collect(ctx context.Context, req *CollectRequest) error
• type CollectRequest
• type Collector
  • func NewChannelCollector(c chan CollectRequest) Collector
• type MockCollector
  • func (m *MockCollector) Collect(ctx context.Context, req *CollectRequest) error

Types

type AckFunc

type AckFunc func(err error)

type ChannelCollector

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

func (*ChannelCollector) Collect

func (c *ChannelCollector) Collect(ctx context.Context, req *CollectRequest) error

type CollectRequest

type CollectRequest struct {
	ConnectionIdentifier identification.Identifier
	TimeConsumed         time.Time
	TimePushed           time.Time
	AckFunc
	*pb.SendEventRequest
}

type Collector

type Collector interface {
	Collect(ctx context.Context, req *CollectRequest) error
}

func NewChannelCollector

func NewChannelCollector(c chan CollectRequest) Collector

type MockCollector

type MockCollector struct {
	mock.Mock
}

func (*MockCollector) Collect

func (m *MockCollector) Collect(ctx context.Context, req *CollectRequest) error