mocks

Documentation

Index

• type Store
  • func (m *Store) Ack(ctx context.Context, le *schemalog.LogEntry) error
  • func (m *Store) Close() error
  • func (m *Store) Fetch(ctx context.Context, schemaName string, ackedOnly bool) (*schemalog.LogEntry, error)
  • func (m *Store) GetAckCalls() uint64
  • func (m *Store) GetFetchCalls() uint64
  • func (m *Store) GetInsertCalls() uint64
  • func (m *Store) Insert(ctx context.Context, schemaName string) (*schemalog.LogEntry, error)

Types

type Store

type Store struct {
	InsertFn func(ctx context.Context, schemaName string) (*schemalog.LogEntry, error)
	FetchFn  func(ctx context.Context, schemaName string, ackedOnly bool) (*schemalog.LogEntry, error)
	AckFn    func(ctx context.Context, le *schemalog.LogEntry) error
	CloseFn  func() error
	// contains filtered or unexported fields
}

func (*Store) Ack

func (m *Store) Ack(ctx context.Context, le *schemalog.LogEntry) error

func (*Store) Close

func (m *Store) Close() error

func (*Store) Fetch

func (m *Store) Fetch(ctx context.Context, schemaName string, ackedOnly bool) (*schemalog.LogEntry, error)

func (*Store) GetAckCalls

func (m *Store) GetAckCalls() uint64

func (*Store) GetFetchCalls

func (m *Store) GetFetchCalls() uint64

func (*Store) GetInsertCalls

func (m *Store) GetInsertCalls() uint64

func (*Store) Insert

func (m *Store) Insert(ctx context.Context, schemaName string) (*schemalog.LogEntry, error)