Documentation ¶
Index ¶
- type Orchestrator
- func (_m *Orchestrator) Assets() assets.Manager
- func (_m *Orchestrator) Broadcast() broadcast.Manager
- func (_m *Orchestrator) CreateSubscription(ctx context.Context, ns string, subDef *fftypes.Subscription) (*fftypes.Subscription, error)
- func (_m *Orchestrator) CreateUpdateSubscription(ctx context.Context, ns string, subDef *fftypes.Subscription) (*fftypes.Subscription, error)
- func (_m *Orchestrator) Data() data.Manager
- func (_m *Orchestrator) DeleteConfigRecord(ctx context.Context, key string) error
- func (_m *Orchestrator) DeleteSubscription(ctx context.Context, ns string, id string) error
- func (_m *Orchestrator) Events() events.EventManager
- func (_m *Orchestrator) GetBatchByID(ctx context.Context, ns string, id string) (*fftypes.Batch, error)
- func (_m *Orchestrator) GetBatches(ctx context.Context, ns string, filter database.AndFilter) ([]*fftypes.Batch, *database.FilterResult, error)
- func (_m *Orchestrator) GetConfig(ctx context.Context) fftypes.JSONObject
- func (_m *Orchestrator) GetConfigRecord(ctx context.Context, key string) (*fftypes.ConfigRecord, error)
- func (_m *Orchestrator) GetConfigRecords(ctx context.Context, filter database.AndFilter) ([]*fftypes.ConfigRecord, *database.FilterResult, error)
- func (_m *Orchestrator) GetData(ctx context.Context, ns string, filter database.AndFilter) ([]*fftypes.Data, *database.FilterResult, error)
- func (_m *Orchestrator) GetDataByID(ctx context.Context, ns string, id string) (*fftypes.Data, error)
- func (_m *Orchestrator) GetDatatypeByID(ctx context.Context, ns string, id string) (*fftypes.Datatype, error)
- func (_m *Orchestrator) GetDatatypeByName(ctx context.Context, ns string, name string, version string) (*fftypes.Datatype, error)
- func (_m *Orchestrator) GetDatatypes(ctx context.Context, ns string, filter database.AndFilter) ([]*fftypes.Datatype, *database.FilterResult, error)
- func (_m *Orchestrator) GetEventByID(ctx context.Context, ns string, id string) (*fftypes.Event, error)
- func (_m *Orchestrator) GetEvents(ctx context.Context, ns string, filter database.AndFilter) ([]*fftypes.Event, *database.FilterResult, error)
- func (_m *Orchestrator) GetMessageByID(ctx context.Context, ns string, id string, withValues bool) (*fftypes.MessageInOut, error)
- func (_m *Orchestrator) GetMessageData(ctx context.Context, ns string, id string) ([]*fftypes.Data, error)
- func (_m *Orchestrator) GetMessageEvents(ctx context.Context, ns string, id string, filter database.AndFilter) ([]*fftypes.Event, *database.FilterResult, error)
- func (_m *Orchestrator) GetMessageOperations(ctx context.Context, ns string, id string) ([]*fftypes.Operation, *database.FilterResult, error)
- func (_m *Orchestrator) GetMessageTransaction(ctx context.Context, ns string, id string) (*fftypes.Transaction, error)
- func (_m *Orchestrator) GetMessages(ctx context.Context, ns string, filter database.AndFilter) ([]*fftypes.Message, *database.FilterResult, error)
- func (_m *Orchestrator) GetMessagesForData(ctx context.Context, ns string, dataID string, filter database.AndFilter) ([]*fftypes.Message, *database.FilterResult, error)
- func (_m *Orchestrator) GetNamespace(ctx context.Context, ns string) (*fftypes.Namespace, error)
- func (_m *Orchestrator) GetNamespaces(ctx context.Context, filter database.AndFilter) ([]*fftypes.Namespace, *database.FilterResult, error)
- func (_m *Orchestrator) GetOperationByID(ctx context.Context, ns string, id string) (*fftypes.Operation, error)
- func (_m *Orchestrator) GetOperations(ctx context.Context, ns string, filter database.AndFilter) ([]*fftypes.Operation, *database.FilterResult, error)
- func (_m *Orchestrator) GetStatus(ctx context.Context) (*fftypes.NodeStatus, error)
- func (_m *Orchestrator) GetSubscriptionByID(ctx context.Context, ns string, id string) (*fftypes.Subscription, error)
- func (_m *Orchestrator) GetSubscriptions(ctx context.Context, ns string, filter database.AndFilter) ([]*fftypes.Subscription, *database.FilterResult, error)
- func (_m *Orchestrator) GetTransactionByID(ctx context.Context, ns string, id string) (*fftypes.Transaction, error)
- func (_m *Orchestrator) GetTransactionOperations(ctx context.Context, ns string, id string) ([]*fftypes.Operation, *database.FilterResult, error)
- func (_m *Orchestrator) GetTransactions(ctx context.Context, ns string, filter database.AndFilter) ([]*fftypes.Transaction, *database.FilterResult, error)
- func (_m *Orchestrator) Init(ctx context.Context, cancelCtx context.CancelFunc) error
- func (_m *Orchestrator) IsPreInit() bool
- func (_m *Orchestrator) NetworkMap() networkmap.Manager
- func (_m *Orchestrator) PrivateMessaging() privatemessaging.Manager
- func (_m *Orchestrator) PutConfigRecord(ctx context.Context, key string, configRecord fftypes.Byteable) (fftypes.Byteable, error)
- func (_m *Orchestrator) RequestReply(ctx context.Context, ns string, msg *fftypes.MessageInOut) (*fftypes.MessageInOut, error)
- func (_m *Orchestrator) ResetConfig(ctx context.Context)
- func (_m *Orchestrator) Start() error
- func (_m *Orchestrator) WaitStop()
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Orchestrator ¶
Orchestrator is an autogenerated mock type for the Orchestrator type
func (*Orchestrator) Assets ¶
func (_m *Orchestrator) Assets() assets.Manager
Assets provides a mock function with given fields:
func (*Orchestrator) Broadcast ¶
func (_m *Orchestrator) Broadcast() broadcast.Manager
Broadcast provides a mock function with given fields:
func (*Orchestrator) CreateSubscription ¶
func (_m *Orchestrator) CreateSubscription(ctx context.Context, ns string, subDef *fftypes.Subscription) (*fftypes.Subscription, error)
CreateSubscription provides a mock function with given fields: ctx, ns, subDef
func (*Orchestrator) CreateUpdateSubscription ¶
func (_m *Orchestrator) CreateUpdateSubscription(ctx context.Context, ns string, subDef *fftypes.Subscription) (*fftypes.Subscription, error)
CreateUpdateSubscription provides a mock function with given fields: ctx, ns, subDef
func (*Orchestrator) Data ¶
func (_m *Orchestrator) Data() data.Manager
Data provides a mock function with given fields:
func (*Orchestrator) DeleteConfigRecord ¶
func (_m *Orchestrator) DeleteConfigRecord(ctx context.Context, key string) error
DeleteConfigRecord provides a mock function with given fields: ctx, key
func (*Orchestrator) DeleteSubscription ¶
DeleteSubscription provides a mock function with given fields: ctx, ns, id
func (*Orchestrator) Events ¶
func (_m *Orchestrator) Events() events.EventManager
Events provides a mock function with given fields:
func (*Orchestrator) GetBatchByID ¶
func (_m *Orchestrator) GetBatchByID(ctx context.Context, ns string, id string) (*fftypes.Batch, error)
GetBatchByID provides a mock function with given fields: ctx, ns, id
func (*Orchestrator) GetBatches ¶
func (_m *Orchestrator) GetBatches(ctx context.Context, ns string, filter database.AndFilter) ([]*fftypes.Batch, *database.FilterResult, error)
GetBatches provides a mock function with given fields: ctx, ns, filter
func (*Orchestrator) GetConfig ¶
func (_m *Orchestrator) GetConfig(ctx context.Context) fftypes.JSONObject
GetConfig provides a mock function with given fields: ctx
func (*Orchestrator) GetConfigRecord ¶
func (_m *Orchestrator) GetConfigRecord(ctx context.Context, key string) (*fftypes.ConfigRecord, error)
GetConfigRecord provides a mock function with given fields: ctx, key
func (*Orchestrator) GetConfigRecords ¶
func (_m *Orchestrator) GetConfigRecords(ctx context.Context, filter database.AndFilter) ([]*fftypes.ConfigRecord, *database.FilterResult, error)
GetConfigRecords provides a mock function with given fields: ctx, filter
func (*Orchestrator) GetData ¶
func (_m *Orchestrator) GetData(ctx context.Context, ns string, filter database.AndFilter) ([]*fftypes.Data, *database.FilterResult, error)
GetData provides a mock function with given fields: ctx, ns, filter
func (*Orchestrator) GetDataByID ¶
func (_m *Orchestrator) GetDataByID(ctx context.Context, ns string, id string) (*fftypes.Data, error)
GetDataByID provides a mock function with given fields: ctx, ns, id
func (*Orchestrator) GetDatatypeByID ¶
func (_m *Orchestrator) GetDatatypeByID(ctx context.Context, ns string, id string) (*fftypes.Datatype, error)
GetDatatypeByID provides a mock function with given fields: ctx, ns, id
func (*Orchestrator) GetDatatypeByName ¶
func (_m *Orchestrator) GetDatatypeByName(ctx context.Context, ns string, name string, version string) (*fftypes.Datatype, error)
GetDatatypeByName provides a mock function with given fields: ctx, ns, name, version
func (*Orchestrator) GetDatatypes ¶
func (_m *Orchestrator) GetDatatypes(ctx context.Context, ns string, filter database.AndFilter) ([]*fftypes.Datatype, *database.FilterResult, error)
GetDatatypes provides a mock function with given fields: ctx, ns, filter
func (*Orchestrator) GetEventByID ¶
func (_m *Orchestrator) GetEventByID(ctx context.Context, ns string, id string) (*fftypes.Event, error)
GetEventByID provides a mock function with given fields: ctx, ns, id
func (*Orchestrator) GetEvents ¶
func (_m *Orchestrator) GetEvents(ctx context.Context, ns string, filter database.AndFilter) ([]*fftypes.Event, *database.FilterResult, error)
GetEvents provides a mock function with given fields: ctx, ns, filter
func (*Orchestrator) GetMessageByID ¶
func (_m *Orchestrator) GetMessageByID(ctx context.Context, ns string, id string, withValues bool) (*fftypes.MessageInOut, error)
GetMessageByID provides a mock function with given fields: ctx, ns, id, withValues
func (*Orchestrator) GetMessageData ¶
func (_m *Orchestrator) GetMessageData(ctx context.Context, ns string, id string) ([]*fftypes.Data, error)
GetMessageData provides a mock function with given fields: ctx, ns, id
func (*Orchestrator) GetMessageEvents ¶
func (_m *Orchestrator) GetMessageEvents(ctx context.Context, ns string, id string, filter database.AndFilter) ([]*fftypes.Event, *database.FilterResult, error)
GetMessageEvents provides a mock function with given fields: ctx, ns, id, filter
func (*Orchestrator) GetMessageOperations ¶
func (_m *Orchestrator) GetMessageOperations(ctx context.Context, ns string, id string) ([]*fftypes.Operation, *database.FilterResult, error)
GetMessageOperations provides a mock function with given fields: ctx, ns, id
func (*Orchestrator) GetMessageTransaction ¶
func (_m *Orchestrator) GetMessageTransaction(ctx context.Context, ns string, id string) (*fftypes.Transaction, error)
GetMessageTransaction provides a mock function with given fields: ctx, ns, id
func (*Orchestrator) GetMessages ¶
func (_m *Orchestrator) GetMessages(ctx context.Context, ns string, filter database.AndFilter) ([]*fftypes.Message, *database.FilterResult, error)
GetMessages provides a mock function with given fields: ctx, ns, filter
func (*Orchestrator) GetMessagesForData ¶
func (_m *Orchestrator) GetMessagesForData(ctx context.Context, ns string, dataID string, filter database.AndFilter) ([]*fftypes.Message, *database.FilterResult, error)
GetMessagesForData provides a mock function with given fields: ctx, ns, dataID, filter
func (*Orchestrator) GetNamespace ¶
GetNamespace provides a mock function with given fields: ctx, ns
func (*Orchestrator) GetNamespaces ¶
func (_m *Orchestrator) GetNamespaces(ctx context.Context, filter database.AndFilter) ([]*fftypes.Namespace, *database.FilterResult, error)
GetNamespaces provides a mock function with given fields: ctx, filter
func (*Orchestrator) GetOperationByID ¶
func (_m *Orchestrator) GetOperationByID(ctx context.Context, ns string, id string) (*fftypes.Operation, error)
GetOperationByID provides a mock function with given fields: ctx, ns, id
func (*Orchestrator) GetOperations ¶
func (_m *Orchestrator) GetOperations(ctx context.Context, ns string, filter database.AndFilter) ([]*fftypes.Operation, *database.FilterResult, error)
GetOperations provides a mock function with given fields: ctx, ns, filter
func (*Orchestrator) GetStatus ¶
func (_m *Orchestrator) GetStatus(ctx context.Context) (*fftypes.NodeStatus, error)
GetStatus provides a mock function with given fields: ctx
func (*Orchestrator) GetSubscriptionByID ¶
func (_m *Orchestrator) GetSubscriptionByID(ctx context.Context, ns string, id string) (*fftypes.Subscription, error)
GetSubscriptionByID provides a mock function with given fields: ctx, ns, id
func (*Orchestrator) GetSubscriptions ¶
func (_m *Orchestrator) GetSubscriptions(ctx context.Context, ns string, filter database.AndFilter) ([]*fftypes.Subscription, *database.FilterResult, error)
GetSubscriptions provides a mock function with given fields: ctx, ns, filter
func (*Orchestrator) GetTransactionByID ¶
func (_m *Orchestrator) GetTransactionByID(ctx context.Context, ns string, id string) (*fftypes.Transaction, error)
GetTransactionByID provides a mock function with given fields: ctx, ns, id
func (*Orchestrator) GetTransactionOperations ¶
func (_m *Orchestrator) GetTransactionOperations(ctx context.Context, ns string, id string) ([]*fftypes.Operation, *database.FilterResult, error)
GetTransactionOperations provides a mock function with given fields: ctx, ns, id
func (*Orchestrator) GetTransactions ¶
func (_m *Orchestrator) GetTransactions(ctx context.Context, ns string, filter database.AndFilter) ([]*fftypes.Transaction, *database.FilterResult, error)
GetTransactions provides a mock function with given fields: ctx, ns, filter
func (*Orchestrator) Init ¶
func (_m *Orchestrator) Init(ctx context.Context, cancelCtx context.CancelFunc) error
Init provides a mock function with given fields: ctx, cancelCtx
func (*Orchestrator) IsPreInit ¶
func (_m *Orchestrator) IsPreInit() bool
IsPreInit provides a mock function with given fields:
func (*Orchestrator) NetworkMap ¶
func (_m *Orchestrator) NetworkMap() networkmap.Manager
NetworkMap provides a mock function with given fields:
func (*Orchestrator) PrivateMessaging ¶
func (_m *Orchestrator) PrivateMessaging() privatemessaging.Manager
PrivateMessaging provides a mock function with given fields:
func (*Orchestrator) PutConfigRecord ¶
func (_m *Orchestrator) PutConfigRecord(ctx context.Context, key string, configRecord fftypes.Byteable) (fftypes.Byteable, error)
PutConfigRecord provides a mock function with given fields: ctx, key, configRecord
func (*Orchestrator) RequestReply ¶
func (_m *Orchestrator) RequestReply(ctx context.Context, ns string, msg *fftypes.MessageInOut) (*fftypes.MessageInOut, error)
RequestReply provides a mock function with given fields: ctx, ns, msg
func (*Orchestrator) ResetConfig ¶
func (_m *Orchestrator) ResetConfig(ctx context.Context)
ResetConfig provides a mock function with given fields: ctx
func (*Orchestrator) Start ¶
func (_m *Orchestrator) Start() error
Start provides a mock function with given fields:
func (*Orchestrator) WaitStop ¶
func (_m *Orchestrator) WaitStop()
WaitStop provides a mock function with given fields: