eventbridge

README

Installation

go get -u  github.com/mmadfox/es/eventbridge/eventbridge

Documentation

Overview

Package eventbridge is a generated GoMock package.

Index

• type DB
• type Dup
• type ErrorFunc
• type ErrorHandlerFunc
• type Event
• type EventFunc
• type Hook
• type Metrics
• type MockDB
  • func NewMockDB(ctrl *gomock.Controller) *MockDB
  • func (m *MockDB) Close() error
  • func (m *MockDB) Connect(ctx context.Context, fn func() error) error
  • func (m *MockDB) EXPECT() *MockDBMockRecorder
  • func (m *MockDB) OnEvent(eventFunc EventFunc)
  • func (m *MockDB) UpdateVersion(ctx context.Context, streamID, streamType string, version int) error
  • func (m *MockDB) WalkUnpublishedEvents(ctx context.Context, fn UnpublishedStreamFunc) error
• type MockDBMockRecorder
  • func (mr *MockDBMockRecorder) Close() *gomock.Call
  • func (mr *MockDBMockRecorder) Connect(ctx, fn interface{}) *gomock.Call
  • func (mr *MockDBMockRecorder) OnEvent(eventFunc interface{}) *gomock.Call
  • func (mr *MockDBMockRecorder) UpdateVersion(ctx, streamID, streamType, version interface{}) *gomock.Call
  • func (mr *MockDBMockRecorder) WalkUnpublishedEvents(ctx, fn interface{}) *gomock.Call
• type Sync
  • func New(db DB, pub esmessagingkafka.Client, dup Dup, sc Metrics, ...) *Sync
  • func (s *Sync) Close() (err error)
  • func (s *Sync) Run(ctx context.Context) error
• type UnpublishedStream
  • func (ua UnpublishedStream) TotalUnpublished() int
• type UnpublishedStreamFunc

Types

type DB

type DB interface {
	WalkUnpublishedEvents(ctx context.Context, fn UnpublishedStreamFunc) error
	UpdateVersion(ctx context.Context, streamID string, streamType string, version int) (err error)
	OnEvent(eventFunc EventFunc)
	Connect(ctx context.Context, fn func() error) error
	Close() error
}

type Dup

type Dup interface {
	Exists(e *Event) bool
	Ensure(e *Event)
}

type ErrorFunc

type ErrorFunc func(context.Context, error)

type ErrorHandlerFunc

type ErrorHandlerFunc func(ctx context.Context, err error)

type Event

type Event struct {
	StreamID   string
	StreamType string
	EventType  string
	Version    int
	Serialized []byte
}

type EventFunc

type EventFunc func(context.Context, *Event) error

type Hook

type Hook func(context.Context) error

type Metrics

type Metrics interface {
	WalkUnpublishedEventsInc()
	PublishEventInc(streamType string, eventType string)
}

type MockDB

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

MockDB is a mock of DB interface

func NewMockDB

func NewMockDB(ctrl *gomock.Controller) *MockDB

NewMockDB creates a new mock instance

func (*MockDB) Close

func (m *MockDB) Close() error

Close mocks base method

func (*MockDB) Connect

func (m *MockDB) Connect(ctx context.Context, fn func() error) error

Connect mocks base method

func (*MockDB) EXPECT

func (m *MockDB) EXPECT() *MockDBMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockDB) OnEvent

func (m *MockDB) OnEvent(eventFunc EventFunc)

OnEvent mocks base method

func (*MockDB) UpdateVersion

func (m *MockDB) UpdateVersion(ctx context.Context, streamID, streamType string, version int) error

UpdateVersion mocks base method

func (*MockDB) WalkUnpublishedEvents

func (m *MockDB) WalkUnpublishedEvents(ctx context.Context, fn UnpublishedStreamFunc) error

WalkUnpublishedEvents mocks base method

type MockDBMockRecorder

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

MockDBMockRecorder is the mock recorder for MockDB

func (*MockDBMockRecorder) Close

func (mr *MockDBMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close

func (*MockDBMockRecorder) Connect

func (mr *MockDBMockRecorder) Connect(ctx, fn interface{}) *gomock.Call

Connect indicates an expected call of Connect

func (*MockDBMockRecorder) OnEvent

func (mr *MockDBMockRecorder) OnEvent(eventFunc interface{}) *gomock.Call

OnEvent indicates an expected call of OnEvent

func (*MockDBMockRecorder) UpdateVersion

func (mr *MockDBMockRecorder) UpdateVersion(ctx, streamID, streamType, version interface{}) *gomock.Call

UpdateVersion indicates an expected call of UpdateVersion

func (*MockDBMockRecorder) WalkUnpublishedEvents

func (mr *MockDBMockRecorder) WalkUnpublishedEvents(ctx, fn interface{}) *gomock.Call

WalkUnpublishedEvents indicates an expected call of WalkUnpublishedEvents

type Sync

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

func New

func New(
	db DB,
	pub esmessagingkafka.Client,
	dup Dup,
	sc Metrics,
	logger *zap.SugaredLogger,
	topicBuilder eseventbuskafka.TopicBuilder,
) *Sync

func (*Sync) Close

func (s *Sync) Close() (err error)

func (*Sync) Run

func (s *Sync) Run(ctx context.Context) error

type UnpublishedStream

type UnpublishedStream struct {
	StreamID               string
	StreamType             string
	LatestPublishedVersion int
	CurrentVersion         int
	Events                 []*Event
}

func (UnpublishedStream) TotalUnpublished

func (ua UnpublishedStream) TotalUnpublished() int

type UnpublishedStreamFunc

type UnpublishedStreamFunc func(ctx context.Context, stream *UnpublishedStream) error