client

package
v0.0.0-...-1427ac7 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 30, 2020 License: MIT Imports: 21 Imported by: 0

Documentation

Overview

Package client is a generated GoMock package.

Package client is a generated GoMock package.

Package client is a generated GoMock package.

Index

Constants

View Source 
const (
	MethodPost Method = schedulerV1.ExecutionMethod_EXECUTION_METHOD_POST
	MethodGet  Method = schedulerV1.ExecutionMethod_EXECUTION_METHOD_GET

	StatusSuccess Status = schedulerV1.ExecutionStatus_EXECUTION_STATUS_SUCCESS
	StatusFailed  Status = schedulerV1.ExecutionStatus_EXECUTION_STATUS_FAILED
)

Variables

This section is empty.

Functions

func DefaultDialOptions 

func DefaultDialOptions() []grpc.DialOption

Types

type Conn 

type Conn interface {
	grpc.ClientConnInterface
	io.Closer
}

type ExecutionInfo 

type ExecutionInfo struct {
	Duration time.Duration
	Output   []byte
	Status   Status
	Message  string
	Id       string
}

func (ExecutionInfo) String 

func (e ExecutionInfo) String() string

type GRPCError 

type GRPCError struct {
	// contains filtered or unexported fields
}

func (*GRPCError) Error 

func (e *GRPCError) Error() string

func (*GRPCError) GetDetailsMap 

func (e *GRPCError) GetDetailsMap() map[string]interface{}

type Method 

type Method = schedulerV1.ExecutionMethod

type MockSchedulerServiceClient 

type MockSchedulerServiceClient struct {
	// contains filtered or unexported fields
}

MockSchedulerServiceClient is a mock of SchedulerServiceClient interface

func NewMockSchedulerServiceClient 

func NewMockSchedulerServiceClient(ctrl *gomock.Controller) *MockSchedulerServiceClient

NewMockSchedulerServiceClient creates a new mock instance

func (*MockSchedulerServiceClient) EXPECT 

func (m *MockSchedulerServiceClient) EXPECT() *MockSchedulerServiceClientMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockSchedulerServiceClient) ExecutionNotifications 

func (m *MockSchedulerServiceClient) ExecutionNotifications(arg0 context.Context, arg1 *scheduler.ExecutionNotificationsRequest, arg2 ...grpc.CallOption) (scheduler.SchedulerService_ExecutionNotificationsClient, error)

ExecutionNotifications mocks base method

func (*MockSchedulerServiceClient) ScheduleCommandTask 

func (m *MockSchedulerServiceClient) ScheduleCommandTask(arg0 context.Context, arg1 *scheduler.ScheduleCommandTaskRequest, arg2 ...grpc.CallOption) (*scheduler.ScheduleCommandTaskResponse, error)

ScheduleCommandTask mocks base method

func (*MockSchedulerServiceClient) ScheduleDummyTask 

func (m *MockSchedulerServiceClient) ScheduleDummyTask(arg0 context.Context, arg1 *scheduler.ScheduleDummyTaskRequest, arg2 ...grpc.CallOption) (*scheduler.ScheduleDummyTaskResponse, error)

ScheduleDummyTask mocks base method

func (*MockSchedulerServiceClient) ScheduleRemoteTask 

func (m *MockSchedulerServiceClient) ScheduleRemoteTask(arg0 context.Context, arg1 *scheduler.ScheduleRemoteTaskRequest, arg2 ...grpc.CallOption) (*scheduler.ScheduleRemoteTaskResponse, error)

ScheduleRemoteTask mocks base method

type MockSchedulerServiceClientMockRecorder 

type MockSchedulerServiceClientMockRecorder struct {
	// contains filtered or unexported fields
}

MockSchedulerServiceClientMockRecorder is the mock recorder for MockSchedulerServiceClient

func (*MockSchedulerServiceClientMockRecorder) ExecutionNotifications 

