persistencemocks

Documentation

Index

• type Persistence
  • func (_m *Persistence) Close(ctx context.Context)
  • func (_m *Persistence) DeleteCheckpoint(ctx context.Context, streamID *fftypes.UUID) error
  • func (_m *Persistence) DeleteListener(ctx context.Context, listenerID *fftypes.UUID) error
  • func (_m *Persistence) DeleteStream(ctx context.Context, streamID *fftypes.UUID) error
  • func (_m *Persistence) DeleteTransaction(ctx context.Context, txID string) error
  • func (_m *Persistence) GetCheckpoint(ctx context.Context, streamID *fftypes.UUID) (*apitypes.EventStreamCheckpoint, error)
  • func (_m *Persistence) GetListener(ctx context.Context, listenerID *fftypes.UUID) (*apitypes.Listener, error)
  • func (_m *Persistence) GetStream(ctx context.Context, streamID *fftypes.UUID) (*apitypes.EventStream, error)
  • func (_m *Persistence) GetTransactionByID(ctx context.Context, txID string) (*apitypes.ManagedTX, error)
  • func (_m *Persistence) GetTransactionByNonce(ctx context.Context, signer string, nonce *fftypes.FFBigInt) (*apitypes.ManagedTX, error)
  • func (_m *Persistence) ListListeners(ctx context.Context, after *fftypes.UUID, limit int, ...) ([]*apitypes.Listener, error)
  • func (_m *Persistence) ListStreamListeners(ctx context.Context, after *fftypes.UUID, limit int, ...) ([]*apitypes.Listener, error)
  • func (_m *Persistence) ListStreams(ctx context.Context, after *fftypes.UUID, limit int, ...) ([]*apitypes.EventStream, error)
  • func (_m *Persistence) ListTransactionsByCreateTime(ctx context.Context, after *apitypes.ManagedTX, limit int, ...) ([]*apitypes.ManagedTX, error)
  • func (_m *Persistence) ListTransactionsByNonce(ctx context.Context, signer string, after *fftypes.FFBigInt, limit int, ...) ([]*apitypes.ManagedTX, error)
  • func (_m *Persistence) ListTransactionsPending(ctx context.Context, after *fftypes.UUID, limit int, ...) ([]*apitypes.ManagedTX, error)
  • func (_m *Persistence) WriteCheckpoint(ctx context.Context, checkpoint *apitypes.EventStreamCheckpoint) error
  • func (_m *Persistence) WriteListener(ctx context.Context, spec *apitypes.Listener) error
  • func (_m *Persistence) WriteStream(ctx context.Context, spec *apitypes.EventStream) error
  • func (_m *Persistence) WriteTransaction(ctx context.Context, tx *apitypes.ManagedTX, new bool) error

Types

type Persistence

type Persistence struct {
	mock.Mock
}

Persistence is an autogenerated mock type for the Persistence type

func (*Persistence) Close

func (_m *Persistence) Close(ctx context.Context)

Close provides a mock function with given fields: ctx

func (*Persistence) DeleteCheckpoint

func (_m *Persistence) DeleteCheckpoint(ctx context.Context, streamID *fftypes.UUID) error

DeleteCheckpoint provides a mock function with given fields: ctx, streamID

func (*Persistence) DeleteListener

func (_m *Persistence) DeleteListener(ctx context.Context, listenerID *fftypes.UUID) error

DeleteListener provides a mock function with given fields: ctx, listenerID

func (*Persistence) DeleteStream

func (_m *Persistence) DeleteStream(ctx context.Context, streamID *fftypes.UUID) error

DeleteStream provides a mock function with given fields: ctx, streamID

func (*Persistence) DeleteTransaction

func (_m *Persistence) DeleteTransaction(ctx context.Context, txID string) error

DeleteTransaction provides a mock function with given fields: ctx, txID

func (*Persistence) GetCheckpoint

