persistence

package
v3.2.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 20, 2024 License: MIT Imports: 3 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type EventsStore 

type EventsStore struct {
	mock.Mock
}

EventsStore is an autogenerated mock type for the EventsStore type

func NewEventsStore 

func NewEventsStore(t interface {
	mock.TestingT
	Cleanup(func())
}) *EventsStore

NewEventsStore creates a new instance of EventsStore. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*EventsStore) Connect 

func (_m *EventsStore) Connect(ctx context.Context) error

Connect provides a mock function with given fields: ctx

func (*EventsStore) DeleteEvents 

func (_m *EventsStore) DeleteEvents(ctx context.Context, persistenceID string, toSequenceNumber uint64) error

DeleteEvents provides a mock function with given fields: ctx, persistenceID, toSequenceNumber

func (*EventsStore) Disconnect 

func (_m *EventsStore) Disconnect(ctx context.Context) error

Disconnect provides a mock function with given fields: ctx

func (*EventsStore) EXPECT 

func (_m *EventsStore) EXPECT() *EventsStore_Expecter

func (*EventsStore) GetLatestEvent 

func (_m *EventsStore) GetLatestEvent(ctx context.Context, persistenceID string) (*egopb.Event, error)

GetLatestEvent provides a mock function with given fields: ctx, persistenceID

func (*EventsStore) GetShardEvents 

func (_m *EventsStore) GetShardEvents(ctx context.Context, shardNumber uint64, offset int64, max uint64) ([]*egopb.Event, int64, error)

GetShardEvents provides a mock function with given fields: ctx, shardNumber, offset, max

func (*EventsStore) PersistenceIDs 

func (_m *EventsStore) PersistenceIDs(ctx context.Context, pageSize uint64, pageToken string) ([]string, string, error)

PersistenceIDs provides a mock function with given fields: ctx, pageSize, pageToken

func (*EventsStore) Ping 

func (_m *EventsStore) Ping(ctx context.Context) error

Ping provides a mock function with given fields: ctx

func (*EventsStore) ReplayEvents 

func (_m *EventsStore) ReplayEvents(ctx context.Context, persistenceID string, fromSequenceNumber uint64, toSequenceNumber uint64, max uint64) ([]*egopb.Event, error)

ReplayEvents provides a mock function with given fields: ctx, persistenceID, fromSequenceNumber, toSequenceNumber, max

func (*EventsStore) ShardNumbers 

func (_m *EventsStore) ShardNumbers(ctx context.Context) ([]uint64, error)

ShardNumbers provides a mock function with given fields: ctx

func (*EventsStore) WriteEvents 

func (_m *EventsStore) WriteEvents(ctx context.Context, events []*egopb.Event) error

WriteEvents provides a mock function with given fields: ctx, events

type EventsStore_Connect_Call 

type EventsStore_Connect_Call struct {
	*mock.Call
}

EventsStore_Connect_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Connect'

func (*EventsStore_Connect_Call) Return 

func (_c *EventsStore_Connect_Call) Return(_a0 error) *EventsStore_Connect_Call

func (*EventsStore_Connect_Call) Run 

func (_c *EventsStore_Connect_Call) Run(run func(ctx context.Context)) *EventsStore_Connect_Call

func (*EventsStore_Connect_Call) RunAndReturn 

func (_c *EventsStore_Connect_Call) RunAndReturn(run func(context.Context) error) *EventsStore_Connect_Call

type EventsStore_DeleteEvents_Call 

type EventsStore_DeleteEvents_Call struct {
	*mock.Call
}

EventsStore_DeleteEvents_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DeleteEvents'

func (*EventsStore_DeleteEvents_Call) Return 

func (_c *EventsStore_DeleteEvents_Call) Return(_a0 error) *EventsStore_DeleteEvents_Call

func (*EventsStore_DeleteEvents_Call) Run 

func (_c *EventsStore_DeleteEvents_Call) Run(run func(ctx context.Context, persistenceID string, toSequenceNumber uint64)) *EventsStore_DeleteEvents_Call

