datamocks

Documentation

Index

• type Manager
  • func NewManager(t mockConstructorTestingTNewManager) *Manager
  • func (_m *Manager) BlobsEnabled() bool
  • func (_m *Manager) CheckDatatype(ctx context.Context, datatype *core.Datatype) error
  • func (_m *Manager) DownloadBlob(ctx context.Context, dataID string) (*core.Blob, io.ReadCloser, error)
  • func (_m *Manager) GetMessageDataCached(ctx context.Context, msg *core.Message, options ...data.CacheReadOption) (core.DataArray, bool, error)
  • func (_m *Manager) GetMessageWithDataCached(ctx context.Context, msgID *fftypes.UUID, options ...data.CacheReadOption) (*core.Message, core.DataArray, bool, error)
  • func (_m *Manager) HydrateBatch(ctx context.Context, persistedBatch *core.BatchPersisted) (*core.Batch, error)
  • func (_m *Manager) PeekMessageCache(ctx context.Context, id *fftypes.UUID, options ...data.CacheReadOption) (*core.Message, core.DataArray)
  • func (_m *Manager) ResolveInlineData(ctx context.Context, msg *data.NewMessage) error
  • func (_m *Manager) Start()
  • func (_m *Manager) UpdateMessageCache(msg *core.Message, _a1 core.DataArray)
  • func (_m *Manager) UpdateMessageIfCached(ctx context.Context, msg *core.Message)
  • func (_m *Manager) UpdateMessageStateIfCached(ctx context.Context, id *fftypes.UUID, state fftypes.FFEnum, ...)
  • func (_m *Manager) UploadBlob(ctx context.Context, inData *core.DataRefOrValue, blob *ffapi.Multipart, ...) (*core.Data, error)
  • func (_m *Manager) UploadJSON(ctx context.Context, inData *core.DataRefOrValue) (*core.Data, error)
  • func (_m *Manager) ValidateAll(ctx context.Context, _a1 core.DataArray) (bool, error)
  • func (_m *Manager) WaitStop()
  • func (_m *Manager) WriteNewMessage(ctx context.Context, newMsg *data.NewMessage) error

Types

type Manager

type Manager struct {
	mock.Mock
}

Manager is an autogenerated mock type for the Manager type

func NewManager

func NewManager(t mockConstructorTestingTNewManager) *Manager

NewManager creates a new instance of Manager. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*Manager) BlobsEnabled

func (_m *Manager) BlobsEnabled() bool

BlobsEnabled provides a mock function with given fields:

func (*Manager) CheckDatatype

func (_m *Manager) CheckDatatype(ctx context.Context, datatype *core.Datatype) error

CheckDatatype provides a mock function with given fields: ctx, datatype

func (*Manager) DownloadBlob

func (_m *Manager) DownloadBlob(ctx context.Context, dataID string) (*core.Blob, io.ReadCloser, error)

DownloadBlob provides a mock function with given fields: ctx, dataID

func (*Manager) GetMessageDataCached

func (_m *Manager) GetMessageDataCached(ctx context.Context, msg *core.Message, options ...data.CacheReadOption) (core.DataArray, bool, error)

GetMessageDataCached provides a mock function with given fields: ctx, msg, options

func (*Manager) GetMessageWithDataCached

func (_m *Manager) GetMessageWithDataCached(ctx context.Context, msgID *fftypes.UUID, options ...data.CacheReadOption) (*core.Message, core.DataArray, bool, error)

GetMessageWithDataCached provides a mock function with given fields: ctx, msgID, options

func (*Manager) HydrateBatch

func (_m *Manager) HydrateBatch(ctx context.Context, persistedBatch *core.BatchPersisted) (*core.Batch, error)

HydrateBatch provides a mock function with given fields: ctx, persistedBatch

func (*Manager) PeekMessageCache

func (_m *Manager) PeekMessageCache(ctx context.Context, id *fftypes.UUID, options ...data.CacheReadOption) (*core.Message, core.DataArray)

PeekMessageCache provides a mock function with given fields: ctx, id, options

func (*Manager) ResolveInlineData

func (_m *Manager) ResolveInlineData(ctx context.Context, msg *data.NewMessage) error

ResolveInlineData provides a mock function with given fields: ctx, msg

func (*Manager) Start

func (_m *Manager) Start()

Start provides a mock function with given fields:

func (*Manager) UpdateMessageCache

func (_m *Manager) UpdateMessageCache(msg *core.Message, _a1 core.DataArray)

UpdateMessageCache provides a mock function with given fields: msg, _a1

func (*Manager) UpdateMessageIfCached

func (_m *Manager) UpdateMessageIfCached(ctx context.Context, msg *core.Message)

UpdateMessageIfCached provides a mock function with given fields: ctx, msg

func (*Manager) UpdateMessageStateIfCached

func (_m *Manager) UpdateMessageStateIfCached(ctx context.Context, id *fftypes.UUID, state fftypes.FFEnum, confirmed *fftypes.FFTime)

UpdateMessageStateIfCached provides a mock function with given fields: ctx, id, state, confirmed

func (*Manager) UploadBlob

func (_m *Manager) UploadBlob(ctx context.Context, inData *core.DataRefOrValue, blob *ffapi.Multipart, autoMeta bool) (*core.Data, error)

UploadBlob provides a mock function with given fields: ctx, inData, blob, autoMeta

func (*Manager) UploadJSON

func (_m *Manager) UploadJSON(ctx context.Context, inData *core.DataRefOrValue) (*core.Data, error)

UploadJSON provides a mock function with given fields: ctx, inData

func (*Manager) ValidateAll

func (_m *Manager) ValidateAll(ctx context.Context, _a1 core.DataArray) (bool, error)

ValidateAll provides a mock function with given fields: ctx, _a1

func (*Manager) WaitStop

func (_m *Manager) WaitStop()

WaitStop provides a mock function with given fields:

func (*Manager) WriteNewMessage

func (_m *Manager) WriteNewMessage(ctx context.Context, newMsg *data.NewMessage) error

WriteNewMessage provides a mock function with given fields: ctx, newMsg