func (_m *Persistence) GetCheckpoint(ctx context.Context, streamID *fftypes.UUID) (*apitypes.EventStreamCheckpoint, error)

GetCheckpoint provides a mock function with given fields: ctx, streamID

func (*Persistence) GetListener

func (_m *Persistence) GetListener(ctx context.Context, listenerID *fftypes.UUID) (*apitypes.Listener, error)

GetListener provides a mock function with given fields: ctx, listenerID

func (*Persistence) GetStream

func (_m *Persistence) GetStream(ctx context.Context, streamID *fftypes.UUID) (*apitypes.EventStream, error)

GetStream provides a mock function with given fields: ctx, streamID

func (*Persistence) GetTransactionByID

func (_m *Persistence) GetTransactionByID(ctx context.Context, txID string) (*apitypes.ManagedTX, error)

GetTransactionByID provides a mock function with given fields: ctx, txID

func (*Persistence) GetTransactionByNonce

func (_m *Persistence) GetTransactionByNonce(ctx context.Context, signer string, nonce *fftypes.FFBigInt) (*apitypes.ManagedTX, error)

GetTransactionByNonce provides a mock function with given fields: ctx, signer, nonce

func (*Persistence) ListListeners

func (_m *Persistence) ListListeners(ctx context.Context, after *fftypes.UUID, limit int, dir persistence.SortDirection) ([]*apitypes.Listener, error)

ListListeners provides a mock function with given fields: ctx, after, limit, dir

func (*Persistence) ListStreamListeners

func (_m *Persistence) ListStreamListeners(ctx context.Context, after *fftypes.UUID, limit int, dir persistence.SortDirection, streamID *fftypes.UUID) ([]*apitypes.Listener, error)

ListStreamListeners provides a mock function with given fields: ctx, after, limit, dir, streamID

func (*Persistence) ListStreams

func (_m *Persistence) ListStreams(ctx context.Context, after *fftypes.UUID, limit int, dir persistence.SortDirection) ([]*apitypes.EventStream, error)

ListStreams provides a mock function with given fields: ctx, after, limit, dir

func (*Persistence) ListTransactionsByCreateTime

func (_m *Persistence) ListTransactionsByCreateTime(ctx context.Context, after *apitypes.ManagedTX, limit int, dir persistence.SortDirection) ([]*apitypes.ManagedTX, error)

ListTransactionsByCreateTime provides a mock function with given fields: ctx, after, limit, dir

func (*Persistence) ListTransactionsByNonce

func (_m *Persistence) ListTransactionsByNonce(ctx context.Context, signer string, after *fftypes.FFBigInt, limit int, dir persistence.SortDirection) ([]*apitypes.ManagedTX, error)

ListTransactionsByNonce provides a mock function with given fields: ctx, signer, after, limit, dir

func (*Persistence) ListTransactionsPending

func (_m *Persistence) ListTransactionsPending(ctx context.Context, after *fftypes.UUID, limit int, dir persistence.SortDirection) ([]*apitypes.ManagedTX, error)

ListTransactionsPending provides a mock function with given fields: ctx, after, limit, dir

func (*Persistence) WriteCheckpoint

func (_m *Persistence) WriteCheckpoint(ctx context.Context, checkpoint *apitypes.EventStreamCheckpoint) error

WriteCheckpoint provides a mock function with given fields: ctx, checkpoint

func (*Persistence) WriteListener

func (_m *Persistence) WriteListener(ctx context.Context, spec *apitypes.Listener) error

WriteListener provides a mock function with given fields: ctx, spec

func (*Persistence) WriteStream

func (_m *Persistence) WriteStream(ctx context.Context, spec *apitypes.EventStream) error

WriteStream provides a mock function with given fields: ctx, spec

func (*Persistence) WriteTransaction

func (_m *Persistence) WriteTransaction(ctx context.Context, tx *apitypes.ManagedTX, new bool) error

WriteTransaction provides a mock function with given fields: ctx, tx, new