func (mr *MockSchedulerServiceClientMockRecorder) ExecutionNotifications(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

ExecutionNotifications indicates an expected call of ExecutionNotifications

func (*MockSchedulerServiceClientMockRecorder) ScheduleCommandTask 

func (mr *MockSchedulerServiceClientMockRecorder) ScheduleCommandTask(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

ScheduleCommandTask indicates an expected call of ScheduleCommandTask

func (*MockSchedulerServiceClientMockRecorder) ScheduleDummyTask 

func (mr *MockSchedulerServiceClientMockRecorder) ScheduleDummyTask(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

ScheduleDummyTask indicates an expected call of ScheduleDummyTask

func (*MockSchedulerServiceClientMockRecorder) ScheduleRemoteTask 

func (mr *MockSchedulerServiceClientMockRecorder) ScheduleRemoteTask(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

ScheduleRemoteTask indicates an expected call of ScheduleRemoteTask

type MockSchedulerServiceServer 

type MockSchedulerServiceServer struct {
	// contains filtered or unexported fields
}

MockSchedulerServiceServer is a mock of SchedulerServiceServer interface

func NewMockSchedulerServiceServer 

func NewMockSchedulerServiceServer(ctrl *gomock.Controller) *MockSchedulerServiceServer

NewMockSchedulerServiceServer creates a new mock instance

func (*MockSchedulerServiceServer) EXPECT 

func (m *MockSchedulerServiceServer) EXPECT() *MockSchedulerServiceServerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockSchedulerServiceServer) ExecutionNotifications 

func (m *MockSchedulerServiceServer) ExecutionNotifications(arg0 *scheduler.ExecutionNotificationsRequest, arg1 scheduler.SchedulerService_ExecutionNotificationsServer) error

ExecutionNotifications mocks base method

func (*MockSchedulerServiceServer) ScheduleCommandTask 

func (m *MockSchedulerServiceServer) ScheduleCommandTask(arg0 context.Context, arg1 *scheduler.ScheduleCommandTaskRequest) (*scheduler.ScheduleCommandTaskResponse, error)

ScheduleCommandTask mocks base method

func (*MockSchedulerServiceServer) ScheduleDummyTask 

func (m *MockSchedulerServiceServer) ScheduleDummyTask(arg0 context.Context, arg1 *scheduler.ScheduleDummyTaskRequest) (*scheduler.ScheduleDummyTaskResponse, error)

ScheduleDummyTask mocks base method

func (*MockSchedulerServiceServer) ScheduleRemoteTask 

func (m *MockSchedulerServiceServer) ScheduleRemoteTask(arg0 context.Context, arg1 *scheduler.ScheduleRemoteTaskRequest) (*scheduler.ScheduleRemoteTaskResponse, error)

ScheduleRemoteTask mocks base method

type MockSchedulerServiceServerMockRecorder 

type MockSchedulerServiceServerMockRecorder struct {
	// contains filtered or unexported fields
}

MockSchedulerServiceServerMockRecorder is the mock recorder for MockSchedulerServiceServer

func (*MockSchedulerServiceServerMockRecorder) ExecutionNotifications 

func (mr *MockSchedulerServiceServerMockRecorder) ExecutionNotifications(arg0, arg1 interface{}) *gomock.Call

ExecutionNotifications indicates an expected call of ExecutionNotifications

func (*MockSchedulerServiceServerMockRecorder) ScheduleCommandTask 

func (mr *MockSchedulerServiceServerMockRecorder) ScheduleCommandTask(arg0, arg1 interface{}) *gomock.Call

ScheduleCommandTask indicates an expected call of ScheduleCommandTask

func (*MockSchedulerServiceServerMockRecorder) ScheduleDummyTask 

func (mr *MockSchedulerServiceServerMockRecorder) ScheduleDummyTask(arg0, arg1 interface{}) *gomock.Call

ScheduleDummyTask indicates an expected call of ScheduleDummyTask

func (*MockSchedulerServiceServerMockRecorder) ScheduleRemoteTask 

func (mr *MockSchedulerServiceServerMockRecorder) ScheduleRemoteTask(arg0, arg1 interface{}) *gomock.Call

ScheduleRemoteTask indicates an expected call of ScheduleRemoteTask

type MockSchedulerService_ExecutionNotificationsClient 

type MockSchedulerService_ExecutionNotificationsClient struct {
	// contains filtered or unexported fields
}

MockSchedulerService_ExecutionNotificationsClient is a mock of SchedulerService_ExecutionNotificationsClient interface

func NewMockSchedulerService_ExecutionNotificationsClient 

func NewMockSchedulerService_ExecutionNotificationsClient(ctrl *gomock.Controller) *MockSchedulerService_ExecutionNotificationsClient

NewMockSchedulerService_ExecutionNotificationsClient creates a new mock instance

func (*MockSchedulerService_ExecutionNotificationsClient) CloseSend 

func (m *MockSchedulerService_ExecutionNotificationsClient) CloseSend() error

CloseSend mocks base method

func (*MockSchedulerService_ExecutionNotificationsClient) Context 

func (m *MockSchedulerService_ExecutionNotificationsClient) Context() context.Context

Context mocks base method

func (*MockSchedulerService_ExecutionNotificationsClient) EXPECT 

func (m *MockSchedulerService_ExecutionNotificationsClient) EXPECT() *MockSchedulerService_ExecutionNotificationsClientMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockSchedulerService_ExecutionNotificationsClient) Header 

func (m *MockSchedulerService_ExecutionNotificationsClient) Header() (metadata.MD, error)

Header mocks base method

func (*MockSchedulerService_ExecutionNotificationsClient) Recv 

func (m *MockSchedulerService_ExecutionNotificationsClient) Recv() (*scheduler.ExecutionNotificationsResponse, error)

Recv mocks base method

func (*MockSchedulerService_ExecutionNotificationsClient) RecvMsg 

func (m *MockSchedulerService_ExecutionNotificationsClient) RecvMsg(arg0 interface{}) error

RecvMsg mocks base method

func (*MockSchedulerService_ExecutionNotificationsClient) SendMsg 

func (m *MockSchedulerService_ExecutionNotificationsClient) SendMsg(arg0 interface{}) error

SendMsg mocks base method

func (*MockSchedulerService_ExecutionNotificationsClient) Trailer 

func (m *MockSchedulerService_ExecutionNotificationsClient) Trailer() metadata.MD

Trailer mocks base method

type MockSchedulerService_ExecutionNotificationsClientMockRecorder 

type MockSchedulerService_ExecutionNotificationsClientMockRecorder struct {
	// contains filtered or unexported fields
}

MockSchedulerService_ExecutionNotificationsClientMockRecorder is the mock recorder for MockSchedulerService_ExecutionNotificationsClient

func (*MockSchedulerService_ExecutionNotificationsClientMockRecorder) CloseSend 

func (mr *MockSchedulerService_ExecutionNotificationsClientMockRecorder) CloseSend() *gomock.Call

CloseSend indicates an expected call of CloseSend

func (*MockSchedulerService_ExecutionNotificationsClientMockRecorder) Context 

func (mr *MockSchedulerService_ExecutionNotificationsClientMockRecorder) Context() *gomock.Call

Context indicates an expected call of Context

func (*MockSchedulerService_ExecutionNotificationsClientMockRecorder) Header 

func (mr *MockSchedulerService_ExecutionNotificationsClientMockRecorder) Header() *gomock.Call

Header indicates an expected call of Header

func (*MockSchedulerService_ExecutionNotificationsClientMockRecorder) Recv 

func (mr *MockSchedulerService_ExecutionNotificationsClientMockRecorder) Recv() *gomock.Call

Recv indicates an expected call of Recv

func (*MockSchedulerService_ExecutionNotificationsClientMockRecorder) RecvMsg 

func (mr *MockSchedulerService_ExecutionNotificationsClientMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call

RecvMsg indicates an expected call of RecvMsg

func (*MockSchedulerService_ExecutionNotificationsClientMockRecorder) SendMsg 

func (mr *MockSchedulerService_ExecutionNotificationsClientMockRecorder) SendMsg(arg0 interface{}) *gomock.Call

SendMsg indicates an expected call of SendMsg

func (*MockSchedulerService_ExecutionNotificationsClientMockRecorder) Trailer 

func (mr *MockSchedulerService_ExecutionNotificationsClientMockRecorder) Trailer() *gomock.Call

Trailer indicates an expected call of Trailer

type RemoteConfig 

type RemoteConfig struct {
	Method        Method
	URL           string
	Headers       map[string]string
	Body          []byte
	ExpectedCodes []uint32
	Timeout       time.Duration
}

type SchedulerClient 

type SchedulerClient interface {
	ScheduleDummyTask(ctx context.Context, id string, time time.Time) error
	ScheduleCommandTask(
		ctx context.Context, id string, time time.Time, timeout time.Duration, command string, arguments ...string,
	) error
	ScheduleRemoteTask(ctx context.Context, id string, time time.Time, retries int32, config RemoteConfig) error
	ExecutionNotifications(ctx context.Context) (<-chan *ExecutionInfo, <-chan error, error)

	Close() error
}

func NewDefaultClient 

func NewDefaultClient(host string, port int) (SchedulerClient, error)

func NewSchedulerClient 

func NewSchedulerClient(host string, port int, options []grpc.DialOption) (SchedulerClient, error)

type Status 

type Status = schedulerV1.ExecutionStatus

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.