Documentation ¶
Index ¶
- type Peer
- func (_m *Peer) Done(c context.Context, id string, state rpc.State) error
- func (_m *Peer) Extend(c context.Context, id string) error
- func (_m *Peer) Init(c context.Context, id string, state rpc.State) error
- func (_m *Peer) Log(c context.Context, logEntry *rpc.LogEntry) error
- func (_m *Peer) Next(c context.Context, f rpc.Filter) (*rpc.Workflow, error)
- func (_m *Peer) RegisterAgent(ctx context.Context, platform string, backend string, version string, ...) (int64, error)
- func (_m *Peer) ReportHealth(c context.Context) error
- func (_m *Peer) UnregisterAgent(ctx context.Context) error
- func (_m *Peer) Update(c context.Context, id string, state rpc.State) error
- func (_m *Peer) Version(c context.Context) (*rpc.Version, error)
- func (_m *Peer) Wait(c context.Context, id string) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Peer ¶
Peer is an autogenerated mock type for the Peer type
func NewPeer ¶
NewPeer creates a new instance of Peer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*Peer) RegisterAgent ¶
func (_m *Peer) RegisterAgent(ctx context.Context, platform string, backend string, version string, capacity int) (int64, error)
RegisterAgent provides a mock function with given fields: ctx, platform, backend, version, capacity
func (*Peer) ReportHealth ¶
ReportHealth provides a mock function with given fields: c
func (*Peer) UnregisterAgent ¶
UnregisterAgent provides a mock function with given fields: ctx
Click to show internal directories.
Click to hide internal directories.