Documentation
¶
Overview ¶
Package mock is a generated GoMock package.
Index ¶
- type MockPiroServiceClient
- func (m *MockPiroServiceClient) EXPECT() *MockPiroServiceClientMockRecorder
- func (m *MockPiroServiceClient) GetJob(ctx context.Context, in *v1.GetJobRequest, opts ...grpc.CallOption) (*v1.GetJobResponse, error)
- func (m *MockPiroServiceClient) ListJobs(ctx context.Context, in *v1.ListJobsRequest, opts ...grpc.CallOption) (*v1.ListJobsResponse, error)
- func (m *MockPiroServiceClient) Listen(ctx context.Context, in *v1.ListenRequest, opts ...grpc.CallOption) (v1.PiroService_ListenClient, error)
- func (m *MockPiroServiceClient) StartFromPreviousJob(ctx context.Context, in *v1.StartFromPreviousJobRequest, ...) (*v1.StartJobResponse, error)
- func (m *MockPiroServiceClient) StartGitHubJob(ctx context.Context, in *v1.StartGitHubJobRequest, opts ...grpc.CallOption) (*v1.StartJobResponse, error)
- func (m *MockPiroServiceClient) StartJob(ctx context.Context, in *v1.StartJobRequest, opts ...grpc.CallOption) (*v1.StartJobResponse, error)
- func (m *MockPiroServiceClient) StartJob2(ctx context.Context, in *v1.StartJobRequest2, opts ...grpc.CallOption) (*v1.StartJobResponse, error)
- func (m *MockPiroServiceClient) StartLocalJob(ctx context.Context, opts ...grpc.CallOption) (v1.PiroService_StartLocalJobClient, error)
- func (m *MockPiroServiceClient) StopJob(ctx context.Context, in *v1.StopJobRequest, opts ...grpc.CallOption) (*v1.StopJobResponse, error)
- func (m *MockPiroServiceClient) Subscribe(ctx context.Context, in *v1.SubscribeRequest, opts ...grpc.CallOption) (v1.PiroService_SubscribeClient, error)
- type MockPiroServiceClientMockRecorder
- func (mr *MockPiroServiceClientMockRecorder) GetJob(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockPiroServiceClientMockRecorder) ListJobs(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockPiroServiceClientMockRecorder) Listen(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockPiroServiceClientMockRecorder) StartFromPreviousJob(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockPiroServiceClientMockRecorder) StartGitHubJob(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockPiroServiceClientMockRecorder) StartJob(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockPiroServiceClientMockRecorder) StartJob2(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockPiroServiceClientMockRecorder) StartLocalJob(ctx interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockPiroServiceClientMockRecorder) StopJob(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockPiroServiceClientMockRecorder) Subscribe(ctx, in interface{}, opts ...interface{}) *gomock.Call
- type MockPiroServiceServer
- func (m *MockPiroServiceServer) EXPECT() *MockPiroServiceServerMockRecorder
- func (m *MockPiroServiceServer) GetJob(arg0 context.Context, arg1 *v1.GetJobRequest) (*v1.GetJobResponse, error)
- func (m *MockPiroServiceServer) ListJobs(arg0 context.Context, arg1 *v1.ListJobsRequest) (*v1.ListJobsResponse, error)
- func (m *MockPiroServiceServer) Listen(arg0 *v1.ListenRequest, arg1 v1.PiroService_ListenServer) error
- func (m *MockPiroServiceServer) StartFromPreviousJob(arg0 context.Context, arg1 *v1.StartFromPreviousJobRequest) (*v1.StartJobResponse, error)
- func (m *MockPiroServiceServer) StartGitHubJob(arg0 context.Context, arg1 *v1.StartGitHubJobRequest) (*v1.StartJobResponse, error)
- func (m *MockPiroServiceServer) StartJob(arg0 context.Context, arg1 *v1.StartJobRequest) (*v1.StartJobResponse, error)
- func (m *MockPiroServiceServer) StartJob2(arg0 context.Context, arg1 *v1.StartJobRequest2) (*v1.StartJobResponse, error)
- func (m *MockPiroServiceServer) StartLocalJob(arg0 v1.PiroService_StartLocalJobServer) error
- func (m *MockPiroServiceServer) StopJob(arg0 context.Context, arg1 *v1.StopJobRequest) (*v1.StopJobResponse, error)
- func (m *MockPiroServiceServer) Subscribe(arg0 *v1.SubscribeRequest, arg1 v1.PiroService_SubscribeServer) error
- type MockPiroServiceServerMockRecorder
- func (mr *MockPiroServiceServerMockRecorder) GetJob(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockPiroServiceServerMockRecorder) ListJobs(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockPiroServiceServerMockRecorder) Listen(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockPiroServiceServerMockRecorder) StartFromPreviousJob(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockPiroServiceServerMockRecorder) StartGitHubJob(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockPiroServiceServerMockRecorder) StartJob(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockPiroServiceServerMockRecorder) StartJob2(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockPiroServiceServerMockRecorder) StartLocalJob(arg0 interface{}) *gomock.Call
- func (mr *MockPiroServiceServerMockRecorder) StopJob(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockPiroServiceServerMockRecorder) Subscribe(arg0, arg1 interface{}) *gomock.Call
- type MockPiroService_ListenClient
- func (m *MockPiroService_ListenClient) CloseSend() error
- func (m *MockPiroService_ListenClient) Context() context.Context
- func (m *MockPiroService_ListenClient) EXPECT() *MockPiroService_ListenClientMockRecorder
- func (m *MockPiroService_ListenClient) Header() (metadata.MD, error)
- func (m *MockPiroService_ListenClient) Recv() (*v1.ListenResponse, error)
- func (m_2 *MockPiroService_ListenClient) RecvMsg(m interface{}) error
- func (m_2 *MockPiroService_ListenClient) SendMsg(m interface{}) error
- func (m *MockPiroService_ListenClient) Trailer() metadata.MD
- type MockPiroService_ListenClientMockRecorder
- func (mr *MockPiroService_ListenClientMockRecorder) CloseSend() *gomock.Call
- func (mr *MockPiroService_ListenClientMockRecorder) Context() *gomock.Call
- func (mr *MockPiroService_ListenClientMockRecorder) Header() *gomock.Call
- func (mr *MockPiroService_ListenClientMockRecorder) Recv() *gomock.Call
- func (mr *MockPiroService_ListenClientMockRecorder) RecvMsg(m interface{}) *gomock.Call
- func (mr *MockPiroService_ListenClientMockRecorder) SendMsg(m interface{}) *gomock.Call
- func (mr *MockPiroService_ListenClientMockRecorder) Trailer() *gomock.Call
- type MockPiroService_ListenServer
- func (m *MockPiroService_ListenServer) Context() context.Context
- func (m *MockPiroService_ListenServer) EXPECT() *MockPiroService_ListenServerMockRecorder
- func (m_2 *MockPiroService_ListenServer) RecvMsg(m interface{}) error
- func (m *MockPiroService_ListenServer) Send(arg0 *v1.ListenResponse) error
- func (m *MockPiroService_ListenServer) SendHeader(arg0 metadata.MD) error
- func (m_2 *MockPiroService_ListenServer) SendMsg(m interface{}) error
- func (m *MockPiroService_ListenServer) SetHeader(arg0 metadata.MD) error
- func (m *MockPiroService_ListenServer) SetTrailer(arg0 metadata.MD)
- type MockPiroService_ListenServerMockRecorder
- func (mr *MockPiroService_ListenServerMockRecorder) Context() *gomock.Call
- func (mr *MockPiroService_ListenServerMockRecorder) RecvMsg(m interface{}) *gomock.Call
- func (mr *MockPiroService_ListenServerMockRecorder) Send(arg0 interface{}) *gomock.Call
- func (mr *MockPiroService_ListenServerMockRecorder) SendHeader(arg0 interface{}) *gomock.Call
- func (mr *MockPiroService_ListenServerMockRecorder) SendMsg(m interface{}) *gomock.Call
- func (mr *MockPiroService_ListenServerMockRecorder) SetHeader(arg0 interface{}) *gomock.Call
- func (mr *MockPiroService_ListenServerMockRecorder) SetTrailer(arg0 interface{}) *gomock.Call
- type MockPiroService_StartLocalJobClient
- func (m *MockPiroService_StartLocalJobClient) CloseAndRecv() (*v1.StartJobResponse, error)
- func (m *MockPiroService_StartLocalJobClient) CloseSend() error
- func (m *MockPiroService_StartLocalJobClient) Context() context.Context
- func (m *MockPiroService_StartLocalJobClient) EXPECT() *MockPiroService_StartLocalJobClientMockRecorder
- func (m *MockPiroService_StartLocalJobClient) Header() (metadata.MD, error)
- func (m_2 *MockPiroService_StartLocalJobClient) RecvMsg(m interface{}) error
- func (m *MockPiroService_StartLocalJobClient) Send(arg0 *v1.StartLocalJobRequest) error
- func (m_2 *MockPiroService_StartLocalJobClient) SendMsg(m interface{}) error
- func (m *MockPiroService_StartLocalJobClient) Trailer() metadata.MD
- type MockPiroService_StartLocalJobClientMockRecorder
- func (mr *MockPiroService_StartLocalJobClientMockRecorder) CloseAndRecv() *gomock.Call
- func (mr *MockPiroService_StartLocalJobClientMockRecorder) CloseSend() *gomock.Call
- func (mr *MockPiroService_StartLocalJobClientMockRecorder) Context() *gomock.Call
- func (mr *MockPiroService_StartLocalJobClientMockRecorder) Header() *gomock.Call
- func (mr *MockPiroService_StartLocalJobClientMockRecorder) RecvMsg(m interface{}) *gomock.Call
- func (mr *MockPiroService_StartLocalJobClientMockRecorder) Send(arg0 interface{}) *gomock.Call
- func (mr *MockPiroService_StartLocalJobClientMockRecorder) SendMsg(m interface{}) *gomock.Call
- func (mr *MockPiroService_StartLocalJobClientMockRecorder) Trailer() *gomock.Call
- type MockPiroService_StartLocalJobServer
- func (m *MockPiroService_StartLocalJobServer) Context() context.Context
- func (m *MockPiroService_StartLocalJobServer) EXPECT() *MockPiroService_StartLocalJobServerMockRecorder
- func (m *MockPiroService_StartLocalJobServer) Recv() (*v1.StartLocalJobRequest, error)
- func (m_2 *MockPiroService_StartLocalJobServer) RecvMsg(m interface{}) error
- func (m *MockPiroService_StartLocalJobServer) SendAndClose(arg0 *v1.StartJobResponse) error
- func (m *MockPiroService_StartLocalJobServer) SendHeader(arg0 metadata.MD) error
- func (m_2 *MockPiroService_StartLocalJobServer) SendMsg(m interface{}) error
- func (m *MockPiroService_StartLocalJobServer) SetHeader(arg0 metadata.MD) error
- func (m *MockPiroService_StartLocalJobServer) SetTrailer(arg0 metadata.MD)
- type MockPiroService_StartLocalJobServerMockRecorder
- func (mr *MockPiroService_StartLocalJobServerMockRecorder) Context() *gomock.Call
- func (mr *MockPiroService_StartLocalJobServerMockRecorder) Recv() *gomock.Call
- func (mr *MockPiroService_StartLocalJobServerMockRecorder) RecvMsg(m interface{}) *gomock.Call
- func (mr *MockPiroService_StartLocalJobServerMockRecorder) SendAndClose(arg0 interface{}) *gomock.Call
- func (mr *MockPiroService_StartLocalJobServerMockRecorder) SendHeader(arg0 interface{}) *gomock.Call
- func (mr *MockPiroService_StartLocalJobServerMockRecorder) SendMsg(m interface{}) *gomock.Call
- func (mr *MockPiroService_StartLocalJobServerMockRecorder) SetHeader(arg0 interface{}) *gomock.Call
- func (mr *MockPiroService_StartLocalJobServerMockRecorder) SetTrailer(arg0 interface{}) *gomock.Call
- type MockPiroService_SubscribeClient
- func (m *MockPiroService_SubscribeClient) CloseSend() error
- func (m *MockPiroService_SubscribeClient) Context() context.Context
- func (m *MockPiroService_SubscribeClient) EXPECT() *MockPiroService_SubscribeClientMockRecorder
- func (m *MockPiroService_SubscribeClient) Header() (metadata.MD, error)
- func (m *MockPiroService_SubscribeClient) Recv() (*v1.SubscribeResponse, error)
- func (m_2 *MockPiroService_SubscribeClient) RecvMsg(m interface{}) error
- func (m_2 *MockPiroService_SubscribeClient) SendMsg(m interface{}) error
- func (m *MockPiroService_SubscribeClient) Trailer() metadata.MD
- type MockPiroService_SubscribeClientMockRecorder
- func (mr *MockPiroService_SubscribeClientMockRecorder) CloseSend() *gomock.Call
- func (mr *MockPiroService_SubscribeClientMockRecorder) Context() *gomock.Call
- func (mr *MockPiroService_SubscribeClientMockRecorder) Header() *gomock.Call
- func (mr *MockPiroService_SubscribeClientMockRecorder) Recv() *gomock.Call
- func (mr *MockPiroService_SubscribeClientMockRecorder) RecvMsg(m interface{}) *gomock.Call
- func (mr *MockPiroService_SubscribeClientMockRecorder) SendMsg(m interface{}) *gomock.Call
- func (mr *MockPiroService_SubscribeClientMockRecorder) Trailer() *gomock.Call
- type MockPiroService_SubscribeServer
- func (m *MockPiroService_SubscribeServer) Context() context.Context
- func (m *MockPiroService_SubscribeServer) EXPECT() *MockPiroService_SubscribeServerMockRecorder
- func (m_2 *MockPiroService_SubscribeServer) RecvMsg(m interface{}) error
- func (m *MockPiroService_SubscribeServer) Send(arg0 *v1.SubscribeResponse) error
- func (m *MockPiroService_SubscribeServer) SendHeader(arg0 metadata.MD) error
- func (m_2 *MockPiroService_SubscribeServer) SendMsg(m interface{}) error
- func (m *MockPiroService_SubscribeServer) SetHeader(arg0 metadata.MD) error
- func (m *MockPiroService_SubscribeServer) SetTrailer(arg0 metadata.MD)
- type MockPiroService_SubscribeServerMockRecorder
- func (mr *MockPiroService_SubscribeServerMockRecorder) Context() *gomock.Call
- func (mr *MockPiroService_SubscribeServerMockRecorder) RecvMsg(m interface{}) *gomock.Call
- func (mr *MockPiroService_SubscribeServerMockRecorder) Send(arg0 interface{}) *gomock.Call
- func (mr *MockPiroService_SubscribeServerMockRecorder) SendHeader(arg0 interface{}) *gomock.Call
- func (mr *MockPiroService_SubscribeServerMockRecorder) SendMsg(m interface{}) *gomock.Call
- func (mr *MockPiroService_SubscribeServerMockRecorder) SetHeader(arg0 interface{}) *gomock.Call
- func (mr *MockPiroService_SubscribeServerMockRecorder) SetTrailer(arg0 interface{}) *gomock.Call
- type MockisJobSpec_Source
- type MockisJobSpec_SourceMockRecorder
- type MockisListenResponse_Content
- type MockisListenResponse_ContentMockRecorder
- type MockisStartLocalJobRequest_Content
- type MockisStartLocalJobRequest_ContentMockRecorder
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockPiroServiceClient ¶
type MockPiroServiceClient struct {
// contains filtered or unexported fields
}
MockPiroServiceClient is a mock of PiroServiceClient interface.
func NewMockPiroServiceClient ¶
func NewMockPiroServiceClient(ctrl *gomock.Controller) *MockPiroServiceClient
NewMockPiroServiceClient creates a new mock instance.
func (*MockPiroServiceClient) EXPECT ¶
func (m *MockPiroServiceClient) EXPECT() *MockPiroServiceClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockPiroServiceClient) GetJob ¶
func (m *MockPiroServiceClient) GetJob(ctx context.Context, in *v1.GetJobRequest, opts ...grpc.CallOption) (*v1.GetJobResponse, error)
GetJob mocks base method.
func (*MockPiroServiceClient) ListJobs ¶
func (m *MockPiroServiceClient) ListJobs(ctx context.Context, in *v1.ListJobsRequest, opts ...grpc.CallOption) (*v1.ListJobsResponse, error)
ListJobs mocks base method.
func (*MockPiroServiceClient) Listen ¶
func (m *MockPiroServiceClient) Listen(ctx context.Context, in *v1.ListenRequest, opts ...grpc.CallOption) (v1.PiroService_ListenClient, error)
Listen mocks base method.
func (*MockPiroServiceClient) StartFromPreviousJob ¶
func (m *MockPiroServiceClient) StartFromPreviousJob(ctx context.Context, in *v1.StartFromPreviousJobRequest, opts ...grpc.CallOption) (*v1.StartJobResponse, error)
StartFromPreviousJob mocks base method.
func (*MockPiroServiceClient) StartGitHubJob ¶
func (m *MockPiroServiceClient) StartGitHubJob(ctx context.Context, in *v1.StartGitHubJobRequest, opts ...grpc.CallOption) (*v1.StartJobResponse, error)
StartGitHubJob mocks base method.
func (*MockPiroServiceClient) StartJob ¶
func (m *MockPiroServiceClient) StartJob(ctx context.Context, in *v1.StartJobRequest, opts ...grpc.CallOption) (*v1.StartJobResponse, error)
StartJob mocks base method.
func (*MockPiroServiceClient) StartJob2 ¶
func (m *MockPiroServiceClient) StartJob2(ctx context.Context, in *v1.StartJobRequest2, opts ...grpc.CallOption) (*v1.StartJobResponse, error)
StartJob2 mocks base method.
func (*MockPiroServiceClient) StartLocalJob ¶
func (m *MockPiroServiceClient) StartLocalJob(ctx context.Context, opts ...grpc.CallOption) (v1.PiroService_StartLocalJobClient, error)
StartLocalJob mocks base method.
func (*MockPiroServiceClient) StopJob ¶
func (m *MockPiroServiceClient) StopJob(ctx context.Context, in *v1.StopJobRequest, opts ...grpc.CallOption) (*v1.StopJobResponse, error)
StopJob mocks base method.
func (*MockPiroServiceClient) Subscribe ¶
func (m *MockPiroServiceClient) Subscribe(ctx context.Context, in *v1.SubscribeRequest, opts ...grpc.CallOption) (v1.PiroService_SubscribeClient, error)
Subscribe mocks base method.
type MockPiroServiceClientMockRecorder ¶
type MockPiroServiceClientMockRecorder struct {
// contains filtered or unexported fields
}
MockPiroServiceClientMockRecorder is the mock recorder for MockPiroServiceClient.
func (*MockPiroServiceClientMockRecorder) GetJob ¶
func (mr *MockPiroServiceClientMockRecorder) GetJob(ctx, in interface{}, opts ...interface{}) *gomock.Call
GetJob indicates an expected call of GetJob.
func (*MockPiroServiceClientMockRecorder) ListJobs ¶
func (mr *MockPiroServiceClientMockRecorder) ListJobs(ctx, in interface{}, opts ...interface{}) *gomock.Call
ListJobs indicates an expected call of ListJobs.
func (*MockPiroServiceClientMockRecorder) Listen ¶
func (mr *MockPiroServiceClientMockRecorder) Listen(ctx, in interface{}, opts ...interface{}) *gomock.Call
Listen indicates an expected call of Listen.
func (*MockPiroServiceClientMockRecorder) StartFromPreviousJob ¶
func (mr *MockPiroServiceClientMockRecorder) StartFromPreviousJob(ctx, in interface{}, opts ...interface{}) *gomock.Call
StartFromPreviousJob indicates an expected call of StartFromPreviousJob.
func (*MockPiroServiceClientMockRecorder) StartGitHubJob ¶
func (mr *MockPiroServiceClientMockRecorder) StartGitHubJob(ctx, in interface{}, opts ...interface{}) *gomock.Call
StartGitHubJob indicates an expected call of StartGitHubJob.
func (*MockPiroServiceClientMockRecorder) StartJob ¶
func (mr *MockPiroServiceClientMockRecorder) StartJob(ctx, in interface{}, opts ...interface{}) *gomock.Call
StartJob indicates an expected call of StartJob.
func (*MockPiroServiceClientMockRecorder) StartJob2 ¶
func (mr *MockPiroServiceClientMockRecorder) StartJob2(ctx, in interface{}, opts ...interface{}) *gomock.Call
StartJob2 indicates an expected call of StartJob2.
func (*MockPiroServiceClientMockRecorder) StartLocalJob ¶
func (mr *MockPiroServiceClientMockRecorder) StartLocalJob(ctx interface{}, opts ...interface{}) *gomock.Call
StartLocalJob indicates an expected call of StartLocalJob.
func (*MockPiroServiceClientMockRecorder) StopJob ¶
func (mr *MockPiroServiceClientMockRecorder) StopJob(ctx, in interface{}, opts ...interface{}) *gomock.Call
StopJob indicates an expected call of StopJob.
func (*MockPiroServiceClientMockRecorder) Subscribe ¶
func (mr *MockPiroServiceClientMockRecorder) Subscribe(ctx, in interface{}, opts ...interface{}) *gomock.Call
Subscribe indicates an expected call of Subscribe.
type MockPiroServiceServer ¶
type MockPiroServiceServer struct {
// contains filtered or unexported fields
}
MockPiroServiceServer is a mock of PiroServiceServer interface.
func NewMockPiroServiceServer ¶
func NewMockPiroServiceServer(ctrl *gomock.Controller) *MockPiroServiceServer
NewMockPiroServiceServer creates a new mock instance.
func (*MockPiroServiceServer) EXPECT ¶
func (m *MockPiroServiceServer) EXPECT() *MockPiroServiceServerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockPiroServiceServer) GetJob ¶
func (m *MockPiroServiceServer) GetJob(arg0 context.Context, arg1 *v1.GetJobRequest) (*v1.GetJobResponse, error)
GetJob mocks base method.
func (*MockPiroServiceServer) ListJobs ¶
func (m *MockPiroServiceServer) ListJobs(arg0 context.Context, arg1 *v1.ListJobsRequest) (*v1.ListJobsResponse, error)
ListJobs mocks base method.
func (*MockPiroServiceServer) Listen ¶
func (m *MockPiroServiceServer) Listen(arg0 *v1.ListenRequest, arg1 v1.PiroService_ListenServer) error
Listen mocks base method.
func (*MockPiroServiceServer) StartFromPreviousJob ¶
func (m *MockPiroServiceServer) StartFromPreviousJob(arg0 context.Context, arg1 *v1.StartFromPreviousJobRequest) (*v1.StartJobResponse, error)
StartFromPreviousJob mocks base method.
func (*MockPiroServiceServer) StartGitHubJob ¶
func (m *MockPiroServiceServer) StartGitHubJob(arg0 context.Context, arg1 *v1.StartGitHubJobRequest) (*v1.StartJobResponse, error)
StartGitHubJob mocks base method.
func (*MockPiroServiceServer) StartJob ¶
func (m *MockPiroServiceServer) StartJob(arg0 context.Context, arg1 *v1.StartJobRequest) (*v1.StartJobResponse, error)
StartJob mocks base method.
func (*MockPiroServiceServer) StartJob2 ¶
func (m *MockPiroServiceServer) StartJob2(arg0 context.Context, arg1 *v1.StartJobRequest2) (*v1.StartJobResponse, error)
StartJob2 mocks base method.
func (*MockPiroServiceServer) StartLocalJob ¶
func (m *MockPiroServiceServer) StartLocalJob(arg0 v1.PiroService_StartLocalJobServer) error
StartLocalJob mocks base method.
func (*MockPiroServiceServer) StopJob ¶
func (m *MockPiroServiceServer) StopJob(arg0 context.Context, arg1 *v1.StopJobRequest) (*v1.StopJobResponse, error)
StopJob mocks base method.
func (*MockPiroServiceServer) Subscribe ¶
func (m *MockPiroServiceServer) Subscribe(arg0 *v1.SubscribeRequest, arg1 v1.PiroService_SubscribeServer) error
Subscribe mocks base method.
type MockPiroServiceServerMockRecorder ¶
type MockPiroServiceServerMockRecorder struct {
// contains filtered or unexported fields
}
MockPiroServiceServerMockRecorder is the mock recorder for MockPiroServiceServer.
func (*MockPiroServiceServerMockRecorder) GetJob ¶
func (mr *MockPiroServiceServerMockRecorder) GetJob(arg0, arg1 interface{}) *gomock.Call
GetJob indicates an expected call of GetJob.
func (*MockPiroServiceServerMockRecorder) ListJobs ¶
func (mr *MockPiroServiceServerMockRecorder) ListJobs(arg0, arg1 interface{}) *gomock.Call
ListJobs indicates an expected call of ListJobs.
func (*MockPiroServiceServerMockRecorder) Listen ¶
func (mr *MockPiroServiceServerMockRecorder) Listen(arg0, arg1 interface{}) *gomock.Call
Listen indicates an expected call of Listen.
func (*MockPiroServiceServerMockRecorder) StartFromPreviousJob ¶
func (mr *MockPiroServiceServerMockRecorder) StartFromPreviousJob(arg0, arg1 interface{}) *gomock.Call
StartFromPreviousJob indicates an expected call of StartFromPreviousJob.
func (*MockPiroServiceServerMockRecorder) StartGitHubJob ¶
func (mr *MockPiroServiceServerMockRecorder) StartGitHubJob(arg0, arg1 interface{}) *gomock.Call
StartGitHubJob indicates an expected call of StartGitHubJob.
func (*MockPiroServiceServerMockRecorder) StartJob ¶
func (mr *MockPiroServiceServerMockRecorder) StartJob(arg0, arg1 interface{}) *gomock.Call
StartJob indicates an expected call of StartJob.
func (*MockPiroServiceServerMockRecorder) StartJob2 ¶
func (mr *MockPiroServiceServerMockRecorder) StartJob2(arg0, arg1 interface{}) *gomock.Call
StartJob2 indicates an expected call of StartJob2.
func (*MockPiroServiceServerMockRecorder) StartLocalJob ¶
func (mr *MockPiroServiceServerMockRecorder) StartLocalJob(arg0 interface{}) *gomock.Call
StartLocalJob indicates an expected call of StartLocalJob.
func (*MockPiroServiceServerMockRecorder) StopJob ¶
func (mr *MockPiroServiceServerMockRecorder) StopJob(arg0, arg1 interface{}) *gomock.Call
StopJob indicates an expected call of StopJob.
func (*MockPiroServiceServerMockRecorder) Subscribe ¶
func (mr *MockPiroServiceServerMockRecorder) Subscribe(arg0, arg1 interface{}) *gomock.Call
Subscribe indicates an expected call of Subscribe.
type MockPiroService_ListenClient ¶
type MockPiroService_ListenClient struct {
// contains filtered or unexported fields
}
MockPiroService_ListenClient is a mock of PiroService_ListenClient interface.
func NewMockPiroService_ListenClient ¶
func NewMockPiroService_ListenClient(ctrl *gomock.Controller) *MockPiroService_ListenClient
NewMockPiroService_ListenClient creates a new mock instance.
func (*MockPiroService_ListenClient) CloseSend ¶
func (m *MockPiroService_ListenClient) CloseSend() error
CloseSend mocks base method.
func (*MockPiroService_ListenClient) Context ¶
func (m *MockPiroService_ListenClient) Context() context.Context
Context mocks base method.
func (*MockPiroService_ListenClient) EXPECT ¶
func (m *MockPiroService_ListenClient) EXPECT() *MockPiroService_ListenClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockPiroService_ListenClient) Header ¶
func (m *MockPiroService_ListenClient) Header() (metadata.MD, error)
Header mocks base method.
func (*MockPiroService_ListenClient) Recv ¶
func (m *MockPiroService_ListenClient) Recv() (*v1.ListenResponse, error)
Recv mocks base method.
func (*MockPiroService_ListenClient) RecvMsg ¶
func (m_2 *MockPiroService_ListenClient) RecvMsg(m interface{}) error
RecvMsg mocks base method.
func (*MockPiroService_ListenClient) SendMsg ¶
func (m_2 *MockPiroService_ListenClient) SendMsg(m interface{}) error
SendMsg mocks base method.
func (*MockPiroService_ListenClient) Trailer ¶
func (m *MockPiroService_ListenClient) Trailer() metadata.MD
Trailer mocks base method.
type MockPiroService_ListenClientMockRecorder ¶
type MockPiroService_ListenClientMockRecorder struct {
// contains filtered or unexported fields
}
MockPiroService_ListenClientMockRecorder is the mock recorder for MockPiroService_ListenClient.
func (*MockPiroService_ListenClientMockRecorder) CloseSend ¶
func (mr *MockPiroService_ListenClientMockRecorder) CloseSend() *gomock.Call
CloseSend indicates an expected call of CloseSend.
func (*MockPiroService_ListenClientMockRecorder) Context ¶
func (mr *MockPiroService_ListenClientMockRecorder) Context() *gomock.Call
Context indicates an expected call of Context.
func (*MockPiroService_ListenClientMockRecorder) Header ¶
func (mr *MockPiroService_ListenClientMockRecorder) Header() *gomock.Call
Header indicates an expected call of Header.
func (*MockPiroService_ListenClientMockRecorder) Recv ¶
func (mr *MockPiroService_ListenClientMockRecorder) Recv() *gomock.Call
Recv indicates an expected call of Recv.
func (*MockPiroService_ListenClientMockRecorder) RecvMsg ¶
func (mr *MockPiroService_ListenClientMockRecorder) RecvMsg(m interface{}) *gomock.Call
RecvMsg indicates an expected call of RecvMsg.
func (*MockPiroService_ListenClientMockRecorder) SendMsg ¶
func (mr *MockPiroService_ListenClientMockRecorder) SendMsg(m interface{}) *gomock.Call
SendMsg indicates an expected call of SendMsg.
func (*MockPiroService_ListenClientMockRecorder) Trailer ¶
func (mr *MockPiroService_ListenClientMockRecorder) Trailer() *gomock.Call
Trailer indicates an expected call of Trailer.
type MockPiroService_ListenServer ¶
type MockPiroService_ListenServer struct {
// contains filtered or unexported fields
}
MockPiroService_ListenServer is a mock of PiroService_ListenServer interface.
func NewMockPiroService_ListenServer ¶
func NewMockPiroService_ListenServer(ctrl *gomock.Controller) *MockPiroService_ListenServer
NewMockPiroService_ListenServer creates a new mock instance.
func (*MockPiroService_ListenServer) Context ¶
func (m *MockPiroService_ListenServer) Context() context.Context
Context mocks base method.
func (*MockPiroService_ListenServer) EXPECT ¶
func (m *MockPiroService_ListenServer) EXPECT() *MockPiroService_ListenServerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockPiroService_ListenServer) RecvMsg ¶
func (m_2 *MockPiroService_ListenServer) RecvMsg(m interface{}) error
RecvMsg mocks base method.
func (*MockPiroService_ListenServer) Send ¶
func (m *MockPiroService_ListenServer) Send(arg0 *v1.ListenResponse) error
Send mocks base method.
func (*MockPiroService_ListenServer) SendHeader ¶
func (m *MockPiroService_ListenServer) SendHeader(arg0 metadata.MD) error
SendHeader mocks base method.
func (*MockPiroService_ListenServer) SendMsg ¶
func (m_2 *MockPiroService_ListenServer) SendMsg(m interface{}) error
SendMsg mocks base method.
func (*MockPiroService_ListenServer) SetHeader ¶
func (m *MockPiroService_ListenServer) SetHeader(arg0 metadata.MD) error
SetHeader mocks base method.
func (*MockPiroService_ListenServer) SetTrailer ¶
func (m *MockPiroService_ListenServer) SetTrailer(arg0 metadata.MD)
SetTrailer mocks base method.
type MockPiroService_ListenServerMockRecorder ¶
type MockPiroService_ListenServerMockRecorder struct {
// contains filtered or unexported fields
}
MockPiroService_ListenServerMockRecorder is the mock recorder for MockPiroService_ListenServer.
func (*MockPiroService_ListenServerMockRecorder) Context ¶
func (mr *MockPiroService_ListenServerMockRecorder) Context() *gomock.Call
Context indicates an expected call of Context.
func (*MockPiroService_ListenServerMockRecorder) RecvMsg ¶
func (mr *MockPiroService_ListenServerMockRecorder) RecvMsg(m interface{}) *gomock.Call
RecvMsg indicates an expected call of RecvMsg.
func (*MockPiroService_ListenServerMockRecorder) Send ¶
func (mr *MockPiroService_ListenServerMockRecorder) Send(arg0 interface{}) *gomock.Call
Send indicates an expected call of Send.
func (*MockPiroService_ListenServerMockRecorder) SendHeader ¶
func (mr *MockPiroService_ListenServerMockRecorder) SendHeader(arg0 interface{}) *gomock.Call
SendHeader indicates an expected call of SendHeader.
func (*MockPiroService_ListenServerMockRecorder) SendMsg ¶
func (mr *MockPiroService_ListenServerMockRecorder) SendMsg(m interface{}) *gomock.Call
SendMsg indicates an expected call of SendMsg.
func (*MockPiroService_ListenServerMockRecorder) SetHeader ¶
func (mr *MockPiroService_ListenServerMockRecorder) SetHeader(arg0 interface{}) *gomock.Call
SetHeader indicates an expected call of SetHeader.
func (*MockPiroService_ListenServerMockRecorder) SetTrailer ¶
func (mr *MockPiroService_ListenServerMockRecorder) SetTrailer(arg0 interface{}) *gomock.Call
SetTrailer indicates an expected call of SetTrailer.
type MockPiroService_StartLocalJobClient ¶
type MockPiroService_StartLocalJobClient struct {
// contains filtered or unexported fields
}
MockPiroService_StartLocalJobClient is a mock of PiroService_StartLocalJobClient interface.
func NewMockPiroService_StartLocalJobClient ¶
func NewMockPiroService_StartLocalJobClient(ctrl *gomock.Controller) *MockPiroService_StartLocalJobClient
NewMockPiroService_StartLocalJobClient creates a new mock instance.
func (*MockPiroService_StartLocalJobClient) CloseAndRecv ¶
func (m *MockPiroService_StartLocalJobClient) CloseAndRecv() (*v1.StartJobResponse, error)
CloseAndRecv mocks base method.
func (*MockPiroService_StartLocalJobClient) CloseSend ¶
func (m *MockPiroService_StartLocalJobClient) CloseSend() error
CloseSend mocks base method.
func (*MockPiroService_StartLocalJobClient) Context ¶
func (m *MockPiroService_StartLocalJobClient) Context() context.Context
Context mocks base method.
func (*MockPiroService_StartLocalJobClient) EXPECT ¶
func (m *MockPiroService_StartLocalJobClient) EXPECT() *MockPiroService_StartLocalJobClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockPiroService_StartLocalJobClient) Header ¶
func (m *MockPiroService_StartLocalJobClient) Header() (metadata.MD, error)
Header mocks base method.
func (*MockPiroService_StartLocalJobClient) RecvMsg ¶
func (m_2 *MockPiroService_StartLocalJobClient) RecvMsg(m interface{}) error
RecvMsg mocks base method.
func (*MockPiroService_StartLocalJobClient) Send ¶
func (m *MockPiroService_StartLocalJobClient) Send(arg0 *v1.StartLocalJobRequest) error
Send mocks base method.
func (*MockPiroService_StartLocalJobClient) SendMsg ¶
func (m_2 *MockPiroService_StartLocalJobClient) SendMsg(m interface{}) error
SendMsg mocks base method.
func (*MockPiroService_StartLocalJobClient) Trailer ¶
func (m *MockPiroService_StartLocalJobClient) Trailer() metadata.MD
Trailer mocks base method.
type MockPiroService_StartLocalJobClientMockRecorder ¶
type MockPiroService_StartLocalJobClientMockRecorder struct {
// contains filtered or unexported fields
}
MockPiroService_StartLocalJobClientMockRecorder is the mock recorder for MockPiroService_StartLocalJobClient.
func (*MockPiroService_StartLocalJobClientMockRecorder) CloseAndRecv ¶
func (mr *MockPiroService_StartLocalJobClientMockRecorder) CloseAndRecv() *gomock.Call
CloseAndRecv indicates an expected call of CloseAndRecv.
func (*MockPiroService_StartLocalJobClientMockRecorder) CloseSend ¶
func (mr *MockPiroService_StartLocalJobClientMockRecorder) CloseSend() *gomock.Call
CloseSend indicates an expected call of CloseSend.
func (*MockPiroService_StartLocalJobClientMockRecorder) Context ¶
func (mr *MockPiroService_StartLocalJobClientMockRecorder) Context() *gomock.Call
Context indicates an expected call of Context.
func (*MockPiroService_StartLocalJobClientMockRecorder) Header ¶
func (mr *MockPiroService_StartLocalJobClientMockRecorder) Header() *gomock.Call
Header indicates an expected call of Header.
func (*MockPiroService_StartLocalJobClientMockRecorder) RecvMsg ¶
func (mr *MockPiroService_StartLocalJobClientMockRecorder) RecvMsg(m interface{}) *gomock.Call
RecvMsg indicates an expected call of RecvMsg.
func (*MockPiroService_StartLocalJobClientMockRecorder) Send ¶
func (mr *MockPiroService_StartLocalJobClientMockRecorder) Send(arg0 interface{}) *gomock.Call
Send indicates an expected call of Send.
func (*MockPiroService_StartLocalJobClientMockRecorder) SendMsg ¶
func (mr *MockPiroService_StartLocalJobClientMockRecorder) SendMsg(m interface{}) *gomock.Call
SendMsg indicates an expected call of SendMsg.
func (*MockPiroService_StartLocalJobClientMockRecorder) Trailer ¶
func (mr *MockPiroService_StartLocalJobClientMockRecorder) Trailer() *gomock.Call
Trailer indicates an expected call of Trailer.
type MockPiroService_StartLocalJobServer ¶
type MockPiroService_StartLocalJobServer struct {
// contains filtered or unexported fields
}
MockPiroService_StartLocalJobServer is a mock of PiroService_StartLocalJobServer interface.
func NewMockPiroService_StartLocalJobServer ¶
func NewMockPiroService_StartLocalJobServer(ctrl *gomock.Controller) *MockPiroService_StartLocalJobServer
NewMockPiroService_StartLocalJobServer creates a new mock instance.
func (*MockPiroService_StartLocalJobServer) Context ¶
func (m *MockPiroService_StartLocalJobServer) Context() context.Context
Context mocks base method.
func (*MockPiroService_StartLocalJobServer) EXPECT ¶
func (m *MockPiroService_StartLocalJobServer) EXPECT() *MockPiroService_StartLocalJobServerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockPiroService_StartLocalJobServer) Recv ¶
func (m *MockPiroService_StartLocalJobServer) Recv() (*v1.StartLocalJobRequest, error)
Recv mocks base method.
func (*MockPiroService_StartLocalJobServer) RecvMsg ¶
func (m_2 *MockPiroService_StartLocalJobServer) RecvMsg(m interface{}) error
RecvMsg mocks base method.
func (*MockPiroService_StartLocalJobServer) SendAndClose ¶
func (m *MockPiroService_StartLocalJobServer) SendAndClose(arg0 *v1.StartJobResponse) error
SendAndClose mocks base method.
func (*MockPiroService_StartLocalJobServer) SendHeader ¶
func (m *MockPiroService_StartLocalJobServer) SendHeader(arg0 metadata.MD) error
SendHeader mocks base method.
func (*MockPiroService_StartLocalJobServer) SendMsg ¶
func (m_2 *MockPiroService_StartLocalJobServer) SendMsg(m interface{}) error
SendMsg mocks base method.
func (*MockPiroService_StartLocalJobServer) SetHeader ¶
func (m *MockPiroService_StartLocalJobServer) SetHeader(arg0 metadata.MD) error
SetHeader mocks base method.
func (*MockPiroService_StartLocalJobServer) SetTrailer ¶
func (m *MockPiroService_StartLocalJobServer) SetTrailer(arg0 metadata.MD)
SetTrailer mocks base method.
type MockPiroService_StartLocalJobServerMockRecorder ¶
type MockPiroService_StartLocalJobServerMockRecorder struct {
// contains filtered or unexported fields
}
MockPiroService_StartLocalJobServerMockRecorder is the mock recorder for MockPiroService_StartLocalJobServer.
func (*MockPiroService_StartLocalJobServerMockRecorder) Context ¶
func (mr *MockPiroService_StartLocalJobServerMockRecorder) Context() *gomock.Call
Context indicates an expected call of Context.
func (*MockPiroService_StartLocalJobServerMockRecorder) Recv ¶
func (mr *MockPiroService_StartLocalJobServerMockRecorder) Recv() *gomock.Call
Recv indicates an expected call of Recv.
func (*MockPiroService_StartLocalJobServerMockRecorder) RecvMsg ¶
func (mr *MockPiroService_StartLocalJobServerMockRecorder) RecvMsg(m interface{}) *gomock.Call
RecvMsg indicates an expected call of RecvMsg.
func (*MockPiroService_StartLocalJobServerMockRecorder) SendAndClose ¶
func (mr *MockPiroService_StartLocalJobServerMockRecorder) SendAndClose(arg0 interface{}) *gomock.Call
SendAndClose indicates an expected call of SendAndClose.
func (*MockPiroService_StartLocalJobServerMockRecorder) SendHeader ¶
func (mr *MockPiroService_StartLocalJobServerMockRecorder) SendHeader(arg0 interface{}) *gomock.Call
SendHeader indicates an expected call of SendHeader.
func (*MockPiroService_StartLocalJobServerMockRecorder) SendMsg ¶
func (mr *MockPiroService_StartLocalJobServerMockRecorder) SendMsg(m interface{}) *gomock.Call
SendMsg indicates an expected call of SendMsg.
func (*MockPiroService_StartLocalJobServerMockRecorder) SetHeader ¶
func (mr *MockPiroService_StartLocalJobServerMockRecorder) SetHeader(arg0 interface{}) *gomock.Call
SetHeader indicates an expected call of SetHeader.
func (*MockPiroService_StartLocalJobServerMockRecorder) SetTrailer ¶
func (mr *MockPiroService_StartLocalJobServerMockRecorder) SetTrailer(arg0 interface{}) *gomock.Call
SetTrailer indicates an expected call of SetTrailer.
type MockPiroService_SubscribeClient ¶
type MockPiroService_SubscribeClient struct {
// contains filtered or unexported fields
}
MockPiroService_SubscribeClient is a mock of PiroService_SubscribeClient interface.
func NewMockPiroService_SubscribeClient ¶
func NewMockPiroService_SubscribeClient(ctrl *gomock.Controller) *MockPiroService_SubscribeClient
NewMockPiroService_SubscribeClient creates a new mock instance.
func (*MockPiroService_SubscribeClient) CloseSend ¶
func (m *MockPiroService_SubscribeClient) CloseSend() error
CloseSend mocks base method.
func (*MockPiroService_SubscribeClient) Context ¶
func (m *MockPiroService_SubscribeClient) Context() context.Context
Context mocks base method.
func (*MockPiroService_SubscribeClient) EXPECT ¶
func (m *MockPiroService_SubscribeClient) EXPECT() *MockPiroService_SubscribeClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockPiroService_SubscribeClient) Header ¶
func (m *MockPiroService_SubscribeClient) Header() (metadata.MD, error)
Header mocks base method.
func (*MockPiroService_SubscribeClient) Recv ¶
func (m *MockPiroService_SubscribeClient) Recv() (*v1.SubscribeResponse, error)
Recv mocks base method.
func (*MockPiroService_SubscribeClient) RecvMsg ¶
func (m_2 *MockPiroService_SubscribeClient) RecvMsg(m interface{}) error
RecvMsg mocks base method.
func (*MockPiroService_SubscribeClient) SendMsg ¶
func (m_2 *MockPiroService_SubscribeClient) SendMsg(m interface{}) error
SendMsg mocks base method.
func (*MockPiroService_SubscribeClient) Trailer ¶
func (m *MockPiroService_SubscribeClient) Trailer() metadata.MD
Trailer mocks base method.
type MockPiroService_SubscribeClientMockRecorder ¶
type MockPiroService_SubscribeClientMockRecorder struct {
// contains filtered or unexported fields
}
MockPiroService_SubscribeClientMockRecorder is the mock recorder for MockPiroService_SubscribeClient.
func (*MockPiroService_SubscribeClientMockRecorder) CloseSend ¶
func (mr *MockPiroService_SubscribeClientMockRecorder) CloseSend() *gomock.Call
CloseSend indicates an expected call of CloseSend.
func (*MockPiroService_SubscribeClientMockRecorder) Context ¶
func (mr *MockPiroService_SubscribeClientMockRecorder) Context() *gomock.Call
Context indicates an expected call of Context.
func (*MockPiroService_SubscribeClientMockRecorder) Header ¶
func (mr *MockPiroService_SubscribeClientMockRecorder) Header() *gomock.Call
Header indicates an expected call of Header.
func (*MockPiroService_SubscribeClientMockRecorder) Recv ¶
func (mr *MockPiroService_SubscribeClientMockRecorder) Recv() *gomock.Call
Recv indicates an expected call of Recv.
func (*MockPiroService_SubscribeClientMockRecorder) RecvMsg ¶
func (mr *MockPiroService_SubscribeClientMockRecorder) RecvMsg(m interface{}) *gomock.Call
RecvMsg indicates an expected call of RecvMsg.
func (*MockPiroService_SubscribeClientMockRecorder) SendMsg ¶
func (mr *MockPiroService_SubscribeClientMockRecorder) SendMsg(m interface{}) *gomock.Call
SendMsg indicates an expected call of SendMsg.
func (*MockPiroService_SubscribeClientMockRecorder) Trailer ¶
func (mr *MockPiroService_SubscribeClientMockRecorder) Trailer() *gomock.Call
Trailer indicates an expected call of Trailer.
type MockPiroService_SubscribeServer ¶
type MockPiroService_SubscribeServer struct {
// contains filtered or unexported fields
}
MockPiroService_SubscribeServer is a mock of PiroService_SubscribeServer interface.
func NewMockPiroService_SubscribeServer ¶
func NewMockPiroService_SubscribeServer(ctrl *gomock.Controller) *MockPiroService_SubscribeServer
NewMockPiroService_SubscribeServer creates a new mock instance.
func (*MockPiroService_SubscribeServer) Context ¶
func (m *MockPiroService_SubscribeServer) Context() context.Context
Context mocks base method.
func (*MockPiroService_SubscribeServer) EXPECT ¶
func (m *MockPiroService_SubscribeServer) EXPECT() *MockPiroService_SubscribeServerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockPiroService_SubscribeServer) RecvMsg ¶
func (m_2 *MockPiroService_SubscribeServer) RecvMsg(m interface{}) error
RecvMsg mocks base method.
func (*MockPiroService_SubscribeServer) Send ¶
func (m *MockPiroService_SubscribeServer) Send(arg0 *v1.SubscribeResponse) error
Send mocks base method.
func (*MockPiroService_SubscribeServer) SendHeader ¶
func (m *MockPiroService_SubscribeServer) SendHeader(arg0 metadata.MD) error
SendHeader mocks base method.
func (*MockPiroService_SubscribeServer) SendMsg ¶
func (m_2 *MockPiroService_SubscribeServer) SendMsg(m interface{}) error
SendMsg mocks base method.
func (*MockPiroService_SubscribeServer) SetHeader ¶
func (m *MockPiroService_SubscribeServer) SetHeader(arg0 metadata.MD) error
SetHeader mocks base method.
func (*MockPiroService_SubscribeServer) SetTrailer ¶
func (m *MockPiroService_SubscribeServer) SetTrailer(arg0 metadata.MD)
SetTrailer mocks base method.
type MockPiroService_SubscribeServerMockRecorder ¶
type MockPiroService_SubscribeServerMockRecorder struct {
// contains filtered or unexported fields
}
MockPiroService_SubscribeServerMockRecorder is the mock recorder for MockPiroService_SubscribeServer.
func (*MockPiroService_SubscribeServerMockRecorder) Context ¶
func (mr *MockPiroService_SubscribeServerMockRecorder) Context() *gomock.Call
Context indicates an expected call of Context.
func (*MockPiroService_SubscribeServerMockRecorder) RecvMsg ¶
func (mr *MockPiroService_SubscribeServerMockRecorder) RecvMsg(m interface{}) *gomock.Call
RecvMsg indicates an expected call of RecvMsg.
func (*MockPiroService_SubscribeServerMockRecorder) Send ¶
func (mr *MockPiroService_SubscribeServerMockRecorder) Send(arg0 interface{}) *gomock.Call
Send indicates an expected call of Send.
func (*MockPiroService_SubscribeServerMockRecorder) SendHeader ¶
func (mr *MockPiroService_SubscribeServerMockRecorder) SendHeader(arg0 interface{}) *gomock.Call
SendHeader indicates an expected call of SendHeader.
func (*MockPiroService_SubscribeServerMockRecorder) SendMsg ¶
func (mr *MockPiroService_SubscribeServerMockRecorder) SendMsg(m interface{}) *gomock.Call
SendMsg indicates an expected call of SendMsg.
func (*MockPiroService_SubscribeServerMockRecorder) SetHeader ¶
func (mr *MockPiroService_SubscribeServerMockRecorder) SetHeader(arg0 interface{}) *gomock.Call
SetHeader indicates an expected call of SetHeader.
func (*MockPiroService_SubscribeServerMockRecorder) SetTrailer ¶
func (mr *MockPiroService_SubscribeServerMockRecorder) SetTrailer(arg0 interface{}) *gomock.Call
SetTrailer indicates an expected call of SetTrailer.
type MockisJobSpec_Source ¶
type MockisJobSpec_Source struct {
// contains filtered or unexported fields
}
MockisJobSpec_Source is a mock of isJobSpec_Source interface.
func NewMockisJobSpec_Source ¶
func NewMockisJobSpec_Source(ctrl *gomock.Controller) *MockisJobSpec_Source
NewMockisJobSpec_Source creates a new mock instance.
func (*MockisJobSpec_Source) EXPECT ¶
func (m *MockisJobSpec_Source) EXPECT() *MockisJobSpec_SourceMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type MockisJobSpec_SourceMockRecorder ¶
type MockisJobSpec_SourceMockRecorder struct {
// contains filtered or unexported fields
}
MockisJobSpec_SourceMockRecorder is the mock recorder for MockisJobSpec_Source.
type MockisListenResponse_Content ¶
type MockisListenResponse_Content struct {
// contains filtered or unexported fields
}
MockisListenResponse_Content is a mock of isListenResponse_Content interface.
func NewMockisListenResponse_Content ¶
func NewMockisListenResponse_Content(ctrl *gomock.Controller) *MockisListenResponse_Content
NewMockisListenResponse_Content creates a new mock instance.
func (*MockisListenResponse_Content) EXPECT ¶
func (m *MockisListenResponse_Content) EXPECT() *MockisListenResponse_ContentMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type MockisListenResponse_ContentMockRecorder ¶
type MockisListenResponse_ContentMockRecorder struct {
// contains filtered or unexported fields
}
MockisListenResponse_ContentMockRecorder is the mock recorder for MockisListenResponse_Content.
type MockisStartLocalJobRequest_Content ¶
type MockisStartLocalJobRequest_Content struct {
// contains filtered or unexported fields
}
MockisStartLocalJobRequest_Content is a mock of isStartLocalJobRequest_Content interface.
func NewMockisStartLocalJobRequest_Content ¶
func NewMockisStartLocalJobRequest_Content(ctrl *gomock.Controller) *MockisStartLocalJobRequest_Content
NewMockisStartLocalJobRequest_Content creates a new mock instance.
func (*MockisStartLocalJobRequest_Content) EXPECT ¶
func (m *MockisStartLocalJobRequest_Content) EXPECT() *MockisStartLocalJobRequest_ContentMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type MockisStartLocalJobRequest_ContentMockRecorder ¶
type MockisStartLocalJobRequest_ContentMockRecorder struct {
// contains filtered or unexported fields
}
MockisStartLocalJobRequest_ContentMockRecorder is the mock recorder for MockisStartLocalJobRequest_Content.