func (*EventsStore_DeleteEvents_Call) RunAndReturn 

func (_c *EventsStore_DeleteEvents_Call) RunAndReturn(run func(context.Context, string, uint64) error) *EventsStore_DeleteEvents_Call

type EventsStore_Disconnect_Call 

type EventsStore_Disconnect_Call struct {
	*mock.Call
}

EventsStore_Disconnect_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Disconnect'

func (*EventsStore_Disconnect_Call) Return 

func (_c *EventsStore_Disconnect_Call) Return(_a0 error) *EventsStore_Disconnect_Call

func (*EventsStore_Disconnect_Call) Run 

func (_c *EventsStore_Disconnect_Call) Run(run func(ctx context.Context)) *EventsStore_Disconnect_Call

func (*EventsStore_Disconnect_Call) RunAndReturn 

func (_c *EventsStore_Disconnect_Call) RunAndReturn(run func(context.Context) error) *EventsStore_Disconnect_Call

type EventsStore_Expecter 

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

func (*EventsStore_Expecter) Connect 

func (_e *EventsStore_Expecter) Connect(ctx interface{}) *EventsStore_Connect_Call

Connect is a helper method to define mock.On call

  • ctx context.Context

func (*EventsStore_Expecter) DeleteEvents 

func (_e *EventsStore_Expecter) DeleteEvents(ctx interface{}, persistenceID interface{}, toSequenceNumber interface{}) *EventsStore_DeleteEvents_Call

DeleteEvents is a helper method to define mock.On call

  • ctx context.Context
  • persistenceID string
  • toSequenceNumber uint64

func (*EventsStore_Expecter) Disconnect 

func (_e *EventsStore_Expecter) Disconnect(ctx interface{}) *EventsStore_Disconnect_Call

Disconnect is a helper method to define mock.On call

  • ctx context.Context

func (*EventsStore_Expecter) GetLatestEvent 

func (_e *EventsStore_Expecter) GetLatestEvent(ctx interface{}, persistenceID interface{}) *EventsStore_GetLatestEvent_Call

GetLatestEvent is a helper method to define mock.On call

  • ctx context.Context
  • persistenceID string

func (*EventsStore_Expecter) GetShardEvents 

func (_e *EventsStore_Expecter) GetShardEvents(ctx interface{}, shardNumber interface{}, offset interface{}, max interface{}) *EventsStore_GetShardEvents_Call

GetShardEvents is a helper method to define mock.On call

  • ctx context.Context
  • shardNumber uint64
  • offset int64
  • max uint64

func (*EventsStore_Expecter) PersistenceIDs 

func (_e *EventsStore_Expecter) PersistenceIDs(ctx interface{}, pageSize interface{}, pageToken interface{}) *EventsStore_PersistenceIDs_Call

PersistenceIDs is a helper method to define mock.On call

  • ctx context.Context
  • pageSize uint64
  • pageToken string

func (*EventsStore_Expecter) Ping 

func (_e *EventsStore_Expecter) Ping(ctx interface{}) *EventsStore_Ping_Call

Ping is a helper method to define mock.On call

  • ctx context.Context

func (*EventsStore_Expecter) ReplayEvents 

func (_e *EventsStore_Expecter) ReplayEvents(ctx interface{}, persistenceID interface{}, fromSequenceNumber interface{}, toSequenceNumber interface{}, max interface{}) *EventsStore_ReplayEvents_Call

ReplayEvents is a helper method to define mock.On call

  • ctx context.Context
  • persistenceID string
  • fromSequenceNumber uint64
  • toSequenceNumber uint64
  • max uint64

func (*EventsStore_Expecter) ShardNumbers 

func (_e *EventsStore_Expecter) ShardNumbers(ctx interface{}) *EventsStore_ShardNumbers_Call

ShardNumbers is a helper method to define mock.On call

  • ctx context.Context

func (*EventsStore_Expecter) WriteEvents 

func (_e *EventsStore_Expecter) WriteEvents(ctx interface{}, events interface{}) *EventsStore_WriteEvents_Call

