Documentation ¶
Index ¶
- type Orchestrator
- func (_m *Orchestrator) Assets() assets.Manager
- func (_m *Orchestrator) BatchManager() batch.Manager
- func (_m *Orchestrator) Broadcast() broadcast.Manager
- func (_m *Orchestrator) Contracts() contracts.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.BatchPersisted, error)
- func (_m *Orchestrator) GetBatches(ctx context.Context, ns string, filter database.AndFilter) ([]*fftypes.BatchPersisted, *database.FilterResult, error)
- func (_m *Orchestrator) GetBlockchainEventByID(ctx context.Context, id *fftypes.UUID) (*fftypes.BlockchainEvent, error)
- func (_m *Orchestrator) GetBlockchainEvents(ctx context.Context, ns string, filter database.AndFilter) ([]*fftypes.BlockchainEvent, *database.FilterResult, error)
- func (_m *Orchestrator) GetChartHistogram(ctx context.Context, ns string, startTime int64, endTime int64, buckets int64, ...) ([]*fftypes.ChartHistogram, 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.DataArray, *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) GetEventsWithReferences(ctx context.Context, ns string, filter database.AndFilter) ([]*fftypes.EnrichedEvent, *database.FilterResult, error)
- func (_m *Orchestrator) GetMessageByID(ctx context.Context, ns string, id string) (*fftypes.Message, error)
- func (_m *Orchestrator) GetMessageByIDWithData(ctx context.Context, ns string, id string) (*fftypes.MessageInOut, error)
- func (_m *Orchestrator) GetMessageData(ctx context.Context, ns string, id string) (fftypes.DataArray, 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) GetMessagesWithData(ctx context.Context, ns string, filter database.AndFilter) ([]*fftypes.MessageInOut, *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) GetPins(ctx context.Context, filter database.AndFilter) ([]*fftypes.Pin, *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) GetTransactionBlockchainEvents(ctx context.Context, ns string, id string) ([]*fftypes.BlockchainEvent, *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) GetTransactionStatus(ctx context.Context, ns string, id string) (*fftypes.TransactionStatus, 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) Metrics() metrics.Manager
- func (_m *Orchestrator) NetworkMap() networkmap.Manager
- func (_m *Orchestrator) Operations() operations.Manager
- func (_m *Orchestrator) PrivateMessaging() privatemessaging.Manager
- func (_m *Orchestrator) PutConfigRecord(ctx context.Context, key string, configRecord *fftypes.JSONAny) (*fftypes.JSONAny, 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) BatchManager ¶ added in v0.13.0
func (_m *Orchestrator) BatchManager() batch.Manager
BatchManager 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) Contracts ¶ added in v0.12.0
func (_m *Orchestrator) Contracts() contracts.Manager
Contracts 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.BatchPersisted, 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.BatchPersisted, *database.FilterResult, error)
GetBatches provides a mock function with given fields: ctx, ns, filter
func (*Orchestrator) GetBlockchainEventByID ¶ added in v0.12.0
func (_m *Orchestrator) GetBlockchainEventByID(ctx context.Context, id *fftypes.UUID) (*fftypes.BlockchainEvent, error)
GetBlockchainEventByID provides a mock function with given fields: ctx, id
func (*Orchestrator) GetBlockchainEvents ¶ added in v0.12.0
func (_m *Orchestrator) GetBlockchainEvents(ctx context.Context, ns string, filter database.AndFilter) ([]*fftypes.BlockchainEvent, *database.FilterResult, error)
GetBlockchainEvents provides a mock function with given fields: ctx, ns, filter
func (*Orchestrator) GetChartHistogram ¶ added in v0.11.2
func (_m *Orchestrator) GetChartHistogram(ctx context.Context, ns string, startTime int64, endTime int64, buckets int64, tableName database.CollectionName) ([]*fftypes.ChartHistogram, error)
GetChartHistogram provides a mock function with given fields: ctx, ns, startTime, endTime, buckets, tableName
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.DataArray, *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) GetEventsWithReferences ¶ added in v0.14.0
func (_m *Orchestrator) GetEventsWithReferences(ctx context.Context, ns string, filter database.AndFilter) ([]*fftypes.EnrichedEvent, *database.FilterResult, error)
GetEventsWithReferences provides a mock function with given fields: ctx, ns, filter
func (*Orchestrator) GetMessageByID ¶
func (_m *Orchestrator) GetMessageByID(ctx context.Context, ns string, id string) (*fftypes.Message, error)
GetMessageByID provides a mock function with given fields: ctx, ns, id
func (*Orchestrator) GetMessageByIDWithData ¶ added in v0.11.0
func (_m *Orchestrator) GetMessageByIDWithData(ctx context.Context, ns string, id string) (*fftypes.MessageInOut, error)
GetMessageByIDWithData provides a mock function with given fields: ctx, ns, id
func (*Orchestrator) GetMessageData ¶
func (_m *Orchestrator) GetMessageData(ctx context.Context, ns string, id string) (fftypes.DataArray, 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) GetMessagesWithData ¶ added in v0.11.0
func (_m *Orchestrator) GetMessagesWithData(ctx context.Context, ns string, filter database.AndFilter) ([]*fftypes.MessageInOut, *database.FilterResult, error)
GetMessagesWithData provides a mock function with given fields: ctx, ns, 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) GetPins ¶ added in v0.14.0
func (_m *Orchestrator) GetPins(ctx context.Context, filter database.AndFilter) ([]*fftypes.Pin, *database.FilterResult, error)
GetPins provides a mock function with given fields: ctx, 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) GetTransactionBlockchainEvents ¶ added in v0.12.0
func (_m *Orchestrator) GetTransactionBlockchainEvents(ctx context.Context, ns string, id string) ([]*fftypes.BlockchainEvent, *database.FilterResult, error)
GetTransactionBlockchainEvents provides a mock function with given fields: ctx, ns, id
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) GetTransactionStatus ¶ added in v0.12.0
func (_m *Orchestrator) GetTransactionStatus(ctx context.Context, ns string, id string) (*fftypes.TransactionStatus, error)
GetTransactionStatus 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) Metrics ¶ added in v0.13.0
func (_m *Orchestrator) Metrics() metrics.Manager
Metrics 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) Operations ¶ added in v0.14.0
func (_m *Orchestrator) Operations() operations.Manager
Operations 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.JSONAny) (*fftypes.JSONAny, 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: