Documentation ¶
Overview ¶
Code generated by MockGen. DO NOT EDIT. Source: ../scheduler_grpc.pb.go
Generated by this command:
mockgen -destination scheduler_mock.go -source ../scheduler_grpc.pb.go -package mocks
Package mocks is a generated GoMock package.
Index ¶
- type MockSchedulerClient
- func (m *MockSchedulerClient) AnnounceHost(ctx context.Context, in *scheduler.AnnounceHostRequest, ...) (*emptypb.Empty, error)
- func (m *MockSchedulerClient) AnnouncePeer(ctx context.Context, opts ...grpc.CallOption) (scheduler.Scheduler_AnnouncePeerClient, error)
- func (m *MockSchedulerClient) DeleteHost(ctx context.Context, in *scheduler.DeleteHostRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
- func (m *MockSchedulerClient) DeletePeer(ctx context.Context, in *scheduler.DeletePeerRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
- func (m *MockSchedulerClient) DeleteTask(ctx context.Context, in *scheduler.DeleteTaskRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
- func (m *MockSchedulerClient) EXPECT() *MockSchedulerClientMockRecorder
- func (m *MockSchedulerClient) StatPeer(ctx context.Context, in *scheduler.StatPeerRequest, opts ...grpc.CallOption) (*common.Peer, error)
- func (m *MockSchedulerClient) StatTask(ctx context.Context, in *scheduler.StatTaskRequest, opts ...grpc.CallOption) (*common.Task, error)
- func (m *MockSchedulerClient) SyncProbes(ctx context.Context, opts ...grpc.CallOption) (scheduler.Scheduler_SyncProbesClient, error)
- type MockSchedulerClientMockRecorder
- func (mr *MockSchedulerClientMockRecorder) AnnounceHost(ctx, in any, opts ...any) *gomock.Call
- func (mr *MockSchedulerClientMockRecorder) AnnouncePeer(ctx any, opts ...any) *gomock.Call
- func (mr *MockSchedulerClientMockRecorder) DeleteHost(ctx, in any, opts ...any) *gomock.Call
- func (mr *MockSchedulerClientMockRecorder) DeletePeer(ctx, in any, opts ...any) *gomock.Call
- func (mr *MockSchedulerClientMockRecorder) DeleteTask(ctx, in any, opts ...any) *gomock.Call
- func (mr *MockSchedulerClientMockRecorder) StatPeer(ctx, in any, opts ...any) *gomock.Call
- func (mr *MockSchedulerClientMockRecorder) StatTask(ctx, in any, opts ...any) *gomock.Call
- func (mr *MockSchedulerClientMockRecorder) SyncProbes(ctx any, opts ...any) *gomock.Call
- type MockSchedulerServer
- func (m *MockSchedulerServer) AnnounceHost(arg0 context.Context, arg1 *scheduler.AnnounceHostRequest) (*emptypb.Empty, error)
- func (m *MockSchedulerServer) AnnouncePeer(arg0 scheduler.Scheduler_AnnouncePeerServer) error
- func (m *MockSchedulerServer) DeleteHost(arg0 context.Context, arg1 *scheduler.DeleteHostRequest) (*emptypb.Empty, error)
- func (m *MockSchedulerServer) DeletePeer(arg0 context.Context, arg1 *scheduler.DeletePeerRequest) (*emptypb.Empty, error)
- func (m *MockSchedulerServer) DeleteTask(arg0 context.Context, arg1 *scheduler.DeleteTaskRequest) (*emptypb.Empty, error)
- func (m *MockSchedulerServer) EXPECT() *MockSchedulerServerMockRecorder
- func (m *MockSchedulerServer) StatPeer(arg0 context.Context, arg1 *scheduler.StatPeerRequest) (*common.Peer, error)
- func (m *MockSchedulerServer) StatTask(arg0 context.Context, arg1 *scheduler.StatTaskRequest) (*common.Task, error)
- func (m *MockSchedulerServer) SyncProbes(arg0 scheduler.Scheduler_SyncProbesServer) error
- type MockSchedulerServerMockRecorder
- func (mr *MockSchedulerServerMockRecorder) AnnounceHost(arg0, arg1 any) *gomock.Call
- func (mr *MockSchedulerServerMockRecorder) AnnouncePeer(arg0 any) *gomock.Call
- func (mr *MockSchedulerServerMockRecorder) DeleteHost(arg0, arg1 any) *gomock.Call
- func (mr *MockSchedulerServerMockRecorder) DeletePeer(arg0, arg1 any) *gomock.Call
- func (mr *MockSchedulerServerMockRecorder) DeleteTask(arg0, arg1 any) *gomock.Call
- func (mr *MockSchedulerServerMockRecorder) StatPeer(arg0, arg1 any) *gomock.Call
- func (mr *MockSchedulerServerMockRecorder) StatTask(arg0, arg1 any) *gomock.Call
- func (mr *MockSchedulerServerMockRecorder) SyncProbes(arg0 any) *gomock.Call
- type MockScheduler_AnnouncePeerClient
- func (m *MockScheduler_AnnouncePeerClient) CloseSend() error
- func (m *MockScheduler_AnnouncePeerClient) Context() context.Context
- func (m *MockScheduler_AnnouncePeerClient) EXPECT() *MockScheduler_AnnouncePeerClientMockRecorder
- func (m *MockScheduler_AnnouncePeerClient) Header() (metadata.MD, error)
- func (m *MockScheduler_AnnouncePeerClient) Recv() (*scheduler.AnnouncePeerResponse, error)
- func (m_2 *MockScheduler_AnnouncePeerClient) RecvMsg(m any) error
- func (m *MockScheduler_AnnouncePeerClient) Send(arg0 *scheduler.AnnouncePeerRequest) error
- func (m_2 *MockScheduler_AnnouncePeerClient) SendMsg(m any) error
- func (m *MockScheduler_AnnouncePeerClient) Trailer() metadata.MD
- type MockScheduler_AnnouncePeerClientMockRecorder
- func (mr *MockScheduler_AnnouncePeerClientMockRecorder) CloseSend() *gomock.Call
- func (mr *MockScheduler_AnnouncePeerClientMockRecorder) Context() *gomock.Call
- func (mr *MockScheduler_AnnouncePeerClientMockRecorder) Header() *gomock.Call
- func (mr *MockScheduler_AnnouncePeerClientMockRecorder) Recv() *gomock.Call
- func (mr *MockScheduler_AnnouncePeerClientMockRecorder) RecvMsg(m any) *gomock.Call
- func (mr *MockScheduler_AnnouncePeerClientMockRecorder) Send(arg0 any) *gomock.Call
- func (mr *MockScheduler_AnnouncePeerClientMockRecorder) SendMsg(m any) *gomock.Call
- func (mr *MockScheduler_AnnouncePeerClientMockRecorder) Trailer() *gomock.Call
- type MockScheduler_AnnouncePeerServer
- func (m *MockScheduler_AnnouncePeerServer) Context() context.Context
- func (m *MockScheduler_AnnouncePeerServer) EXPECT() *MockScheduler_AnnouncePeerServerMockRecorder
- func (m *MockScheduler_AnnouncePeerServer) Recv() (*scheduler.AnnouncePeerRequest, error)
- func (m_2 *MockScheduler_AnnouncePeerServer) RecvMsg(m any) error
- func (m *MockScheduler_AnnouncePeerServer) Send(arg0 *scheduler.AnnouncePeerResponse) error
- func (m *MockScheduler_AnnouncePeerServer) SendHeader(arg0 metadata.MD) error
- func (m_2 *MockScheduler_AnnouncePeerServer) SendMsg(m any) error
- func (m *MockScheduler_AnnouncePeerServer) SetHeader(arg0 metadata.MD) error
- func (m *MockScheduler_AnnouncePeerServer) SetTrailer(arg0 metadata.MD)
- type MockScheduler_AnnouncePeerServerMockRecorder
- func (mr *MockScheduler_AnnouncePeerServerMockRecorder) Context() *gomock.Call
- func (mr *MockScheduler_AnnouncePeerServerMockRecorder) Recv() *gomock.Call
- func (mr *MockScheduler_AnnouncePeerServerMockRecorder) RecvMsg(m any) *gomock.Call
- func (mr *MockScheduler_AnnouncePeerServerMockRecorder) Send(arg0 any) *gomock.Call
- func (mr *MockScheduler_AnnouncePeerServerMockRecorder) SendHeader(arg0 any) *gomock.Call
- func (mr *MockScheduler_AnnouncePeerServerMockRecorder) SendMsg(m any) *gomock.Call
- func (mr *MockScheduler_AnnouncePeerServerMockRecorder) SetHeader(arg0 any) *gomock.Call
- func (mr *MockScheduler_AnnouncePeerServerMockRecorder) SetTrailer(arg0 any) *gomock.Call
- type MockScheduler_SyncProbesClient
- func (m *MockScheduler_SyncProbesClient) CloseSend() error
- func (m *MockScheduler_SyncProbesClient) Context() context.Context
- func (m *MockScheduler_SyncProbesClient) EXPECT() *MockScheduler_SyncProbesClientMockRecorder
- func (m *MockScheduler_SyncProbesClient) Header() (metadata.MD, error)
- func (m *MockScheduler_SyncProbesClient) Recv() (*scheduler.SyncProbesResponse, error)
- func (m_2 *MockScheduler_SyncProbesClient) RecvMsg(m any) error
- func (m *MockScheduler_SyncProbesClient) Send(arg0 *scheduler.SyncProbesRequest) error
- func (m_2 *MockScheduler_SyncProbesClient) SendMsg(m any) error
- func (m *MockScheduler_SyncProbesClient) Trailer() metadata.MD
- type MockScheduler_SyncProbesClientMockRecorder
- func (mr *MockScheduler_SyncProbesClientMockRecorder) CloseSend() *gomock.Call
- func (mr *MockScheduler_SyncProbesClientMockRecorder) Context() *gomock.Call
- func (mr *MockScheduler_SyncProbesClientMockRecorder) Header() *gomock.Call
- func (mr *MockScheduler_SyncProbesClientMockRecorder) Recv() *gomock.Call
- func (mr *MockScheduler_SyncProbesClientMockRecorder) RecvMsg(m any) *gomock.Call
- func (mr *MockScheduler_SyncProbesClientMockRecorder) Send(arg0 any) *gomock.Call
- func (mr *MockScheduler_SyncProbesClientMockRecorder) SendMsg(m any) *gomock.Call
- func (mr *MockScheduler_SyncProbesClientMockRecorder) Trailer() *gomock.Call
- type MockScheduler_SyncProbesServer
- func (m *MockScheduler_SyncProbesServer) Context() context.Context
- func (m *MockScheduler_SyncProbesServer) EXPECT() *MockScheduler_SyncProbesServerMockRecorder
- func (m *MockScheduler_SyncProbesServer) Recv() (*scheduler.SyncProbesRequest, error)
- func (m_2 *MockScheduler_SyncProbesServer) RecvMsg(m any) error
- func (m *MockScheduler_SyncProbesServer) Send(arg0 *scheduler.SyncProbesResponse) error
- func (m *MockScheduler_SyncProbesServer) SendHeader(arg0 metadata.MD) error
- func (m_2 *MockScheduler_SyncProbesServer) SendMsg(m any) error
- func (m *MockScheduler_SyncProbesServer) SetHeader(arg0 metadata.MD) error
- func (m *MockScheduler_SyncProbesServer) SetTrailer(arg0 metadata.MD)
- type MockScheduler_SyncProbesServerMockRecorder
- func (mr *MockScheduler_SyncProbesServerMockRecorder) Context() *gomock.Call
- func (mr *MockScheduler_SyncProbesServerMockRecorder) Recv() *gomock.Call
- func (mr *MockScheduler_SyncProbesServerMockRecorder) RecvMsg(m any) *gomock.Call
- func (mr *MockScheduler_SyncProbesServerMockRecorder) Send(arg0 any) *gomock.Call
- func (mr *MockScheduler_SyncProbesServerMockRecorder) SendHeader(arg0 any) *gomock.Call
- func (mr *MockScheduler_SyncProbesServerMockRecorder) SendMsg(m any) *gomock.Call
- func (mr *MockScheduler_SyncProbesServerMockRecorder) SetHeader(arg0 any) *gomock.Call
- func (mr *MockScheduler_SyncProbesServerMockRecorder) SetTrailer(arg0 any) *gomock.Call
- type MockUnsafeSchedulerServer
- type MockUnsafeSchedulerServerMockRecorder
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockSchedulerClient ¶
type MockSchedulerClient struct {
// contains filtered or unexported fields
}
MockSchedulerClient is a mock of SchedulerClient interface.
func NewMockSchedulerClient ¶
func NewMockSchedulerClient(ctrl *gomock.Controller) *MockSchedulerClient
NewMockSchedulerClient creates a new mock instance.
func (*MockSchedulerClient) AnnounceHost ¶
func (m *MockSchedulerClient) AnnounceHost(ctx context.Context, in *scheduler.AnnounceHostRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
AnnounceHost mocks base method.
func (*MockSchedulerClient) AnnouncePeer ¶
func (m *MockSchedulerClient) AnnouncePeer(ctx context.Context, opts ...grpc.CallOption) (scheduler.Scheduler_AnnouncePeerClient, error)
AnnouncePeer mocks base method.
func (*MockSchedulerClient) DeleteHost ¶ added in v2.0.120
func (m *MockSchedulerClient) DeleteHost(ctx context.Context, in *scheduler.DeleteHostRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
DeleteHost mocks base method.
func (*MockSchedulerClient) DeletePeer ¶ added in v2.0.120
func (m *MockSchedulerClient) DeletePeer(ctx context.Context, in *scheduler.DeletePeerRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
DeletePeer mocks base method.
func (*MockSchedulerClient) DeleteTask ¶ added in v2.0.120
func (m *MockSchedulerClient) DeleteTask(ctx context.Context, in *scheduler.DeleteTaskRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
DeleteTask mocks base method.
func (*MockSchedulerClient) EXPECT ¶
func (m *MockSchedulerClient) EXPECT() *MockSchedulerClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockSchedulerClient) StatPeer ¶
func (m *MockSchedulerClient) StatPeer(ctx context.Context, in *scheduler.StatPeerRequest, opts ...grpc.CallOption) (*common.Peer, error)
StatPeer mocks base method.
func (*MockSchedulerClient) StatTask ¶
func (m *MockSchedulerClient) StatTask(ctx context.Context, in *scheduler.StatTaskRequest, opts ...grpc.CallOption) (*common.Task, error)
StatTask mocks base method.
func (*MockSchedulerClient) SyncProbes ¶
func (m *MockSchedulerClient) SyncProbes(ctx context.Context, opts ...grpc.CallOption) (scheduler.Scheduler_SyncProbesClient, error)
SyncProbes mocks base method.
type MockSchedulerClientMockRecorder ¶
type MockSchedulerClientMockRecorder struct {
// contains filtered or unexported fields
}
MockSchedulerClientMockRecorder is the mock recorder for MockSchedulerClient.
func (*MockSchedulerClientMockRecorder) AnnounceHost ¶
func (mr *MockSchedulerClientMockRecorder) AnnounceHost(ctx, in any, opts ...any) *gomock.Call
AnnounceHost indicates an expected call of AnnounceHost.
func (*MockSchedulerClientMockRecorder) AnnouncePeer ¶
func (mr *MockSchedulerClientMockRecorder) AnnouncePeer(ctx any, opts ...any) *gomock.Call
AnnouncePeer indicates an expected call of AnnouncePeer.
func (*MockSchedulerClientMockRecorder) DeleteHost ¶ added in v2.0.120
func (mr *MockSchedulerClientMockRecorder) DeleteHost(ctx, in any, opts ...any) *gomock.Call
DeleteHost indicates an expected call of DeleteHost.
func (*MockSchedulerClientMockRecorder) DeletePeer ¶ added in v2.0.120
func (mr *MockSchedulerClientMockRecorder) DeletePeer(ctx, in any, opts ...any) *gomock.Call
DeletePeer indicates an expected call of DeletePeer.
func (*MockSchedulerClientMockRecorder) DeleteTask ¶ added in v2.0.120
func (mr *MockSchedulerClientMockRecorder) DeleteTask(ctx, in any, opts ...any) *gomock.Call
DeleteTask indicates an expected call of DeleteTask.
func (*MockSchedulerClientMockRecorder) StatPeer ¶
func (mr *MockSchedulerClientMockRecorder) StatPeer(ctx, in any, opts ...any) *gomock.Call
StatPeer indicates an expected call of StatPeer.
func (*MockSchedulerClientMockRecorder) StatTask ¶
func (mr *MockSchedulerClientMockRecorder) StatTask(ctx, in any, opts ...any) *gomock.Call
StatTask indicates an expected call of StatTask.
func (*MockSchedulerClientMockRecorder) SyncProbes ¶
func (mr *MockSchedulerClientMockRecorder) SyncProbes(ctx any, opts ...any) *gomock.Call
SyncProbes indicates an expected call of SyncProbes.
type MockSchedulerServer ¶
type MockSchedulerServer struct {
// contains filtered or unexported fields
}
MockSchedulerServer is a mock of SchedulerServer interface.
func NewMockSchedulerServer ¶
func NewMockSchedulerServer(ctrl *gomock.Controller) *MockSchedulerServer
NewMockSchedulerServer creates a new mock instance.
func (*MockSchedulerServer) AnnounceHost ¶
func (m *MockSchedulerServer) AnnounceHost(arg0 context.Context, arg1 *scheduler.AnnounceHostRequest) (*emptypb.Empty, error)
AnnounceHost mocks base method.
func (*MockSchedulerServer) AnnouncePeer ¶
func (m *MockSchedulerServer) AnnouncePeer(arg0 scheduler.Scheduler_AnnouncePeerServer) error
AnnouncePeer mocks base method.
func (*MockSchedulerServer) DeleteHost ¶ added in v2.0.120
func (m *MockSchedulerServer) DeleteHost(arg0 context.Context, arg1 *scheduler.DeleteHostRequest) (*emptypb.Empty, error)
DeleteHost mocks base method.
func (*MockSchedulerServer) DeletePeer ¶ added in v2.0.120
func (m *MockSchedulerServer) DeletePeer(arg0 context.Context, arg1 *scheduler.DeletePeerRequest) (*emptypb.Empty, error)
DeletePeer mocks base method.
func (*MockSchedulerServer) DeleteTask ¶ added in v2.0.120
func (m *MockSchedulerServer) DeleteTask(arg0 context.Context, arg1 *scheduler.DeleteTaskRequest) (*emptypb.Empty, error)
DeleteTask mocks base method.
func (*MockSchedulerServer) EXPECT ¶
func (m *MockSchedulerServer) EXPECT() *MockSchedulerServerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockSchedulerServer) StatPeer ¶
func (m *MockSchedulerServer) StatPeer(arg0 context.Context, arg1 *scheduler.StatPeerRequest) (*common.Peer, error)
StatPeer mocks base method.
func (*MockSchedulerServer) StatTask ¶
func (m *MockSchedulerServer) StatTask(arg0 context.Context, arg1 *scheduler.StatTaskRequest) (*common.Task, error)
StatTask mocks base method.
func (*MockSchedulerServer) SyncProbes ¶
func (m *MockSchedulerServer) SyncProbes(arg0 scheduler.Scheduler_SyncProbesServer) error
SyncProbes mocks base method.
type MockSchedulerServerMockRecorder ¶
type MockSchedulerServerMockRecorder struct {
// contains filtered or unexported fields
}
MockSchedulerServerMockRecorder is the mock recorder for MockSchedulerServer.
func (*MockSchedulerServerMockRecorder) AnnounceHost ¶
func (mr *MockSchedulerServerMockRecorder) AnnounceHost(arg0, arg1 any) *gomock.Call
AnnounceHost indicates an expected call of AnnounceHost.
func (*MockSchedulerServerMockRecorder) AnnouncePeer ¶
func (mr *MockSchedulerServerMockRecorder) AnnouncePeer(arg0 any) *gomock.Call
AnnouncePeer indicates an expected call of AnnouncePeer.
func (*MockSchedulerServerMockRecorder) DeleteHost ¶ added in v2.0.120
func (mr *MockSchedulerServerMockRecorder) DeleteHost(arg0, arg1 any) *gomock.Call
DeleteHost indicates an expected call of DeleteHost.
func (*MockSchedulerServerMockRecorder) DeletePeer ¶ added in v2.0.120
func (mr *MockSchedulerServerMockRecorder) DeletePeer(arg0, arg1 any) *gomock.Call
DeletePeer indicates an expected call of DeletePeer.
func (*MockSchedulerServerMockRecorder) DeleteTask ¶ added in v2.0.120
func (mr *MockSchedulerServerMockRecorder) DeleteTask(arg0, arg1 any) *gomock.Call
DeleteTask indicates an expected call of DeleteTask.
func (*MockSchedulerServerMockRecorder) StatPeer ¶
func (mr *MockSchedulerServerMockRecorder) StatPeer(arg0, arg1 any) *gomock.Call
StatPeer indicates an expected call of StatPeer.
func (*MockSchedulerServerMockRecorder) StatTask ¶
func (mr *MockSchedulerServerMockRecorder) StatTask(arg0, arg1 any) *gomock.Call
StatTask indicates an expected call of StatTask.
func (*MockSchedulerServerMockRecorder) SyncProbes ¶
func (mr *MockSchedulerServerMockRecorder) SyncProbes(arg0 any) *gomock.Call
SyncProbes indicates an expected call of SyncProbes.
type MockScheduler_AnnouncePeerClient ¶
type MockScheduler_AnnouncePeerClient struct {
// contains filtered or unexported fields
}
MockScheduler_AnnouncePeerClient is a mock of Scheduler_AnnouncePeerClient interface.
func NewMockScheduler_AnnouncePeerClient ¶
func NewMockScheduler_AnnouncePeerClient(ctrl *gomock.Controller) *MockScheduler_AnnouncePeerClient
NewMockScheduler_AnnouncePeerClient creates a new mock instance.
func (*MockScheduler_AnnouncePeerClient) CloseSend ¶
func (m *MockScheduler_AnnouncePeerClient) CloseSend() error
CloseSend mocks base method.
func (*MockScheduler_AnnouncePeerClient) Context ¶
func (m *MockScheduler_AnnouncePeerClient) Context() context.Context
Context mocks base method.
func (*MockScheduler_AnnouncePeerClient) EXPECT ¶
func (m *MockScheduler_AnnouncePeerClient) EXPECT() *MockScheduler_AnnouncePeerClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockScheduler_AnnouncePeerClient) Header ¶
func (m *MockScheduler_AnnouncePeerClient) Header() (metadata.MD, error)
Header mocks base method.
func (*MockScheduler_AnnouncePeerClient) Recv ¶
func (m *MockScheduler_AnnouncePeerClient) Recv() (*scheduler.AnnouncePeerResponse, error)
Recv mocks base method.
func (*MockScheduler_AnnouncePeerClient) RecvMsg ¶
func (m_2 *MockScheduler_AnnouncePeerClient) RecvMsg(m any) error
RecvMsg mocks base method.
func (*MockScheduler_AnnouncePeerClient) Send ¶
func (m *MockScheduler_AnnouncePeerClient) Send(arg0 *scheduler.AnnouncePeerRequest) error
Send mocks base method.
func (*MockScheduler_AnnouncePeerClient) SendMsg ¶
func (m_2 *MockScheduler_AnnouncePeerClient) SendMsg(m any) error
SendMsg mocks base method.
func (*MockScheduler_AnnouncePeerClient) Trailer ¶
func (m *MockScheduler_AnnouncePeerClient) Trailer() metadata.MD
Trailer mocks base method.
type MockScheduler_AnnouncePeerClientMockRecorder ¶
type MockScheduler_AnnouncePeerClientMockRecorder struct {
// contains filtered or unexported fields
}
MockScheduler_AnnouncePeerClientMockRecorder is the mock recorder for MockScheduler_AnnouncePeerClient.
func (*MockScheduler_AnnouncePeerClientMockRecorder) CloseSend ¶
func (mr *MockScheduler_AnnouncePeerClientMockRecorder) CloseSend() *gomock.Call
CloseSend indicates an expected call of CloseSend.
func (*MockScheduler_AnnouncePeerClientMockRecorder) Context ¶
func (mr *MockScheduler_AnnouncePeerClientMockRecorder) Context() *gomock.Call
Context indicates an expected call of Context.
func (*MockScheduler_AnnouncePeerClientMockRecorder) Header ¶
func (mr *MockScheduler_AnnouncePeerClientMockRecorder) Header() *gomock.Call
Header indicates an expected call of Header.
func (*MockScheduler_AnnouncePeerClientMockRecorder) Recv ¶
func (mr *MockScheduler_AnnouncePeerClientMockRecorder) Recv() *gomock.Call
Recv indicates an expected call of Recv.
func (*MockScheduler_AnnouncePeerClientMockRecorder) RecvMsg ¶
func (mr *MockScheduler_AnnouncePeerClientMockRecorder) RecvMsg(m any) *gomock.Call
RecvMsg indicates an expected call of RecvMsg.
func (*MockScheduler_AnnouncePeerClientMockRecorder) Send ¶
func (mr *MockScheduler_AnnouncePeerClientMockRecorder) Send(arg0 any) *gomock.Call
Send indicates an expected call of Send.
func (*MockScheduler_AnnouncePeerClientMockRecorder) SendMsg ¶
func (mr *MockScheduler_AnnouncePeerClientMockRecorder) SendMsg(m any) *gomock.Call
SendMsg indicates an expected call of SendMsg.
func (*MockScheduler_AnnouncePeerClientMockRecorder) Trailer ¶
func (mr *MockScheduler_AnnouncePeerClientMockRecorder) Trailer() *gomock.Call
Trailer indicates an expected call of Trailer.
type MockScheduler_AnnouncePeerServer ¶
type MockScheduler_AnnouncePeerServer struct {
// contains filtered or unexported fields
}
MockScheduler_AnnouncePeerServer is a mock of Scheduler_AnnouncePeerServer interface.
func NewMockScheduler_AnnouncePeerServer ¶
func NewMockScheduler_AnnouncePeerServer(ctrl *gomock.Controller) *MockScheduler_AnnouncePeerServer
NewMockScheduler_AnnouncePeerServer creates a new mock instance.
func (*MockScheduler_AnnouncePeerServer) Context ¶
func (m *MockScheduler_AnnouncePeerServer) Context() context.Context
Context mocks base method.
func (*MockScheduler_AnnouncePeerServer) EXPECT ¶
func (m *MockScheduler_AnnouncePeerServer) EXPECT() *MockScheduler_AnnouncePeerServerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockScheduler_AnnouncePeerServer) Recv ¶
func (m *MockScheduler_AnnouncePeerServer) Recv() (*scheduler.AnnouncePeerRequest, error)
Recv mocks base method.
func (*MockScheduler_AnnouncePeerServer) RecvMsg ¶
func (m_2 *MockScheduler_AnnouncePeerServer) RecvMsg(m any) error
RecvMsg mocks base method.
func (*MockScheduler_AnnouncePeerServer) Send ¶
func (m *MockScheduler_AnnouncePeerServer) Send(arg0 *scheduler.AnnouncePeerResponse) error
Send mocks base method.
func (*MockScheduler_AnnouncePeerServer) SendHeader ¶
func (m *MockScheduler_AnnouncePeerServer) SendHeader(arg0 metadata.MD) error
SendHeader mocks base method.
func (*MockScheduler_AnnouncePeerServer) SendMsg ¶
func (m_2 *MockScheduler_AnnouncePeerServer) SendMsg(m any) error
SendMsg mocks base method.
func (*MockScheduler_AnnouncePeerServer) SetHeader ¶
func (m *MockScheduler_AnnouncePeerServer) SetHeader(arg0 metadata.MD) error
SetHeader mocks base method.
func (*MockScheduler_AnnouncePeerServer) SetTrailer ¶
func (m *MockScheduler_AnnouncePeerServer) SetTrailer(arg0 metadata.MD)
SetTrailer mocks base method.
type MockScheduler_AnnouncePeerServerMockRecorder ¶
type MockScheduler_AnnouncePeerServerMockRecorder struct {
// contains filtered or unexported fields
}
MockScheduler_AnnouncePeerServerMockRecorder is the mock recorder for MockScheduler_AnnouncePeerServer.
func (*MockScheduler_AnnouncePeerServerMockRecorder) Context ¶
func (mr *MockScheduler_AnnouncePeerServerMockRecorder) Context() *gomock.Call
Context indicates an expected call of Context.
func (*MockScheduler_AnnouncePeerServerMockRecorder) Recv ¶
func (mr *MockScheduler_AnnouncePeerServerMockRecorder) Recv() *gomock.Call
Recv indicates an expected call of Recv.
func (*MockScheduler_AnnouncePeerServerMockRecorder) RecvMsg ¶
func (mr *MockScheduler_AnnouncePeerServerMockRecorder) RecvMsg(m any) *gomock.Call
RecvMsg indicates an expected call of RecvMsg.
func (*MockScheduler_AnnouncePeerServerMockRecorder) Send ¶
func (mr *MockScheduler_AnnouncePeerServerMockRecorder) Send(arg0 any) *gomock.Call
Send indicates an expected call of Send.
func (*MockScheduler_AnnouncePeerServerMockRecorder) SendHeader ¶
func (mr *MockScheduler_AnnouncePeerServerMockRecorder) SendHeader(arg0 any) *gomock.Call
SendHeader indicates an expected call of SendHeader.
func (*MockScheduler_AnnouncePeerServerMockRecorder) SendMsg ¶
func (mr *MockScheduler_AnnouncePeerServerMockRecorder) SendMsg(m any) *gomock.Call
SendMsg indicates an expected call of SendMsg.
func (*MockScheduler_AnnouncePeerServerMockRecorder) SetHeader ¶
func (mr *MockScheduler_AnnouncePeerServerMockRecorder) SetHeader(arg0 any) *gomock.Call
SetHeader indicates an expected call of SetHeader.
func (*MockScheduler_AnnouncePeerServerMockRecorder) SetTrailer ¶
func (mr *MockScheduler_AnnouncePeerServerMockRecorder) SetTrailer(arg0 any) *gomock.Call
SetTrailer indicates an expected call of SetTrailer.
type MockScheduler_SyncProbesClient ¶
type MockScheduler_SyncProbesClient struct {
// contains filtered or unexported fields
}
MockScheduler_SyncProbesClient is a mock of Scheduler_SyncProbesClient interface.
func NewMockScheduler_SyncProbesClient ¶
func NewMockScheduler_SyncProbesClient(ctrl *gomock.Controller) *MockScheduler_SyncProbesClient
NewMockScheduler_SyncProbesClient creates a new mock instance.
func (*MockScheduler_SyncProbesClient) CloseSend ¶
func (m *MockScheduler_SyncProbesClient) CloseSend() error
CloseSend mocks base method.
func (*MockScheduler_SyncProbesClient) Context ¶
func (m *MockScheduler_SyncProbesClient) Context() context.Context
Context mocks base method.
func (*MockScheduler_SyncProbesClient) EXPECT ¶
func (m *MockScheduler_SyncProbesClient) EXPECT() *MockScheduler_SyncProbesClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockScheduler_SyncProbesClient) Header ¶
func (m *MockScheduler_SyncProbesClient) Header() (metadata.MD, error)
Header mocks base method.
func (*MockScheduler_SyncProbesClient) Recv ¶
func (m *MockScheduler_SyncProbesClient) Recv() (*scheduler.SyncProbesResponse, error)
Recv mocks base method.
func (*MockScheduler_SyncProbesClient) RecvMsg ¶
func (m_2 *MockScheduler_SyncProbesClient) RecvMsg(m any) error
RecvMsg mocks base method.
func (*MockScheduler_SyncProbesClient) Send ¶
func (m *MockScheduler_SyncProbesClient) Send(arg0 *scheduler.SyncProbesRequest) error
Send mocks base method.
func (*MockScheduler_SyncProbesClient) SendMsg ¶
func (m_2 *MockScheduler_SyncProbesClient) SendMsg(m any) error
SendMsg mocks base method.
func (*MockScheduler_SyncProbesClient) Trailer ¶
func (m *MockScheduler_SyncProbesClient) Trailer() metadata.MD
Trailer mocks base method.
type MockScheduler_SyncProbesClientMockRecorder ¶
type MockScheduler_SyncProbesClientMockRecorder struct {
// contains filtered or unexported fields
}
MockScheduler_SyncProbesClientMockRecorder is the mock recorder for MockScheduler_SyncProbesClient.
func (*MockScheduler_SyncProbesClientMockRecorder) CloseSend ¶
func (mr *MockScheduler_SyncProbesClientMockRecorder) CloseSend() *gomock.Call
CloseSend indicates an expected call of CloseSend.
func (*MockScheduler_SyncProbesClientMockRecorder) Context ¶
func (mr *MockScheduler_SyncProbesClientMockRecorder) Context() *gomock.Call
Context indicates an expected call of Context.
func (*MockScheduler_SyncProbesClientMockRecorder) Header ¶
func (mr *MockScheduler_SyncProbesClientMockRecorder) Header() *gomock.Call
Header indicates an expected call of Header.
func (*MockScheduler_SyncProbesClientMockRecorder) Recv ¶
func (mr *MockScheduler_SyncProbesClientMockRecorder) Recv() *gomock.Call
Recv indicates an expected call of Recv.
func (*MockScheduler_SyncProbesClientMockRecorder) RecvMsg ¶
func (mr *MockScheduler_SyncProbesClientMockRecorder) RecvMsg(m any) *gomock.Call
RecvMsg indicates an expected call of RecvMsg.
func (*MockScheduler_SyncProbesClientMockRecorder) Send ¶
func (mr *MockScheduler_SyncProbesClientMockRecorder) Send(arg0 any) *gomock.Call
Send indicates an expected call of Send.
func (*MockScheduler_SyncProbesClientMockRecorder) SendMsg ¶
func (mr *MockScheduler_SyncProbesClientMockRecorder) SendMsg(m any) *gomock.Call
SendMsg indicates an expected call of SendMsg.
func (*MockScheduler_SyncProbesClientMockRecorder) Trailer ¶
func (mr *MockScheduler_SyncProbesClientMockRecorder) Trailer() *gomock.Call
Trailer indicates an expected call of Trailer.
type MockScheduler_SyncProbesServer ¶
type MockScheduler_SyncProbesServer struct {
// contains filtered or unexported fields
}
MockScheduler_SyncProbesServer is a mock of Scheduler_SyncProbesServer interface.
func NewMockScheduler_SyncProbesServer ¶
func NewMockScheduler_SyncProbesServer(ctrl *gomock.Controller) *MockScheduler_SyncProbesServer
NewMockScheduler_SyncProbesServer creates a new mock instance.
func (*MockScheduler_SyncProbesServer) Context ¶
func (m *MockScheduler_SyncProbesServer) Context() context.Context
Context mocks base method.
func (*MockScheduler_SyncProbesServer) EXPECT ¶
func (m *MockScheduler_SyncProbesServer) EXPECT() *MockScheduler_SyncProbesServerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockScheduler_SyncProbesServer) Recv ¶
func (m *MockScheduler_SyncProbesServer) Recv() (*scheduler.SyncProbesRequest, error)
Recv mocks base method.
func (*MockScheduler_SyncProbesServer) RecvMsg ¶
func (m_2 *MockScheduler_SyncProbesServer) RecvMsg(m any) error
RecvMsg mocks base method.
func (*MockScheduler_SyncProbesServer) Send ¶
func (m *MockScheduler_SyncProbesServer) Send(arg0 *scheduler.SyncProbesResponse) error
Send mocks base method.
func (*MockScheduler_SyncProbesServer) SendHeader ¶
func (m *MockScheduler_SyncProbesServer) SendHeader(arg0 metadata.MD) error
SendHeader mocks base method.
func (*MockScheduler_SyncProbesServer) SendMsg ¶
func (m_2 *MockScheduler_SyncProbesServer) SendMsg(m any) error
SendMsg mocks base method.
func (*MockScheduler_SyncProbesServer) SetHeader ¶
func (m *MockScheduler_SyncProbesServer) SetHeader(arg0 metadata.MD) error
SetHeader mocks base method.
func (*MockScheduler_SyncProbesServer) SetTrailer ¶
func (m *MockScheduler_SyncProbesServer) SetTrailer(arg0 metadata.MD)
SetTrailer mocks base method.
type MockScheduler_SyncProbesServerMockRecorder ¶
type MockScheduler_SyncProbesServerMockRecorder struct {
// contains filtered or unexported fields
}
MockScheduler_SyncProbesServerMockRecorder is the mock recorder for MockScheduler_SyncProbesServer.
func (*MockScheduler_SyncProbesServerMockRecorder) Context ¶
func (mr *MockScheduler_SyncProbesServerMockRecorder) Context() *gomock.Call
Context indicates an expected call of Context.
func (*MockScheduler_SyncProbesServerMockRecorder) Recv ¶
func (mr *MockScheduler_SyncProbesServerMockRecorder) Recv() *gomock.Call
Recv indicates an expected call of Recv.
func (*MockScheduler_SyncProbesServerMockRecorder) RecvMsg ¶
func (mr *MockScheduler_SyncProbesServerMockRecorder) RecvMsg(m any) *gomock.Call
RecvMsg indicates an expected call of RecvMsg.
func (*MockScheduler_SyncProbesServerMockRecorder) Send ¶
func (mr *MockScheduler_SyncProbesServerMockRecorder) Send(arg0 any) *gomock.Call
Send indicates an expected call of Send.
func (*MockScheduler_SyncProbesServerMockRecorder) SendHeader ¶
func (mr *MockScheduler_SyncProbesServerMockRecorder) SendHeader(arg0 any) *gomock.Call
SendHeader indicates an expected call of SendHeader.
func (*MockScheduler_SyncProbesServerMockRecorder) SendMsg ¶
func (mr *MockScheduler_SyncProbesServerMockRecorder) SendMsg(m any) *gomock.Call
SendMsg indicates an expected call of SendMsg.
func (*MockScheduler_SyncProbesServerMockRecorder) SetHeader ¶
func (mr *MockScheduler_SyncProbesServerMockRecorder) SetHeader(arg0 any) *gomock.Call
SetHeader indicates an expected call of SetHeader.
func (*MockScheduler_SyncProbesServerMockRecorder) SetTrailer ¶
func (mr *MockScheduler_SyncProbesServerMockRecorder) SetTrailer(arg0 any) *gomock.Call
SetTrailer indicates an expected call of SetTrailer.
type MockUnsafeSchedulerServer ¶
type MockUnsafeSchedulerServer struct {
// contains filtered or unexported fields
}
MockUnsafeSchedulerServer is a mock of UnsafeSchedulerServer interface.
func NewMockUnsafeSchedulerServer ¶
func NewMockUnsafeSchedulerServer(ctrl *gomock.Controller) *MockUnsafeSchedulerServer
NewMockUnsafeSchedulerServer creates a new mock instance.
func (*MockUnsafeSchedulerServer) EXPECT ¶
func (m *MockUnsafeSchedulerServer) EXPECT() *MockUnsafeSchedulerServerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type MockUnsafeSchedulerServerMockRecorder ¶
type MockUnsafeSchedulerServerMockRecorder struct {
// contains filtered or unexported fields
}
MockUnsafeSchedulerServerMockRecorder is the mock recorder for MockUnsafeSchedulerServer.