Documentation ¶
Index ¶
- type Orchestrator
- func (_m *Orchestrator) Assets() assets.Manager
- func (_m *Orchestrator) Authorize(ctx context.Context, authReq *fftypes.AuthReq) error
- 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, subDef *core.Subscription) (*core.Subscription, error)
- func (_m *Orchestrator) CreateUpdateSubscription(ctx context.Context, subDef *core.Subscription) (*core.Subscription, error)
- func (_m *Orchestrator) Data() data.Manager
- func (_m *Orchestrator) DefinitionSender() definitions.Sender
- func (_m *Orchestrator) DeleteSubscription(ctx context.Context, id string) error
- func (_m *Orchestrator) Events() events.EventManager
- func (_m *Orchestrator) GetBatchByID(ctx context.Context, id string) (*core.BatchPersisted, error)
- func (_m *Orchestrator) GetBatches(ctx context.Context, filter database.AndFilter) ([]*core.BatchPersisted, *database.FilterResult, error)
- func (_m *Orchestrator) GetBlockchainEventByID(ctx context.Context, id string) (*core.BlockchainEvent, error)
- func (_m *Orchestrator) GetBlockchainEvents(ctx context.Context, filter database.AndFilter) ([]*core.BlockchainEvent, *database.FilterResult, error)
- func (_m *Orchestrator) GetChartHistogram(ctx context.Context, startTime int64, endTime int64, buckets int64, ...) ([]*core.ChartHistogram, error)
- func (_m *Orchestrator) GetData(ctx context.Context, filter database.AndFilter) (core.DataArray, *database.FilterResult, error)
- func (_m *Orchestrator) GetDataByID(ctx context.Context, id string) (*core.Data, error)
- func (_m *Orchestrator) GetDatatypeByID(ctx context.Context, id string) (*core.Datatype, error)
- func (_m *Orchestrator) GetDatatypeByName(ctx context.Context, name string, version string) (*core.Datatype, error)
- func (_m *Orchestrator) GetDatatypes(ctx context.Context, filter database.AndFilter) ([]*core.Datatype, *database.FilterResult, error)
- func (_m *Orchestrator) GetEventByID(ctx context.Context, id string) (*core.Event, error)
- func (_m *Orchestrator) GetEventByIDWithReference(ctx context.Context, id string) (*core.EnrichedEvent, error)
- func (_m *Orchestrator) GetEvents(ctx context.Context, filter database.AndFilter) ([]*core.Event, *database.FilterResult, error)
- func (_m *Orchestrator) GetEventsWithReferences(ctx context.Context, filter database.AndFilter) ([]*core.EnrichedEvent, *database.FilterResult, error)
- func (_m *Orchestrator) GetMessageByID(ctx context.Context, id string) (*core.Message, error)
- func (_m *Orchestrator) GetMessageByIDWithData(ctx context.Context, id string) (*core.MessageInOut, error)
- func (_m *Orchestrator) GetMessageData(ctx context.Context, id string) (core.DataArray, error)
- func (_m *Orchestrator) GetMessageEvents(ctx context.Context, id string, filter database.AndFilter) ([]*core.Event, *database.FilterResult, error)
- func (_m *Orchestrator) GetMessageTransaction(ctx context.Context, id string) (*core.Transaction, error)
- func (_m *Orchestrator) GetMessages(ctx context.Context, filter database.AndFilter) ([]*core.Message, *database.FilterResult, error)
- func (_m *Orchestrator) GetMessagesForData(ctx context.Context, dataID string, filter database.AndFilter) ([]*core.Message, *database.FilterResult, error)
- func (_m *Orchestrator) GetMessagesWithData(ctx context.Context, filter database.AndFilter) ([]*core.MessageInOut, *database.FilterResult, error)
- func (_m *Orchestrator) GetNamespace(ctx context.Context) *core.Namespace
- func (_m *Orchestrator) GetOperationByID(ctx context.Context, id string) (*core.Operation, error)
- func (_m *Orchestrator) GetOperations(ctx context.Context, filter database.AndFilter) ([]*core.Operation, *database.FilterResult, error)
- func (_m *Orchestrator) GetPins(ctx context.Context, filter database.AndFilter) ([]*core.Pin, *database.FilterResult, error)
- func (_m *Orchestrator) GetStatus(ctx context.Context) (*core.NamespaceStatus, error)
- func (_m *Orchestrator) GetSubscriptionByID(ctx context.Context, id string) (*core.Subscription, error)
- func (_m *Orchestrator) GetSubscriptionByIDWithStatus(ctx context.Context, id string) (*core.SubscriptionWithStatus, error)
- func (_m *Orchestrator) GetSubscriptions(ctx context.Context, filter database.AndFilter) ([]*core.Subscription, *database.FilterResult, error)
- func (_m *Orchestrator) GetTransactionBlockchainEvents(ctx context.Context, id string) ([]*core.BlockchainEvent, *database.FilterResult, error)
- func (_m *Orchestrator) GetTransactionByID(ctx context.Context, id string) (*core.Transaction, error)
- func (_m *Orchestrator) GetTransactionOperations(ctx context.Context, id string) ([]*core.Operation, *database.FilterResult, error)
- func (_m *Orchestrator) GetTransactionStatus(ctx context.Context, id string) (*core.TransactionStatus, error)
- func (_m *Orchestrator) GetTransactions(ctx context.Context, filter database.AndFilter) ([]*core.Transaction, *database.FilterResult, error)
- func (_m *Orchestrator) Identity() identity.Manager
- func (_m *Orchestrator) Init(ctx context.Context, cancelCtx context.CancelFunc) error
- func (_m *Orchestrator) MultiParty() multiparty.Manager
- func (_m *Orchestrator) NetworkMap() networkmap.Manager
- func (_m *Orchestrator) Operations() operations.Manager
- func (_m *Orchestrator) PrivateMessaging() privatemessaging.Manager
- func (_m *Orchestrator) RequestReply(ctx context.Context, msg *core.MessageInOut) (*core.MessageInOut, error)
- func (_m *Orchestrator) RewindPins(ctx context.Context, rewind *core.PinRewind) (*core.PinRewind, error)
- func (_m *Orchestrator) Start() error
- func (_m *Orchestrator) SubmitNetworkAction(ctx context.Context, action *core.NetworkAction) 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 NewOrchestrator ¶ added in v1.1.2
func NewOrchestrator(t mockConstructorTestingTNewOrchestrator) *Orchestrator
NewOrchestrator creates a new instance of Orchestrator. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*Orchestrator) Assets ¶
func (_m *Orchestrator) Assets() assets.Manager
Assets provides a mock function with given fields:
func (*Orchestrator) Authorize ¶ added in v1.1.0
Authorize provides a mock function with given fields: ctx, authReq
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, subDef *core.Subscription) (*core.Subscription, error)
CreateSubscription provides a mock function with given fields: ctx, subDef
func (*Orchestrator) CreateUpdateSubscription ¶
func (_m *Orchestrator) CreateUpdateSubscription(ctx context.Context, subDef *core.Subscription) (*core.Subscription, error)
CreateUpdateSubscription provides a mock function with given fields: ctx, subDef
func (*Orchestrator) Data ¶
func (_m *Orchestrator) Data() data.Manager
Data provides a mock function with given fields:
func (*Orchestrator) DefinitionSender ¶ added in v1.1.0
func (_m *Orchestrator) DefinitionSender() definitions.Sender
DefinitionSender provides a mock function with given fields:
func (*Orchestrator) DeleteSubscription ¶
func (_m *Orchestrator) DeleteSubscription(ctx context.Context, id string) error
DeleteSubscription provides a mock function with given fields: ctx, 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, id string) (*core.BatchPersisted, error)
GetBatchByID provides a mock function with given fields: ctx, id
func (*Orchestrator) GetBatches ¶
func (_m *Orchestrator) GetBatches(ctx context.Context, filter database.AndFilter) ([]*core.BatchPersisted, *database.FilterResult, error)
GetBatches provides a mock function with given fields: ctx, filter
func (*Orchestrator) GetBlockchainEventByID ¶ added in v0.12.0
func (_m *Orchestrator) GetBlockchainEventByID(ctx context.Context, id string) (*core.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, filter database.AndFilter) ([]*core.BlockchainEvent, *database.FilterResult, error)
GetBlockchainEvents provides a mock function with given fields: ctx, filter
func (*Orchestrator) GetChartHistogram ¶ added in v0.11.2
func (_m *Orchestrator) GetChartHistogram(ctx context.Context, startTime int64, endTime int64, buckets int64, tableName database.CollectionName) ([]*core.ChartHistogram, error)
GetChartHistogram provides a mock function with given fields: ctx, startTime, endTime, buckets, tableName
func (*Orchestrator) GetData ¶
func (_m *Orchestrator) GetData(ctx context.Context, filter database.AndFilter) (core.DataArray, *database.FilterResult, error)
GetData provides a mock function with given fields: ctx, filter
func (*Orchestrator) GetDataByID ¶
GetDataByID provides a mock function with given fields: ctx, id
func (*Orchestrator) GetDatatypeByID ¶
GetDatatypeByID provides a mock function with given fields: ctx, id
func (*Orchestrator) GetDatatypeByName ¶
func (_m *Orchestrator) GetDatatypeByName(ctx context.Context, name string, version string) (*core.Datatype, error)
GetDatatypeByName provides a mock function with given fields: ctx, name, version
func (*Orchestrator) GetDatatypes ¶
func (_m *Orchestrator) GetDatatypes(ctx context.Context, filter database.AndFilter) ([]*core.Datatype, *database.FilterResult, error)
GetDatatypes provides a mock function with given fields: ctx, filter
func (*Orchestrator) GetEventByID ¶
GetEventByID provides a mock function with given fields: ctx, id
func (*Orchestrator) GetEventByIDWithReference ¶ added in v1.1.0
func (_m *Orchestrator) GetEventByIDWithReference(ctx context.Context, id string) (*core.EnrichedEvent, error)
GetEventByIDWithReference provides a mock function with given fields: ctx, id
func (*Orchestrator) GetEvents ¶
func (_m *Orchestrator) GetEvents(ctx context.Context, filter database.AndFilter) ([]*core.Event, *database.FilterResult, error)
GetEvents provides a mock function with given fields: ctx, filter
func (*Orchestrator) GetEventsWithReferences ¶ added in v0.14.0
func (_m *Orchestrator) GetEventsWithReferences(ctx context.Context, filter database.AndFilter) ([]*core.EnrichedEvent, *database.FilterResult, error)
GetEventsWithReferences provides a mock function with given fields: ctx, filter
func (*Orchestrator) GetMessageByID ¶
GetMessageByID provides a mock function with given fields: ctx, id
func (*Orchestrator) GetMessageByIDWithData ¶ added in v0.11.0
func (_m *Orchestrator) GetMessageByIDWithData(ctx context.Context, id string) (*core.MessageInOut, error)
GetMessageByIDWithData provides a mock function with given fields: ctx, id
func (*Orchestrator) GetMessageData ¶
GetMessageData provides a mock function with given fields: ctx, id
func (*Orchestrator) GetMessageEvents ¶
func (_m *Orchestrator) GetMessageEvents(ctx context.Context, id string, filter database.AndFilter) ([]*core.Event, *database.FilterResult, error)
GetMessageEvents provides a mock function with given fields: ctx, id, filter
func (*Orchestrator) GetMessageTransaction ¶
func (_m *Orchestrator) GetMessageTransaction(ctx context.Context, id string) (*core.Transaction, error)
GetMessageTransaction provides a mock function with given fields: ctx, id
func (*Orchestrator) GetMessages ¶
func (_m *Orchestrator) GetMessages(ctx context.Context, filter database.AndFilter) ([]*core.Message, *database.FilterResult, error)
GetMessages provides a mock function with given fields: ctx, filter
func (*Orchestrator) GetMessagesForData ¶
func (_m *Orchestrator) GetMessagesForData(ctx context.Context, dataID string, filter database.AndFilter) ([]*core.Message, *database.FilterResult, error)
GetMessagesForData provides a mock function with given fields: ctx, dataID, filter
func (*Orchestrator) GetMessagesWithData ¶ added in v0.11.0
func (_m *Orchestrator) GetMessagesWithData(ctx context.Context, filter database.AndFilter) ([]*core.MessageInOut, *database.FilterResult, error)
GetMessagesWithData provides a mock function with given fields: ctx, filter
func (*Orchestrator) GetNamespace ¶
func (_m *Orchestrator) GetNamespace(ctx context.Context) *core.Namespace
GetNamespace provides a mock function with given fields: ctx
func (*Orchestrator) GetOperationByID ¶
GetOperationByID provides a mock function with given fields: ctx, id
func (*Orchestrator) GetOperations ¶
func (_m *Orchestrator) GetOperations(ctx context.Context, filter database.AndFilter) ([]*core.Operation, *database.FilterResult, error)
GetOperations provides a mock function with given fields: ctx, filter
func (*Orchestrator) GetPins ¶ added in v0.14.0
func (_m *Orchestrator) GetPins(ctx context.Context, filter database.AndFilter) ([]*core.Pin, *database.FilterResult, error)
GetPins provides a mock function with given fields: ctx, filter
func (*Orchestrator) GetStatus ¶
func (_m *Orchestrator) GetStatus(ctx context.Context) (*core.NamespaceStatus, error)
GetStatus provides a mock function with given fields: ctx
func (*Orchestrator) GetSubscriptionByID ¶
func (_m *Orchestrator) GetSubscriptionByID(ctx context.Context, id string) (*core.Subscription, error)
GetSubscriptionByID provides a mock function with given fields: ctx, id
func (*Orchestrator) GetSubscriptionByIDWithStatus ¶ added in v1.1.0
func (_m *Orchestrator) GetSubscriptionByIDWithStatus(ctx context.Context, id string) (*core.SubscriptionWithStatus, error)
GetSubscriptionByIDWithStatus provides a mock function with given fields: ctx, id
func (*Orchestrator) GetSubscriptions ¶
func (_m *Orchestrator) GetSubscriptions(ctx context.Context, filter database.AndFilter) ([]*core.Subscription, *database.FilterResult, error)
GetSubscriptions provides a mock function with given fields: ctx, filter
func (*Orchestrator) GetTransactionBlockchainEvents ¶ added in v0.12.0
func (_m *Orchestrator) GetTransactionBlockchainEvents(ctx context.Context, id string) ([]*core.BlockchainEvent, *database.FilterResult, error)
GetTransactionBlockchainEvents provides a mock function with given fields: ctx, id
func (*Orchestrator) GetTransactionByID ¶
func (_m *Orchestrator) GetTransactionByID(ctx context.Context, id string) (*core.Transaction, error)
GetTransactionByID provides a mock function with given fields: ctx, id
func (*Orchestrator) GetTransactionOperations ¶
func (_m *Orchestrator) GetTransactionOperations(ctx context.Context, id string) ([]*core.Operation, *database.FilterResult, error)
GetTransactionOperations provides a mock function with given fields: ctx, id
func (*Orchestrator) GetTransactionStatus ¶ added in v0.12.0
func (_m *Orchestrator) GetTransactionStatus(ctx context.Context, id string) (*core.TransactionStatus, error)
GetTransactionStatus provides a mock function with given fields: ctx, id
func (*Orchestrator) GetTransactions ¶
func (_m *Orchestrator) GetTransactions(ctx context.Context, filter database.AndFilter) ([]*core.Transaction, *database.FilterResult, error)
GetTransactions provides a mock function with given fields: ctx, filter
func (*Orchestrator) Identity ¶ added in v1.1.0
func (_m *Orchestrator) Identity() identity.Manager
Identity provides a mock function with given fields:
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) MultiParty ¶ added in v1.1.0
func (_m *Orchestrator) MultiParty() multiparty.Manager
MultiParty 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) RequestReply ¶
func (_m *Orchestrator) RequestReply(ctx context.Context, msg *core.MessageInOut) (*core.MessageInOut, error)
RequestReply provides a mock function with given fields: ctx, msg
func (*Orchestrator) RewindPins ¶ added in v1.1.0
func (_m *Orchestrator) RewindPins(ctx context.Context, rewind *core.PinRewind) (*core.PinRewind, error)
RewindPins provides a mock function with given fields: ctx, rewind
func (*Orchestrator) Start ¶
func (_m *Orchestrator) Start() error
Start provides a mock function with given fields:
func (*Orchestrator) SubmitNetworkAction ¶ added in v1.1.0
func (_m *Orchestrator) SubmitNetworkAction(ctx context.Context, action *core.NetworkAction) error
SubmitNetworkAction provides a mock function with given fields: ctx, action
func (*Orchestrator) WaitStop ¶
func (_m *Orchestrator) WaitStop()
WaitStop provides a mock function with given fields: