Documentation ¶
Overview ¶
Package m3em is a generated protocol buffer package.
It is generated from these files:
operator.proto
It has these top-level messages:
SetupRequest SetupResponse StartRequest StartResponse StopRequest StopResponse TeardownRequest TeardownResponse PullFileRequest PullFileResponse PushFileRequest PushFileResponse DataChunk
Index ¶
- Variables
- func RegisterOperatorServer(s *grpc.Server, srv OperatorServer)
- type DataChunk
- type MockOperatorClient
- func (_m *MockOperatorClient) EXPECT() *MockOperatorClientMockRecorder
- func (_m *MockOperatorClient) PullFile(_param0 context.Context, _param1 *PullFileRequest, _param2 ...grpc.CallOption) (Operator_PullFileClient, error)
- func (_m *MockOperatorClient) PushFile(_param0 context.Context, _param1 ...grpc.CallOption) (Operator_PushFileClient, error)
- func (_m *MockOperatorClient) Setup(_param0 context.Context, _param1 *SetupRequest, _param2 ...grpc.CallOption) (*SetupResponse, error)
- func (_m *MockOperatorClient) Start(_param0 context.Context, _param1 *StartRequest, _param2 ...grpc.CallOption) (*StartResponse, error)
- func (_m *MockOperatorClient) Stop(_param0 context.Context, _param1 *StopRequest, _param2 ...grpc.CallOption) (*StopResponse, error)
- func (_m *MockOperatorClient) Teardown(_param0 context.Context, _param1 *TeardownRequest, _param2 ...grpc.CallOption) (*TeardownResponse, error)
- type MockOperatorClientMockRecorder
- func (_mr *MockOperatorClientMockRecorder) PullFile(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (_mr *MockOperatorClientMockRecorder) PushFile(arg0 interface{}, arg1 ...interface{}) *gomock.Call
- func (_mr *MockOperatorClientMockRecorder) Setup(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (_mr *MockOperatorClientMockRecorder) Start(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (_mr *MockOperatorClientMockRecorder) Stop(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (_mr *MockOperatorClientMockRecorder) Teardown(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- type MockOperator_PullFileClient
- func (_m *MockOperator_PullFileClient) CloseSend() error
- func (_m *MockOperator_PullFileClient) Context() context.Context
- func (_m *MockOperator_PullFileClient) EXPECT() *MockOperator_PullFileClientMockRecorder
- func (_m *MockOperator_PullFileClient) Header() (metadata.MD, error)
- func (_m *MockOperator_PullFileClient) Recv() (*PullFileResponse, error)
- func (_m *MockOperator_PullFileClient) RecvMsg(_param0 interface{}) error
- func (_m *MockOperator_PullFileClient) SendMsg(_param0 interface{}) error
- func (_m *MockOperator_PullFileClient) Trailer() metadata.MD
- type MockOperator_PullFileClientMockRecorder
- func (_mr *MockOperator_PullFileClientMockRecorder) CloseSend() *gomock.Call
- func (_mr *MockOperator_PullFileClientMockRecorder) Context() *gomock.Call
- func (_mr *MockOperator_PullFileClientMockRecorder) Header() *gomock.Call
- func (_mr *MockOperator_PullFileClientMockRecorder) Recv() *gomock.Call
- func (_mr *MockOperator_PullFileClientMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call
- func (_mr *MockOperator_PullFileClientMockRecorder) SendMsg(arg0 interface{}) *gomock.Call
- func (_mr *MockOperator_PullFileClientMockRecorder) Trailer() *gomock.Call
- type MockOperator_PullFileServer
- func (_m *MockOperator_PullFileServer) Context() context.Context
- func (_m *MockOperator_PullFileServer) EXPECT() *MockOperator_PullFileServerMockRecorder
- func (_m *MockOperator_PullFileServer) RecvMsg(_param0 interface{}) error
- func (_m *MockOperator_PullFileServer) Send(_param0 *PullFileResponse) error
- func (_m *MockOperator_PullFileServer) SendHeader(_param0 metadata.MD) error
- func (_m *MockOperator_PullFileServer) SendMsg(_param0 interface{}) error
- func (_m *MockOperator_PullFileServer) SetHeader(_param0 metadata.MD) error
- func (_m *MockOperator_PullFileServer) SetTrailer(_param0 metadata.MD)
- type MockOperator_PullFileServerMockRecorder
- func (_mr *MockOperator_PullFileServerMockRecorder) Context() *gomock.Call
- func (_mr *MockOperator_PullFileServerMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call
- func (_mr *MockOperator_PullFileServerMockRecorder) Send(arg0 interface{}) *gomock.Call
- func (_mr *MockOperator_PullFileServerMockRecorder) SendHeader(arg0 interface{}) *gomock.Call
- func (_mr *MockOperator_PullFileServerMockRecorder) SendMsg(arg0 interface{}) *gomock.Call
- func (_mr *MockOperator_PullFileServerMockRecorder) SetHeader(arg0 interface{}) *gomock.Call
- func (_mr *MockOperator_PullFileServerMockRecorder) SetTrailer(arg0 interface{}) *gomock.Call
- type MockOperator_PushFileClient
- func (_m *MockOperator_PushFileClient) CloseAndRecv() (*PushFileResponse, error)
- func (_m *MockOperator_PushFileClient) CloseSend() error
- func (_m *MockOperator_PushFileClient) Context() context.Context
- func (_m *MockOperator_PushFileClient) EXPECT() *MockOperator_PushFileClientMockRecorder
- func (_m *MockOperator_PushFileClient) Header() (metadata.MD, error)
- func (_m *MockOperator_PushFileClient) RecvMsg(_param0 interface{}) error
- func (_m *MockOperator_PushFileClient) Send(_param0 *PushFileRequest) error
- func (_m *MockOperator_PushFileClient) SendMsg(_param0 interface{}) error
- func (_m *MockOperator_PushFileClient) Trailer() metadata.MD
- type MockOperator_PushFileClientMockRecorder
- func (_mr *MockOperator_PushFileClientMockRecorder) CloseAndRecv() *gomock.Call
- func (_mr *MockOperator_PushFileClientMockRecorder) CloseSend() *gomock.Call
- func (_mr *MockOperator_PushFileClientMockRecorder) Context() *gomock.Call
- func (_mr *MockOperator_PushFileClientMockRecorder) Header() *gomock.Call
- func (_mr *MockOperator_PushFileClientMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call
- func (_mr *MockOperator_PushFileClientMockRecorder) Send(arg0 interface{}) *gomock.Call
- func (_mr *MockOperator_PushFileClientMockRecorder) SendMsg(arg0 interface{}) *gomock.Call
- func (_mr *MockOperator_PushFileClientMockRecorder) Trailer() *gomock.Call
- type OperatorClient
- type OperatorServer
- type Operator_PullFileClient
- type Operator_PullFileServer
- type Operator_PushFileClient
- type Operator_PushFileServer
- type PullFileContentType
- type PullFileRequest
- func (*PullFileRequest) Descriptor() ([]byte, []int)
- func (m *PullFileRequest) GetChunkSize() int64
- func (m *PullFileRequest) GetFileType() PullFileType
- func (m *PullFileRequest) GetMaxSize() int64
- func (*PullFileRequest) ProtoMessage()
- func (m *PullFileRequest) Reset()
- func (m *PullFileRequest) String() string
- type PullFileResponse
- type PullFileType
- type PushFileRequest
- func (*PushFileRequest) Descriptor() ([]byte, []int)
- func (m *PushFileRequest) GetData() *DataChunk
- func (m *PushFileRequest) GetOverwrite() bool
- func (m *PushFileRequest) GetTargetPaths() []string
- func (m *PushFileRequest) GetType() PushFileType
- func (*PushFileRequest) ProtoMessage()
- func (m *PushFileRequest) Reset()
- func (m *PushFileRequest) String() string
- type PushFileResponse
- type PushFileType
- type SetupRequest
- func (*SetupRequest) Descriptor() ([]byte, []int)
- func (m *SetupRequest) GetForce() bool
- func (m *SetupRequest) GetHeartbeatEnabled() bool
- func (m *SetupRequest) GetHeartbeatEndpoint() string
- func (m *SetupRequest) GetHeartbeatFrequencySecs() uint32
- func (m *SetupRequest) GetOperatorUuid() string
- func (m *SetupRequest) GetSessionToken() string
- func (*SetupRequest) ProtoMessage()
- func (m *SetupRequest) Reset()
- func (m *SetupRequest) String() string
- type SetupResponse
- type StartRequest
- type StartResponse
- type StopRequest
- type StopResponse
- type TeardownRequest
- type TeardownResponse
Constants ¶
This section is empty.
Variables ¶
var PullFileContentType_name = map[int32]string{
0: "PULL_FILE_CONTENT_TYPE_UNKNOWN",
1: "PULL_FILE_CONTENT_TYPE_LAST",
2: "PULL_FILE_CONTENT_TYPE_FULL",
}
var PullFileContentType_value = map[string]int32{
"PULL_FILE_CONTENT_TYPE_UNKNOWN": 0,
"PULL_FILE_CONTENT_TYPE_LAST": 1,
"PULL_FILE_CONTENT_TYPE_FULL": 2,
}
var PullFileType_name = map[int32]string{
0: "PULL_FILE_TYPE_UNKNOWN",
1: "PULL_FILE_TYPE_SERVICE_STDOUT",
2: "PULL_FILE_TYPE_SERVICE_STDERR",
}
var PullFileType_value = map[string]int32{
"PULL_FILE_TYPE_UNKNOWN": 0,
"PULL_FILE_TYPE_SERVICE_STDOUT": 1,
"PULL_FILE_TYPE_SERVICE_STDERR": 2,
}
var PushFileType_name = map[int32]string{
0: "PUSH_FILE_TYPE_UNKNOWN",
1: "PUSH_FILE_TYPE_SERVICE_BINARY",
2: "PUSH_FILE_TYPE_SERVICE_CONFIG",
3: "PUSH_FILE_TYPE_DATA_FILE",
}
var PushFileType_value = map[string]int32{
"PUSH_FILE_TYPE_UNKNOWN": 0,
"PUSH_FILE_TYPE_SERVICE_BINARY": 1,
"PUSH_FILE_TYPE_SERVICE_CONFIG": 2,
"PUSH_FILE_TYPE_DATA_FILE": 3,
}
Functions ¶
func RegisterOperatorServer ¶
func RegisterOperatorServer(s *grpc.Server, srv OperatorServer)
Types ¶
type DataChunk ¶
type DataChunk struct { Idx int32 `protobuf:"varint,1,opt,name=idx" json:"idx,omitempty"` Bytes []byte `protobuf:"bytes,2,opt,name=bytes,proto3" json:"bytes,omitempty"` }
func (*DataChunk) Descriptor ¶
func (*DataChunk) ProtoMessage ¶
func (*DataChunk) ProtoMessage()
type MockOperatorClient ¶
type MockOperatorClient struct {
// contains filtered or unexported fields
}
MockOperatorClient is a mock of OperatorClient interface
func NewMockOperatorClient ¶
func NewMockOperatorClient(ctrl *gomock.Controller) *MockOperatorClient
NewMockOperatorClient creates a new mock instance
func (*MockOperatorClient) EXPECT ¶
func (_m *MockOperatorClient) EXPECT() *MockOperatorClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockOperatorClient) PullFile ¶
func (_m *MockOperatorClient) PullFile(_param0 context.Context, _param1 *PullFileRequest, _param2 ...grpc.CallOption) (Operator_PullFileClient, error)
PullFile mocks base method
func (*MockOperatorClient) PushFile ¶
func (_m *MockOperatorClient) PushFile(_param0 context.Context, _param1 ...grpc.CallOption) (Operator_PushFileClient, error)
PushFile mocks base method
func (*MockOperatorClient) Setup ¶
func (_m *MockOperatorClient) Setup(_param0 context.Context, _param1 *SetupRequest, _param2 ...grpc.CallOption) (*SetupResponse, error)
Setup mocks base method
func (*MockOperatorClient) Start ¶
func (_m *MockOperatorClient) Start(_param0 context.Context, _param1 *StartRequest, _param2 ...grpc.CallOption) (*StartResponse, error)
Start mocks base method
func (*MockOperatorClient) Stop ¶
func (_m *MockOperatorClient) Stop(_param0 context.Context, _param1 *StopRequest, _param2 ...grpc.CallOption) (*StopResponse, error)
Stop mocks base method
func (*MockOperatorClient) Teardown ¶
func (_m *MockOperatorClient) Teardown(_param0 context.Context, _param1 *TeardownRequest, _param2 ...grpc.CallOption) (*TeardownResponse, error)
Teardown mocks base method
type MockOperatorClientMockRecorder ¶
type MockOperatorClientMockRecorder struct {
// contains filtered or unexported fields
}
MockOperatorClientMockRecorder is the mock recorder for MockOperatorClient
func (*MockOperatorClientMockRecorder) PullFile ¶
func (_mr *MockOperatorClientMockRecorder) PullFile(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
PullFile indicates an expected call of PullFile
func (*MockOperatorClientMockRecorder) PushFile ¶
func (_mr *MockOperatorClientMockRecorder) PushFile(arg0 interface{}, arg1 ...interface{}) *gomock.Call
PushFile indicates an expected call of PushFile
func (*MockOperatorClientMockRecorder) Setup ¶
func (_mr *MockOperatorClientMockRecorder) Setup(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
Setup indicates an expected call of Setup
func (*MockOperatorClientMockRecorder) Start ¶
func (_mr *MockOperatorClientMockRecorder) Start(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
Start indicates an expected call of Start
func (*MockOperatorClientMockRecorder) Stop ¶
func (_mr *MockOperatorClientMockRecorder) Stop(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
Stop indicates an expected call of Stop
func (*MockOperatorClientMockRecorder) Teardown ¶
func (_mr *MockOperatorClientMockRecorder) Teardown(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
Teardown indicates an expected call of Teardown
type MockOperator_PullFileClient ¶
type MockOperator_PullFileClient struct {
// contains filtered or unexported fields
}
MockOperator_PullFileClient is a mock of Operator_PullFileClient interface
func NewMockOperator_PullFileClient ¶
func NewMockOperator_PullFileClient(ctrl *gomock.Controller) *MockOperator_PullFileClient
NewMockOperator_PullFileClient creates a new mock instance
func (*MockOperator_PullFileClient) CloseSend ¶
func (_m *MockOperator_PullFileClient) CloseSend() error
CloseSend mocks base method
func (*MockOperator_PullFileClient) Context ¶
func (_m *MockOperator_PullFileClient) Context() context.Context
Context mocks base method
func (*MockOperator_PullFileClient) EXPECT ¶
func (_m *MockOperator_PullFileClient) EXPECT() *MockOperator_PullFileClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockOperator_PullFileClient) Header ¶
func (_m *MockOperator_PullFileClient) Header() (metadata.MD, error)
Header mocks base method
func (*MockOperator_PullFileClient) Recv ¶
func (_m *MockOperator_PullFileClient) Recv() (*PullFileResponse, error)
Recv mocks base method
func (*MockOperator_PullFileClient) RecvMsg ¶
func (_m *MockOperator_PullFileClient) RecvMsg(_param0 interface{}) error
RecvMsg mocks base method
func (*MockOperator_PullFileClient) SendMsg ¶
func (_m *MockOperator_PullFileClient) SendMsg(_param0 interface{}) error
SendMsg mocks base method
func (*MockOperator_PullFileClient) Trailer ¶
func (_m *MockOperator_PullFileClient) Trailer() metadata.MD
Trailer mocks base method
type MockOperator_PullFileClientMockRecorder ¶
type MockOperator_PullFileClientMockRecorder struct {
// contains filtered or unexported fields
}
MockOperator_PullFileClientMockRecorder is the mock recorder for MockOperator_PullFileClient
func (*MockOperator_PullFileClientMockRecorder) CloseSend ¶
func (_mr *MockOperator_PullFileClientMockRecorder) CloseSend() *gomock.Call
CloseSend indicates an expected call of CloseSend
func (*MockOperator_PullFileClientMockRecorder) Context ¶
func (_mr *MockOperator_PullFileClientMockRecorder) Context() *gomock.Call
Context indicates an expected call of Context
func (*MockOperator_PullFileClientMockRecorder) Header ¶
func (_mr *MockOperator_PullFileClientMockRecorder) Header() *gomock.Call
Header indicates an expected call of Header
func (*MockOperator_PullFileClientMockRecorder) Recv ¶
func (_mr *MockOperator_PullFileClientMockRecorder) Recv() *gomock.Call
Recv indicates an expected call of Recv
func (*MockOperator_PullFileClientMockRecorder) RecvMsg ¶
func (_mr *MockOperator_PullFileClientMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call
RecvMsg indicates an expected call of RecvMsg
func (*MockOperator_PullFileClientMockRecorder) SendMsg ¶
func (_mr *MockOperator_PullFileClientMockRecorder) SendMsg(arg0 interface{}) *gomock.Call
SendMsg indicates an expected call of SendMsg
func (*MockOperator_PullFileClientMockRecorder) Trailer ¶
func (_mr *MockOperator_PullFileClientMockRecorder) Trailer() *gomock.Call
Trailer indicates an expected call of Trailer
type MockOperator_PullFileServer ¶
type MockOperator_PullFileServer struct {
// contains filtered or unexported fields
}
MockOperator_PullFileServer is a mock of Operator_PullFileServer interface
func NewMockOperator_PullFileServer ¶
func NewMockOperator_PullFileServer(ctrl *gomock.Controller) *MockOperator_PullFileServer
NewMockOperator_PullFileServer creates a new mock instance
func (*MockOperator_PullFileServer) Context ¶
func (_m *MockOperator_PullFileServer) Context() context.Context
Context mocks base method
func (*MockOperator_PullFileServer) EXPECT ¶
func (_m *MockOperator_PullFileServer) EXPECT() *MockOperator_PullFileServerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockOperator_PullFileServer) RecvMsg ¶
func (_m *MockOperator_PullFileServer) RecvMsg(_param0 interface{}) error
RecvMsg mocks base method
func (*MockOperator_PullFileServer) Send ¶
func (_m *MockOperator_PullFileServer) Send(_param0 *PullFileResponse) error
Send mocks base method
func (*MockOperator_PullFileServer) SendHeader ¶
func (_m *MockOperator_PullFileServer) SendHeader(_param0 metadata.MD) error
SendHeader mocks base method
func (*MockOperator_PullFileServer) SendMsg ¶
func (_m *MockOperator_PullFileServer) SendMsg(_param0 interface{}) error
SendMsg mocks base method
func (*MockOperator_PullFileServer) SetHeader ¶
func (_m *MockOperator_PullFileServer) SetHeader(_param0 metadata.MD) error
SetHeader mocks base method
func (*MockOperator_PullFileServer) SetTrailer ¶
func (_m *MockOperator_PullFileServer) SetTrailer(_param0 metadata.MD)
SetTrailer mocks base method
type MockOperator_PullFileServerMockRecorder ¶
type MockOperator_PullFileServerMockRecorder struct {
// contains filtered or unexported fields
}
MockOperator_PullFileServerMockRecorder is the mock recorder for MockOperator_PullFileServer
func (*MockOperator_PullFileServerMockRecorder) Context ¶
func (_mr *MockOperator_PullFileServerMockRecorder) Context() *gomock.Call
Context indicates an expected call of Context
func (*MockOperator_PullFileServerMockRecorder) RecvMsg ¶
func (_mr *MockOperator_PullFileServerMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call
RecvMsg indicates an expected call of RecvMsg
func (*MockOperator_PullFileServerMockRecorder) Send ¶
func (_mr *MockOperator_PullFileServerMockRecorder) Send(arg0 interface{}) *gomock.Call
Send indicates an expected call of Send
func (*MockOperator_PullFileServerMockRecorder) SendHeader ¶
func (_mr *MockOperator_PullFileServerMockRecorder) SendHeader(arg0 interface{}) *gomock.Call
SendHeader indicates an expected call of SendHeader
func (*MockOperator_PullFileServerMockRecorder) SendMsg ¶
func (_mr *MockOperator_PullFileServerMockRecorder) SendMsg(arg0 interface{}) *gomock.Call
SendMsg indicates an expected call of SendMsg
func (*MockOperator_PullFileServerMockRecorder) SetHeader ¶
func (_mr *MockOperator_PullFileServerMockRecorder) SetHeader(arg0 interface{}) *gomock.Call
SetHeader indicates an expected call of SetHeader
func (*MockOperator_PullFileServerMockRecorder) SetTrailer ¶
func (_mr *MockOperator_PullFileServerMockRecorder) SetTrailer(arg0 interface{}) *gomock.Call
SetTrailer indicates an expected call of SetTrailer
type MockOperator_PushFileClient ¶
type MockOperator_PushFileClient struct {
// contains filtered or unexported fields
}
MockOperator_PushFileClient is a mock of Operator_PushFileClient interface
func NewMockOperator_PushFileClient ¶
func NewMockOperator_PushFileClient(ctrl *gomock.Controller) *MockOperator_PushFileClient
NewMockOperator_PushFileClient creates a new mock instance
func (*MockOperator_PushFileClient) CloseAndRecv ¶
func (_m *MockOperator_PushFileClient) CloseAndRecv() (*PushFileResponse, error)
CloseAndRecv mocks base method
func (*MockOperator_PushFileClient) CloseSend ¶
func (_m *MockOperator_PushFileClient) CloseSend() error
CloseSend mocks base method
func (*MockOperator_PushFileClient) Context ¶
func (_m *MockOperator_PushFileClient) Context() context.Context
Context mocks base method
func (*MockOperator_PushFileClient) EXPECT ¶
func (_m *MockOperator_PushFileClient) EXPECT() *MockOperator_PushFileClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockOperator_PushFileClient) Header ¶
func (_m *MockOperator_PushFileClient) Header() (metadata.MD, error)
Header mocks base method
func (*MockOperator_PushFileClient) RecvMsg ¶
func (_m *MockOperator_PushFileClient) RecvMsg(_param0 interface{}) error
RecvMsg mocks base method
func (*MockOperator_PushFileClient) Send ¶
func (_m *MockOperator_PushFileClient) Send(_param0 *PushFileRequest) error
Send mocks base method
func (*MockOperator_PushFileClient) SendMsg ¶
func (_m *MockOperator_PushFileClient) SendMsg(_param0 interface{}) error
SendMsg mocks base method
func (*MockOperator_PushFileClient) Trailer ¶
func (_m *MockOperator_PushFileClient) Trailer() metadata.MD
Trailer mocks base method
type MockOperator_PushFileClientMockRecorder ¶
type MockOperator_PushFileClientMockRecorder struct {
// contains filtered or unexported fields
}
MockOperator_PushFileClientMockRecorder is the mock recorder for MockOperator_PushFileClient
func (*MockOperator_PushFileClientMockRecorder) CloseAndRecv ¶
func (_mr *MockOperator_PushFileClientMockRecorder) CloseAndRecv() *gomock.Call
CloseAndRecv indicates an expected call of CloseAndRecv
func (*MockOperator_PushFileClientMockRecorder) CloseSend ¶
func (_mr *MockOperator_PushFileClientMockRecorder) CloseSend() *gomock.Call
CloseSend indicates an expected call of CloseSend
func (*MockOperator_PushFileClientMockRecorder) Context ¶
func (_mr *MockOperator_PushFileClientMockRecorder) Context() *gomock.Call
Context indicates an expected call of Context
func (*MockOperator_PushFileClientMockRecorder) Header ¶
func (_mr *MockOperator_PushFileClientMockRecorder) Header() *gomock.Call
Header indicates an expected call of Header
func (*MockOperator_PushFileClientMockRecorder) RecvMsg ¶
func (_mr *MockOperator_PushFileClientMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call
RecvMsg indicates an expected call of RecvMsg
func (*MockOperator_PushFileClientMockRecorder) Send ¶
func (_mr *MockOperator_PushFileClientMockRecorder) Send(arg0 interface{}) *gomock.Call
Send indicates an expected call of Send
func (*MockOperator_PushFileClientMockRecorder) SendMsg ¶
func (_mr *MockOperator_PushFileClientMockRecorder) SendMsg(arg0 interface{}) *gomock.Call
SendMsg indicates an expected call of SendMsg
func (*MockOperator_PushFileClientMockRecorder) Trailer ¶
func (_mr *MockOperator_PushFileClientMockRecorder) Trailer() *gomock.Call
Trailer indicates an expected call of Trailer
type OperatorClient ¶
type OperatorClient interface { Setup(ctx context.Context, in *SetupRequest, opts ...grpc.CallOption) (*SetupResponse, error) Start(ctx context.Context, in *StartRequest, opts ...grpc.CallOption) (*StartResponse, error) Stop(ctx context.Context, in *StopRequest, opts ...grpc.CallOption) (*StopResponse, error) Teardown(ctx context.Context, in *TeardownRequest, opts ...grpc.CallOption) (*TeardownResponse, error) PullFile(ctx context.Context, in *PullFileRequest, opts ...grpc.CallOption) (Operator_PullFileClient, error) PushFile(ctx context.Context, opts ...grpc.CallOption) (Operator_PushFileClient, error) }
func NewOperatorClient ¶
func NewOperatorClient(cc *grpc.ClientConn) OperatorClient
type OperatorServer ¶
type OperatorServer interface { Setup(context.Context, *SetupRequest) (*SetupResponse, error) Start(context.Context, *StartRequest) (*StartResponse, error) Stop(context.Context, *StopRequest) (*StopResponse, error) Teardown(context.Context, *TeardownRequest) (*TeardownResponse, error) PullFile(*PullFileRequest, Operator_PullFileServer) error PushFile(Operator_PushFileServer) error }
type Operator_PullFileClient ¶
type Operator_PullFileClient interface { Recv() (*PullFileResponse, error) grpc.ClientStream }
type Operator_PullFileServer ¶
type Operator_PullFileServer interface { Send(*PullFileResponse) error grpc.ServerStream }
type Operator_PushFileClient ¶
type Operator_PushFileClient interface { Send(*PushFileRequest) error CloseAndRecv() (*PushFileResponse, error) grpc.ClientStream }
type Operator_PushFileServer ¶
type Operator_PushFileServer interface { SendAndClose(*PushFileResponse) error Recv() (*PushFileRequest, error) grpc.ServerStream }
type PullFileContentType ¶
type PullFileContentType int32
const ( PullFileContentType_PULL_FILE_CONTENT_TYPE_UNKNOWN PullFileContentType = 0 PullFileContentType_PULL_FILE_CONTENT_TYPE_LAST PullFileContentType = 1 PullFileContentType_PULL_FILE_CONTENT_TYPE_FULL PullFileContentType = 2 )
func (PullFileContentType) EnumDescriptor ¶
func (PullFileContentType) EnumDescriptor() ([]byte, []int)
func (PullFileContentType) String ¶
func (x PullFileContentType) String() string
type PullFileRequest ¶
type PullFileRequest struct { FileType PullFileType `protobuf:"varint,1,opt,name=file_type,json=fileType,enum=m3em.PullFileType" json:"file_type,omitempty"` ChunkSize int64 `protobuf:"varint,2,opt,name=chunk_size,json=chunkSize" json:"chunk_size,omitempty"` MaxSize int64 `protobuf:"varint,3,opt,name=max_size,json=maxSize" json:"max_size,omitempty"` }
PullFileRequest(s) are used to transfer files from remote agents to the master.
func (*PullFileRequest) Descriptor ¶
func (*PullFileRequest) Descriptor() ([]byte, []int)
func (*PullFileRequest) GetChunkSize ¶
func (m *PullFileRequest) GetChunkSize() int64
func (*PullFileRequest) GetFileType ¶
func (m *PullFileRequest) GetFileType() PullFileType
func (*PullFileRequest) GetMaxSize ¶
func (m *PullFileRequest) GetMaxSize() int64
func (*PullFileRequest) ProtoMessage ¶
func (*PullFileRequest) ProtoMessage()
func (*PullFileRequest) Reset ¶
func (m *PullFileRequest) Reset()
func (*PullFileRequest) String ¶
func (m *PullFileRequest) String() string
type PullFileResponse ¶
type PullFileResponse struct { Data *DataChunk `protobuf:"bytes,1,opt,name=data" json:"data,omitempty"` Truncated bool `protobuf:"varint,2,opt,name=truncated" json:"truncated,omitempty"` }
func (*PullFileResponse) Descriptor ¶
func (*PullFileResponse) Descriptor() ([]byte, []int)
func (*PullFileResponse) GetData ¶
func (m *PullFileResponse) GetData() *DataChunk
func (*PullFileResponse) GetTruncated ¶
func (m *PullFileResponse) GetTruncated() bool
func (*PullFileResponse) ProtoMessage ¶
func (*PullFileResponse) ProtoMessage()
func (*PullFileResponse) Reset ¶
func (m *PullFileResponse) Reset()
func (*PullFileResponse) String ¶
func (m *PullFileResponse) String() string
type PullFileType ¶
type PullFileType int32
const ( PullFileType_PULL_FILE_TYPE_UNKNOWN PullFileType = 0 PullFileType_PULL_FILE_TYPE_SERVICE_STDOUT PullFileType = 1 PullFileType_PULL_FILE_TYPE_SERVICE_STDERR PullFileType = 2 )
func (PullFileType) EnumDescriptor ¶
func (PullFileType) EnumDescriptor() ([]byte, []int)
func (PullFileType) String ¶
func (x PullFileType) String() string
type PushFileRequest ¶
type PushFileRequest struct { Type PushFileType `protobuf:"varint,1,opt,name=type,enum=m3em.PushFileType" json:"type,omitempty"` Overwrite bool `protobuf:"varint,2,opt,name=overwrite" json:"overwrite,omitempty"` Data *DataChunk `protobuf:"bytes,3,opt,name=data" json:"data,omitempty"` TargetPaths []string `protobuf:"bytes,4,rep,name=target_paths,json=targetPaths" json:"target_paths,omitempty"` }
PushFileRequest(s) are used to transfer files from the master to remote agents.
func (*PushFileRequest) Descriptor ¶
func (*PushFileRequest) Descriptor() ([]byte, []int)
func (*PushFileRequest) GetData ¶
func (m *PushFileRequest) GetData() *DataChunk
func (*PushFileRequest) GetOverwrite ¶
func (m *PushFileRequest) GetOverwrite() bool
func (*PushFileRequest) GetTargetPaths ¶
func (m *PushFileRequest) GetTargetPaths() []string
func (*PushFileRequest) GetType ¶
func (m *PushFileRequest) GetType() PushFileType
func (*PushFileRequest) ProtoMessage ¶
func (*PushFileRequest) ProtoMessage()
func (*PushFileRequest) Reset ¶
func (m *PushFileRequest) Reset()
func (*PushFileRequest) String ¶
func (m *PushFileRequest) String() string
type PushFileResponse ¶
type PushFileResponse struct { FileChecksum uint32 `protobuf:"varint,1,opt,name=file_checksum,json=fileChecksum" json:"file_checksum,omitempty"` NumChunksRecvd int32 `protobuf:"varint,2,opt,name=num_chunks_recvd,json=numChunksRecvd" json:"num_chunks_recvd,omitempty"` }
func (*PushFileResponse) Descriptor ¶
func (*PushFileResponse) Descriptor() ([]byte, []int)
func (*PushFileResponse) GetFileChecksum ¶
func (m *PushFileResponse) GetFileChecksum() uint32
func (*PushFileResponse) GetNumChunksRecvd ¶
func (m *PushFileResponse) GetNumChunksRecvd() int32
func (*PushFileResponse) ProtoMessage ¶
func (*PushFileResponse) ProtoMessage()
func (*PushFileResponse) Reset ¶
func (m *PushFileResponse) Reset()
func (*PushFileResponse) String ¶
func (m *PushFileResponse) String() string
type PushFileType ¶
type PushFileType int32
const ( PushFileType_PUSH_FILE_TYPE_UNKNOWN PushFileType = 0 PushFileType_PUSH_FILE_TYPE_SERVICE_BINARY PushFileType = 1 PushFileType_PUSH_FILE_TYPE_SERVICE_CONFIG PushFileType = 2 PushFileType_PUSH_FILE_TYPE_DATA_FILE PushFileType = 3 )
func (PushFileType) EnumDescriptor ¶
func (PushFileType) EnumDescriptor() ([]byte, []int)
func (PushFileType) String ¶
func (x PushFileType) String() string
type SetupRequest ¶
type SetupRequest struct { SessionToken string `protobuf:"bytes,1,opt,name=session_token,json=sessionToken" json:"session_token,omitempty"` OperatorUuid string `protobuf:"bytes,2,opt,name=operator_uuid,json=operatorUuid" json:"operator_uuid,omitempty"` Force bool `protobuf:"varint,3,opt,name=force" json:"force,omitempty"` HeartbeatEnabled bool `protobuf:"varint,4,opt,name=heartbeat_enabled,json=heartbeatEnabled" json:"heartbeat_enabled,omitempty"` HeartbeatEndpoint string `protobuf:"bytes,5,opt,name=heartbeat_endpoint,json=heartbeatEndpoint" json:"heartbeat_endpoint,omitempty"` HeartbeatFrequencySecs uint32 `protobuf:"varint,6,opt,name=heartbeat_frequency_secs,json=heartbeatFrequencySecs" json:"heartbeat_frequency_secs,omitempty"` }
func (*SetupRequest) Descriptor ¶
func (*SetupRequest) Descriptor() ([]byte, []int)
func (*SetupRequest) GetForce ¶
func (m *SetupRequest) GetForce() bool
func (*SetupRequest) GetHeartbeatEnabled ¶
func (m *SetupRequest) GetHeartbeatEnabled() bool
func (*SetupRequest) GetHeartbeatEndpoint ¶
func (m *SetupRequest) GetHeartbeatEndpoint() string
func (*SetupRequest) GetHeartbeatFrequencySecs ¶
func (m *SetupRequest) GetHeartbeatFrequencySecs() uint32
func (*SetupRequest) GetOperatorUuid ¶
func (m *SetupRequest) GetOperatorUuid() string
func (*SetupRequest) GetSessionToken ¶
func (m *SetupRequest) GetSessionToken() string
func (*SetupRequest) ProtoMessage ¶
func (*SetupRequest) ProtoMessage()
func (*SetupRequest) Reset ¶
func (m *SetupRequest) Reset()
func (*SetupRequest) String ¶
func (m *SetupRequest) String() string
type SetupResponse ¶
type SetupResponse struct { }
func (*SetupResponse) Descriptor ¶
func (*SetupResponse) Descriptor() ([]byte, []int)
func (*SetupResponse) ProtoMessage ¶
func (*SetupResponse) ProtoMessage()
func (*SetupResponse) Reset ¶
func (m *SetupResponse) Reset()
func (*SetupResponse) String ¶
func (m *SetupResponse) String() string
type StartRequest ¶
type StartRequest struct { }
func (*StartRequest) Descriptor ¶
func (*StartRequest) Descriptor() ([]byte, []int)
func (*StartRequest) ProtoMessage ¶
func (*StartRequest) ProtoMessage()
func (*StartRequest) Reset ¶
func (m *StartRequest) Reset()
func (*StartRequest) String ¶
func (m *StartRequest) String() string
type StartResponse ¶
type StartResponse struct { }
func (*StartResponse) Descriptor ¶
func (*StartResponse) Descriptor() ([]byte, []int)
func (*StartResponse) ProtoMessage ¶
func (*StartResponse) ProtoMessage()
func (*StartResponse) Reset ¶
func (m *StartResponse) Reset()
func (*StartResponse) String ¶
func (m *StartResponse) String() string
type StopRequest ¶
type StopRequest struct { }
func (*StopRequest) Descriptor ¶
func (*StopRequest) Descriptor() ([]byte, []int)
func (*StopRequest) ProtoMessage ¶
func (*StopRequest) ProtoMessage()
func (*StopRequest) Reset ¶
func (m *StopRequest) Reset()
func (*StopRequest) String ¶
func (m *StopRequest) String() string
type StopResponse ¶
type StopResponse struct { }
func (*StopResponse) Descriptor ¶
func (*StopResponse) Descriptor() ([]byte, []int)
func (*StopResponse) ProtoMessage ¶
func (*StopResponse) ProtoMessage()
func (*StopResponse) Reset ¶
func (m *StopResponse) Reset()
func (*StopResponse) String ¶
func (m *StopResponse) String() string
type TeardownRequest ¶
type TeardownRequest struct { }
func (*TeardownRequest) Descriptor ¶
func (*TeardownRequest) Descriptor() ([]byte, []int)
func (*TeardownRequest) ProtoMessage ¶
func (*TeardownRequest) ProtoMessage()
func (*TeardownRequest) Reset ¶
func (m *TeardownRequest) Reset()
func (*TeardownRequest) String ¶
func (m *TeardownRequest) String() string
type TeardownResponse ¶
type TeardownResponse struct { }
func (*TeardownResponse) Descriptor ¶
func (*TeardownResponse) Descriptor() ([]byte, []int)
func (*TeardownResponse) ProtoMessage ¶
func (*TeardownResponse) ProtoMessage()
func (*TeardownResponse) Reset ¶
func (m *TeardownResponse) Reset()
func (*TeardownResponse) String ¶
func (m *TeardownResponse) String() string