WriteEvents is a helper method to define mock.On call

  • ctx context.Context
  • events []*egopb.Event

type EventsStore_GetLatestEvent_Call 

type EventsStore_GetLatestEvent_Call struct {
	*mock.Call
}

EventsStore_GetLatestEvent_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetLatestEvent'

func (*EventsStore_GetLatestEvent_Call) Return 

func (_c *EventsStore_GetLatestEvent_Call) Return(_a0 *egopb.Event, _a1 error) *EventsStore_GetLatestEvent_Call

func (*EventsStore_GetLatestEvent_Call) Run 

func (_c *EventsStore_GetLatestEvent_Call) Run(run func(ctx context.Context, persistenceID string)) *EventsStore_GetLatestEvent_Call

func (*EventsStore_GetLatestEvent_Call) RunAndReturn 

func (_c *EventsStore_GetLatestEvent_Call) RunAndReturn(run func(context.Context, string) (*egopb.Event, error)) *EventsStore_GetLatestEvent_Call

type EventsStore_GetShardEvents_Call 

type EventsStore_GetShardEvents_Call struct {
	*mock.Call
}

EventsStore_GetShardEvents_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetShardEvents'

func (*EventsStore_GetShardEvents_Call) Return 

func (_c *EventsStore_GetShardEvents_Call) Return(_a0 []*egopb.Event, _a1 int64, _a2 error) *EventsStore_GetShardEvents_Call

func (*EventsStore_GetShardEvents_Call) Run 

func (_c *EventsStore_GetShardEvents_Call) Run(run func(ctx context.Context, shardNumber uint64, offset int64, max uint64)) *EventsStore_GetShardEvents_Call

func (*EventsStore_GetShardEvents_Call) RunAndReturn 

func (_c *EventsStore_GetShardEvents_Call) RunAndReturn(run func(context.Context, uint64, int64, uint64) ([]*egopb.Event, int64, error)) *EventsStore_GetShardEvents_Call

type EventsStore_PersistenceIDs_Call 

type EventsStore_PersistenceIDs_Call struct {
	*mock.Call
}

EventsStore_PersistenceIDs_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'PersistenceIDs'

func (*EventsStore_PersistenceIDs_Call) Return 

func (_c *EventsStore_PersistenceIDs_Call) Return(persistenceIDs []string, nextPageToken string, err error) *EventsStore_PersistenceIDs_Call

func (*EventsStore_PersistenceIDs_Call) Run 

func (_c *EventsStore_PersistenceIDs_Call) Run(run func(ctx context.Context, pageSize uint64, pageToken string)) *EventsStore_PersistenceIDs_Call

func (*EventsStore_PersistenceIDs_Call) RunAndReturn 

func (_c *EventsStore_PersistenceIDs_Call) RunAndReturn(run func(context.Context, uint64, string) ([]string, string, error)) *EventsStore_PersistenceIDs_Call

type EventsStore_Ping_Call 

type EventsStore_Ping_Call struct {
	*mock.Call
}

EventsStore_Ping_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Ping'

func (*EventsStore_Ping_Call) Return 

func (_c *EventsStore_Ping_Call) Return(_a0 error) *EventsStore_Ping_Call

func (*EventsStore_Ping_Call) Run 

func (_c *EventsStore_Ping_Call) Run(run func(ctx context.Context)) *EventsStore_Ping_Call

func (*EventsStore_Ping_Call) RunAndReturn 

func (_c *EventsStore_Ping_Call) RunAndReturn(run func(context.Context) error) *EventsStore_Ping_Call

type EventsStore_ReplayEvents_Call 

type EventsStore_ReplayEvents_Call struct {
	*mock.Call
}

EventsStore_ReplayEvents_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ReplayEvents'

func (*EventsStore_ReplayEvents_Call) Return 

func (_c *EventsStore_ReplayEvents_Call) Return(_a0 []*egopb.Event, _a1 error) *EventsStore_ReplayEvents_Call

func (*EventsStore_ReplayEvents_Call) Run 

