Documentation ¶
Index ¶
- type Manager
- func (_m *Manager) CheckDatatype(ctx context.Context, ns string, datatype *fftypes.Datatype) error
- func (_m *Manager) DownloadBlob(ctx context.Context, ns string, dataID string) (*fftypes.Blob, io.ReadCloser, error)
- func (_m *Manager) GetMessageDataCached(ctx context.Context, msg *fftypes.Message, options ...data.CacheReadOption) (fftypes.DataArray, bool, error)
- func (_m *Manager) GetMessageWithDataCached(ctx context.Context, msgID *fftypes.UUID, options ...data.CacheReadOption) (*fftypes.Message, fftypes.DataArray, bool, error)
- func (_m *Manager) HydrateBatch(ctx context.Context, persistedBatch *fftypes.BatchPersisted) (*fftypes.Batch, error)
- func (_m *Manager) PeekMessageCache(ctx context.Context, id *fftypes.UUID, options ...data.CacheReadOption) (*fftypes.Message, fftypes.DataArray)
- func (_m *Manager) ResolveInlineData(ctx context.Context, msg *data.NewMessage) error
- func (_m *Manager) UpdateMessageCache(msg *fftypes.Message, _a1 fftypes.DataArray)
- func (_m *Manager) UpdateMessageIfCached(ctx context.Context, msg *fftypes.Message)
- func (_m *Manager) UpdateMessageStateIfCached(ctx context.Context, id *fftypes.UUID, state fftypes.FFEnum, ...)
- func (_m *Manager) UploadBlob(ctx context.Context, ns string, inData *fftypes.DataRefOrValue, ...) (*fftypes.Data, error)
- func (_m *Manager) UploadJSON(ctx context.Context, ns string, inData *fftypes.DataRefOrValue) (*fftypes.Data, error)
- func (_m *Manager) ValidateAll(ctx context.Context, _a1 fftypes.DataArray) (bool, error)
- func (_m *Manager) VerifyNamespaceExists(ctx context.Context, ns string) error
- func (_m *Manager) WaitStop()
- func (_m *Manager) WriteNewMessage(ctx context.Context, newMsg *data.NewMessage) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Manager ¶
Manager is an autogenerated mock type for the Manager type
func (*Manager) CheckDatatype ¶
CheckDatatype provides a mock function with given fields: ctx, ns, datatype
func (*Manager) DownloadBlob ¶ added in v1.0.0
func (_m *Manager) DownloadBlob(ctx context.Context, ns string, dataID string) (*fftypes.Blob, io.ReadCloser, error)
DownloadBlob provides a mock function with given fields: ctx, ns, dataID
func (*Manager) GetMessageDataCached ¶ added in v0.14.0
func (_m *Manager) GetMessageDataCached(ctx context.Context, msg *fftypes.Message, options ...data.CacheReadOption) (fftypes.DataArray, bool, error)
GetMessageDataCached provides a mock function with given fields: ctx, msg, options
func (*Manager) GetMessageWithDataCached ¶ added in v0.14.0
func (_m *Manager) GetMessageWithDataCached(ctx context.Context, msgID *fftypes.UUID, options ...data.CacheReadOption) (*fftypes.Message, fftypes.DataArray, bool, error)
GetMessageWithDataCached provides a mock function with given fields: ctx, msgID, options
func (*Manager) HydrateBatch ¶ added in v0.14.0
func (_m *Manager) HydrateBatch(ctx context.Context, persistedBatch *fftypes.BatchPersisted) (*fftypes.Batch, error)
HydrateBatch provides a mock function with given fields: ctx, persistedBatch
func (*Manager) PeekMessageCache ¶ added in v0.14.0
func (_m *Manager) PeekMessageCache(ctx context.Context, id *fftypes.UUID, options ...data.CacheReadOption) (*fftypes.Message, fftypes.DataArray)
PeekMessageCache provides a mock function with given fields: ctx, id, options
func (*Manager) ResolveInlineData ¶ added in v0.14.0
ResolveInlineData provides a mock function with given fields: ctx, msg
func (*Manager) UpdateMessageCache ¶ added in v0.14.0
UpdateMessageCache provides a mock function with given fields: msg, _a1
func (*Manager) UpdateMessageIfCached ¶ added in v0.14.0
UpdateMessageIfCached provides a mock function with given fields: ctx, msg
func (*Manager) UpdateMessageStateIfCached ¶ added in v1.0.0
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 ¶ added in v1.0.0
func (_m *Manager) UploadBlob(ctx context.Context, ns string, inData *fftypes.DataRefOrValue, blob *fftypes.Multipart, autoMeta bool) (*fftypes.Data, error)
UploadBlob provides a mock function with given fields: ctx, ns, inData, blob, autoMeta
func (*Manager) UploadJSON ¶
func (_m *Manager) UploadJSON(ctx context.Context, ns string, inData *fftypes.DataRefOrValue) (*fftypes.Data, error)
UploadJSON provides a mock function with given fields: ctx, ns, inData
func (*Manager) ValidateAll ¶
ValidateAll provides a mock function with given fields: ctx, _a1
func (*Manager) VerifyNamespaceExists ¶
VerifyNamespaceExists provides a mock function with given fields: ctx, ns
func (*Manager) WaitStop ¶ added in v0.14.0
func (_m *Manager) WaitStop()
WaitStop provides a mock function with given fields:
func (*Manager) WriteNewMessage ¶ added in v0.14.0
WriteNewMessage provides a mock function with given fields: ctx, newMsg