streamer

Documentation

Index

• type MockStreamer
  • func (streamer MockStreamer) Push(ctx context.Context, records []Record) error
• type Record
• type Streamer
  • func NewMockStreamer() (Streamer, error)

Types

type MockStreamer

type MockStreamer struct{}

func (MockStreamer) Push

func (streamer MockStreamer) Push(ctx context.Context, records []Record) error

type Record

type Record struct {
	AggregateID string `json:"id"`
	Type        string `json:"t"`
	Data        []byte `json:"d"`
}

type Streamer

type Streamer interface {
	Push(ctx context.Context, records []Record) error
}

Streamer -

func NewMockStreamer

func NewMockStreamer() (Streamer, error)