func (_c *EventsStore_ReplayEvents_Call) Run(run func(ctx context.Context, persistenceID string, fromSequenceNumber uint64, toSequenceNumber uint64, max uint64)) *EventsStore_ReplayEvents_Call

func (*EventsStore_ReplayEvents_Call) RunAndReturn 

func (_c *EventsStore_ReplayEvents_Call) RunAndReturn(run func(context.Context, string, uint64, uint64, uint64) ([]*egopb.Event, error)) *EventsStore_ReplayEvents_Call

type EventsStore_ShardNumbers_Call 

type EventsStore_ShardNumbers_Call struct {
	*mock.Call
}

EventsStore_ShardNumbers_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ShardNumbers'

func (*EventsStore_ShardNumbers_Call) Return 

func (_c *EventsStore_ShardNumbers_Call) Return(_a0 []uint64, _a1 error) *EventsStore_ShardNumbers_Call

func (*EventsStore_ShardNumbers_Call) Run 

func (_c *EventsStore_ShardNumbers_Call) Run(run func(ctx context.Context)) *EventsStore_ShardNumbers_Call

func (*EventsStore_ShardNumbers_Call) RunAndReturn 

func (_c *EventsStore_ShardNumbers_Call) RunAndReturn(run func(context.Context) ([]uint64, error)) *EventsStore_ShardNumbers_Call

type EventsStore_WriteEvents_Call 

type EventsStore_WriteEvents_Call struct {
	*mock.Call
}

EventsStore_WriteEvents_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'WriteEvents'

func (*EventsStore_WriteEvents_Call) Return 

func (_c *EventsStore_WriteEvents_Call) Return(_a0 error) *EventsStore_WriteEvents_Call

func (*EventsStore_WriteEvents_Call) Run 

func (_c *EventsStore_WriteEvents_Call) Run(run func(ctx context.Context, events []*egopb.Event)) *EventsStore_WriteEvents_Call

func (*EventsStore_WriteEvents_Call) RunAndReturn 

func (_c *EventsStore_WriteEvents_Call) RunAndReturn(run func(context.Context, []*egopb.Event) error) *EventsStore_WriteEvents_Call

type StateStore 

type StateStore struct {
	mock.Mock
}

StateStore is an autogenerated mock type for the StateStore type

func NewStateStore 

func NewStateStore(t interface {
	mock.TestingT
	Cleanup(func())
}) *StateStore

NewStateStore creates a new instance of StateStore. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*StateStore) Connect 

func (_m *StateStore) Connect(ctx context.Context) error

Connect provides a mock function with given fields: ctx

func (*StateStore) Disconnect 

func (_m *StateStore) Disconnect(ctx context.Context) error

Disconnect provides a mock function with given fields: ctx

func (*StateStore) EXPECT 

func (_m *StateStore) EXPECT() *StateStore_Expecter

func (*StateStore) GetLatestState 

func (_m *StateStore) GetLatestState(ctx context.Context, persistenceID string) (*egopb.DurableState, error)

GetLatestState provides a mock function with given fields: ctx, persistenceID

func (*StateStore) Ping 

func (_m *StateStore) Ping(ctx context.Context) error

Ping provides a mock function with given fields: ctx

func (*StateStore) WriteState 

func (_m *StateStore) WriteState(ctx context.Context, state *egopb.DurableState) error

WriteState provides a mock function with given fields: ctx, state

type StateStore_Connect_Call 

type StateStore_Connect_Call struct {
	*mock.Call
}

StateStore_Connect_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Connect'

func (*StateStore_Connect_Call) Return 

func (_c *StateStore_Connect_Call) Return(_a0 error) *StateStore_Connect_Call

func (*StateStore_Connect_Call) Run 

func (_c *StateStore_Connect_Call) Run(run func(ctx context.Context)) *StateStore_Connect_Call

func (*StateStore_Connect_Call) RunAndReturn 

func (_c *StateStore_Connect_Call) RunAndReturn(run func(context.Context) error) *StateStore_Connect_Call

type StateStore_Disconnect_Call 

type StateStore_Disconnect_Call struct {
	*mock.Call
}

StateStore_Disconnect_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Disconnect'

func (*StateStore_Disconnect_Call) Return 

func (_c *StateStore_Disconnect_Call) Return(_a0 error) *StateStore_Disconnect_Call

func (*StateStore_Disconnect_Call) Run 

func (_c *StateStore_Disconnect_Call) Run(run func(ctx context.Context)) *StateStore_Disconnect_Call

func (*StateStore_Disconnect_Call) RunAndReturn 

func (_c *StateStore_Disconnect_Call) RunAndReturn(run func(context.Context) error) *StateStore_Disconnect_Call

type StateStore_Expecter 

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

func (*StateStore_Expecter) Connect 

func (_e *StateStore_Expecter) Connect(ctx interface{}) *StateStore_Connect_Call

Connect is a helper method to define mock.On call

  • ctx context.Context

func (*StateStore_Expecter) Disconnect 

func (_e *StateStore_Expecter) Disconnect(ctx interface{}) *StateStore_Disconnect_Call

Disconnect is a helper method to define mock.On call

  • ctx context.Context

func (*StateStore_Expecter) GetLatestState 

func (_e *StateStore_Expecter) GetLatestState(ctx interface{}, persistenceID interface{}) *StateStore_GetLatestState_Call

GetLatestState is a helper method to define mock.On call

  • ctx context.Context
  • persistenceID string

func (*StateStore_Expecter) Ping 

func (_e *StateStore_Expecter) Ping(ctx interface{}) *StateStore_Ping_Call

Ping is a helper method to define mock.On call

  • ctx context.Context

func (*StateStore_Expecter) WriteState 

func (_e *StateStore_Expecter) WriteState(ctx interface{}, state interface{}) *StateStore_WriteState_Call

WriteState is a helper method to define mock.On call

  • ctx context.Context
  • state *egopb.DurableState

type StateStore_GetLatestState_Call 

type StateStore_GetLatestState_Call struct {
	*mock.Call
}

StateStore_GetLatestState_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetLatestState'

func (*StateStore_GetLatestState_Call) Return 

func (_c *StateStore_GetLatestState_Call) Return(_a0 *egopb.DurableState, _a1 error) *StateStore_GetLatestState_Call

func (*StateStore_GetLatestState_Call) Run 

func (_c *StateStore_GetLatestState_Call) Run(run func(ctx context.Context, persistenceID string)) *StateStore_GetLatestState_Call

func (*StateStore_GetLatestState_Call) RunAndReturn 

func (_c *StateStore_GetLatestState_Call) RunAndReturn(run func(context.Context, string) (*egopb.DurableState, error)) *StateStore_GetLatestState_Call

type StateStore_Ping_Call 

type StateStore_Ping_Call struct {
	*mock.Call
}

StateStore_Ping_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Ping'

func (*StateStore_Ping_Call) Return 

func (_c *StateStore_Ping_Call) Return(_a0 error) *StateStore_Ping_Call

func (*StateStore_Ping_Call) Run 

func (_c *StateStore_Ping_Call) Run(run func(ctx context.Context)) *StateStore_Ping_Call

func (*StateStore_Ping_Call) RunAndReturn 

func (_c *StateStore_Ping_Call) RunAndReturn(run func(context.Context) error) *StateStore_Ping_Call

type StateStore_WriteState_Call 

type StateStore_WriteState_Call struct {
	*mock.Call
}

StateStore_WriteState_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'WriteState'

func (*StateStore_WriteState_Call) Return 

func (_c *StateStore_WriteState_Call) Return(_a0 error) *StateStore_WriteState_Call

func (*StateStore_WriteState_Call) Run 

func (_c *StateStore_WriteState_Call) Run(run func(ctx context.Context, state *egopb.DurableState)) *StateStore_WriteState_Call

func (*StateStore_WriteState_Call) RunAndReturn 

func (_c *StateStore_WriteState_Call) RunAndReturn(run func(context.Context, *egopb.DurableState) error) *StateStore_WriteState_Call

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.