m3em

package
v0.15.13 Latest Latest
Warning

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

 Go to latest Published: Aug 31, 2020 License: Apache-2.0 Imports: 10 Imported by: 8

Documentation

Overview

Package m3em is a generated GoMock package. 

Package m3em is a generated protocol buffer package.

It is generated from these files:
	github.com/m3db/m3/src/m3em/generated/proto/m3em/operator.proto

It has these top-level messages:
	SetupRequest
	SetupResponse
	StartRequest
	StartResponse
	StopRequest
	StopResponse
	TeardownRequest
	TeardownResponse
	PullFileRequest
	PullFileResponse
	PushFileRequest
	PushFileResponse
	DataChunk

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthOperator = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowOperator   = fmt.Errorf("proto: integer overflow")
)
View Source 
var PullFileContentType_name = map[int32]string{
	0: "PULL_FILE_CONTENT_TYPE_UNKNOWN",
	1: "PULL_FILE_CONTENT_TYPE_LAST",
	2: "PULL_FILE_CONTENT_TYPE_FULL",
}
View Source 
var PullFileContentType_value = map[string]int32{
	"PULL_FILE_CONTENT_TYPE_UNKNOWN": 0,
	"PULL_FILE_CONTENT_TYPE_LAST":    1,
	"PULL_FILE_CONTENT_TYPE_FULL":    2,
}
View Source 
var PullFileType_name = map[int32]string{
	0: "PULL_FILE_TYPE_UNKNOWN",
	1: "PULL_FILE_TYPE_SERVICE_STDOUT",
	2: "PULL_FILE_TYPE_SERVICE_STDERR",
}
View Source 
var PullFileType_value = map[string]int32{
	"PULL_FILE_TYPE_UNKNOWN":        0,
	"PULL_FILE_TYPE_SERVICE_STDOUT": 1,
	"PULL_FILE_TYPE_SERVICE_STDERR": 2,
}
View Source 
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",
}
View Source 
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,proto3" json:"idx,omitempty"`
	Bytes []byte `protobuf:"bytes,2,opt,name=bytes,proto3" json:"bytes,omitempty"`
}

func (*DataChunk) Descriptor 

func (*DataChunk) Descriptor() ([]byte, []int)

func (*DataChunk) GetBytes 

func (m *DataChunk) GetBytes() []byte

func (*DataChunk) GetIdx 

func (m *DataChunk) GetIdx() int32

func (*DataChunk) Marshal 

func (m *DataChunk) Marshal() (dAtA []byte, err error)

func (*DataChunk) MarshalTo 

func (m *DataChunk) MarshalTo(dAtA []byte) (int, error)

func (*DataChunk) ProtoMessage 

func (*DataChunk) ProtoMessage()

func (*DataChunk) Reset 

func (m *DataChunk) Reset()

func (*DataChunk) Size 

func (m *DataChunk) Size() (n int)

func (*DataChunk) String 

func (m *DataChunk) String() string

func (*DataChunk) Unmarshal 

func (m *DataChunk) Unmarshal(dAtA []byte) error

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(arg0 context.Context, arg1 *PullFileRequest, arg2 ...grpc.CallOption) (Operator_PullFileClient, error)

PullFile mocks base method

func (*MockOperatorClient) PushFile 

func (m *MockOperatorClient) PushFile(arg0 context.Context, arg1 ...grpc.CallOption) (Operator_PushFileClient, error)

PushFile mocks base method

func (*MockOperatorClient) Setup 

func (m *MockOperatorClient) Setup(arg0 context.Context, arg1 *SetupRequest, arg2 ...grpc.CallOption) (*SetupResponse, error)

Setup mocks base method

func (*MockOperatorClient) Start 

func (m *MockOperatorClient) Start(arg0 context.Context, arg1 *StartRequest, arg2 ...grpc.CallOption) (*StartResponse, error)

Start mocks base method

func (*MockOperatorClient) Stop 

func (m *MockOperatorClient) Stop(arg0 context.Context, arg1 *StopRequest, arg2 ...grpc.CallOption) (*StopResponse, error)

Stop mocks base method

func (*MockOperatorClient) Teardown 

func (m *MockOperatorClient) Teardown(arg0 context.Context, arg1 *TeardownRequest, arg2 ...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(arg0 interface{}) error

RecvMsg mocks base method

func (*MockOperator_PullFileClient) SendMsg 

func (m *MockOperator_PullFileClient) SendMsg(arg0 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(arg0 interface{}) error

RecvMsg mocks base method

func (*MockOperator_PullFileServer) Send 

func (m *MockOperator_PullFileServer) Send(arg0 *PullFileResponse) error

Send mocks base method

func (*MockOperator_PullFileServer) SendHeader 

func (m *MockOperator_PullFileServer) SendHeader(arg0 metadata.MD) error

SendHeader mocks base method

func (*MockOperator_PullFileServer) SendMsg 

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

SendMsg mocks base method

func (*MockOperator_PullFileServer) SetHeader 

func (m *MockOperator_PullFileServer) SetHeader(arg0 metadata.MD) error

SetHeader mocks base method

func (*MockOperator_PullFileServer) SetTrailer 

func (m *MockOperator_PullFileServer) SetTrailer(arg0 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(arg0 interface{}) error

RecvMsg mocks base method

func (*MockOperator_PushFileClient) Send 

func (m *MockOperator_PushFileClient) Send(arg0 *PushFileRequest) error

Send mocks base method

func (*MockOperator_PushFileClient) SendMsg 

func (m *MockOperator_PushFileClient) SendMsg(arg0 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,proto3,enum=m3em.PullFileType" json:"file_type,omitempty"`
	ChunkSize int64        `protobuf:"varint,2,opt,name=chunk_size,json=chunkSize,proto3" json:"chunk_size,omitempty"`
	MaxSize   int64        `protobuf:"varint,3,opt,name=max_size,json=maxSize,proto3" 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) Marshal 

func (m *PullFileRequest) Marshal() (dAtA []byte, err error)

func (*PullFileRequest) MarshalTo 

func (m *PullFileRequest) MarshalTo(dAtA []byte) (int, error)

func (*PullFileRequest) ProtoMessage 

func (*PullFileRequest) ProtoMessage()

func (*PullFileRequest) Reset 

func (m *PullFileRequest) Reset()

func (*PullFileRequest) Size 

func (m *PullFileRequest) Size() (n int)

func (*PullFileRequest) String 

func (m *PullFileRequest) String() string

func (*PullFileRequest) Unmarshal 

func (m *PullFileRequest) Unmarshal(dAtA []byte) error

type PullFileResponse 

type PullFileResponse struct {
	Data      *DataChunk `protobuf:"bytes,1,opt,name=data" json:"data,omitempty"`
	Truncated bool       `protobuf:"varint,2,opt,name=truncated,proto3" 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) Marshal 

func (m *PullFileResponse) Marshal() (dAtA []byte, err error)

func (*PullFileResponse) MarshalTo 

func (m *PullFileResponse) MarshalTo(dAtA []byte) (int, error)

func (*PullFileResponse) ProtoMessage 

func (*PullFileResponse) ProtoMessage()

func (*PullFileResponse) Reset 

func (m *PullFileResponse) Reset()

func (*PullFileResponse) Size 

func (m *PullFileResponse) Size() (n int)

func (*PullFileResponse) String 

func (m *PullFileResponse) String() string

func (*PullFileResponse) Unmarshal 

func (m *PullFileResponse) Unmarshal(dAtA []byte) error

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,proto3,enum=m3em.PushFileType" json:"type,omitempty"`
	Overwrite   bool         `protobuf:"varint,2,opt,name=overwrite,proto3" 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) Marshal 

func (m *PushFileRequest) Marshal() (dAtA []byte, err error)

func (*PushFileRequest) MarshalTo 

func (m *PushFileRequest) MarshalTo(dAtA []byte) (int, error)

func (*PushFileRequest) ProtoMessage 

func (*PushFileRequest) ProtoMessage()

func (*PushFileRequest) Reset 

func (m *PushFileRequest) Reset()

func (*PushFileRequest) Size 

func (m *PushFileRequest) Size() (n int)

func (*PushFileRequest) String 

func (m *PushFileRequest) String() string

func (*PushFileRequest) Unmarshal 

func (m *PushFileRequest) Unmarshal(dAtA []byte) error

type PushFileResponse 

type PushFileResponse struct {
	FileChecksum   uint32 `protobuf:"varint,1,opt,name=file_checksum,json=fileChecksum,proto3" json:"file_checksum,omitempty"`
	NumChunksRecvd int32  `protobuf:"varint,2,opt,name=num_chunks_recvd,json=numChunksRecvd,proto3" 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) Marshal 

func (m *PushFileResponse) Marshal() (dAtA []byte, err error)

func (*PushFileResponse) MarshalTo 

func (m *PushFileResponse) MarshalTo(dAtA []byte) (int, error)

func (*PushFileResponse) ProtoMessage 

func (*PushFileResponse) ProtoMessage()

func (*PushFileResponse) Reset 

func (m *PushFileResponse) Reset()

func (*PushFileResponse) Size 

func (m *PushFileResponse) Size() (n int)

func (*PushFileResponse) String 

func (m *PushFileResponse) String() string

func (*PushFileResponse) Unmarshal 

func (m *PushFileResponse) Unmarshal(dAtA []byte) error

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,proto3" json:"session_token,omitempty"`
	OperatorUuid           string `protobuf:"bytes,2,opt,name=operator_uuid,json=operatorUuid,proto3" json:"operator_uuid,omitempty"`
	Force                  bool   `protobuf:"varint,3,opt,name=force,proto3" json:"force,omitempty"`
	HeartbeatEnabled       bool   `protobuf:"varint,4,opt,name=heartbeat_enabled,json=heartbeatEnabled,proto3" json:"heartbeat_enabled,omitempty"`
	HeartbeatEndpoint      string `protobuf:"bytes,5,opt,name=heartbeat_endpoint,json=heartbeatEndpoint,proto3" json:"heartbeat_endpoint,omitempty"`
	HeartbeatFrequencySecs uint32 `` /* 130-byte string literal not displayed */
}

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) Marshal 

func (m *SetupRequest) Marshal() (dAtA []byte, err error)

func (*SetupRequest) MarshalTo 

func (m *SetupRequest) MarshalTo(dAtA []byte) (int, error)

func (*SetupRequest) ProtoMessage 

func (*SetupRequest) ProtoMessage()

func (*SetupRequest) Reset 

func (m *SetupRequest) Reset()

func (*SetupRequest) Size 

func (m *SetupRequest) Size() (n int)

func (*SetupRequest) String 

func (m *SetupRequest) String() string

func (*SetupRequest) Unmarshal 

func (m *SetupRequest) Unmarshal(dAtA []byte) error

type SetupResponse 

type SetupResponse struct {
}

func (*SetupResponse) Descriptor 

func (*SetupResponse) Descriptor() ([]byte, []int)

func (*SetupResponse) Marshal 

func (m *SetupResponse) Marshal() (dAtA []byte, err error)

func (*SetupResponse) MarshalTo 

func (m *SetupResponse) MarshalTo(dAtA []byte) (int, error)

func (*SetupResponse) ProtoMessage 

func (*SetupResponse) ProtoMessage()

func (*SetupResponse) Reset 

func (m *SetupResponse) Reset()

func (*SetupResponse) Size 

func (m *SetupResponse) Size() (n int)

func (*SetupResponse) String 

func (m *SetupResponse) String() string

func (*SetupResponse) Unmarshal 

func (m *SetupResponse) Unmarshal(dAtA []byte) error

type StartRequest 

type StartRequest struct {
}

func (*StartRequest) Descriptor 

func (*StartRequest) Descriptor() ([]byte, []int)

func (*StartRequest) Marshal 

func (m *StartRequest) Marshal() (dAtA []byte, err error)

func (*StartRequest) MarshalTo 

func (m *StartRequest) MarshalTo(dAtA []byte) (int, error)

func (*StartRequest) ProtoMessage 

func (*StartRequest) ProtoMessage()

func (*StartRequest) Reset 

func (m *StartRequest) Reset()

func (*StartRequest) Size 

func (m *StartRequest) Size() (n int)

func (*StartRequest) String 

func (m *StartRequest) String() string

func (*StartRequest) Unmarshal 

func (m *StartRequest) Unmarshal(dAtA []byte) error

type StartResponse 

type StartResponse struct {
}

func (*StartResponse) Descriptor 

func (*StartResponse) Descriptor() ([]byte, []int)

func (*StartResponse) Marshal 

func (m *StartResponse) Marshal() (dAtA []byte, err error)

func (*StartResponse) MarshalTo 

func (m *StartResponse) MarshalTo(dAtA []byte) (int, error)

func (*StartResponse) ProtoMessage 

func (*StartResponse) ProtoMessage()

func (*StartResponse) Reset 

func (m *StartResponse) Reset()

func (*StartResponse) Size 

func (m *StartResponse) Size() (n int)

func (*StartResponse) String 

func (m *StartResponse) String() string

func (*StartResponse) Unmarshal 

func (m *StartResponse) Unmarshal(dAtA []byte) error

type StopRequest 

type StopRequest struct {
}

func (*StopRequest) Descriptor 

func (*StopRequest) Descriptor() ([]byte, []int)

func (*StopRequest) Marshal 

func (m *StopRequest) Marshal() (dAtA []byte, err error)

func (*StopRequest) MarshalTo 

func (m *StopRequest) MarshalTo(dAtA []byte) (int, error)

func (*StopRequest) ProtoMessage 

func (*StopRequest) ProtoMessage()

func (*StopRequest) Reset 

func (m *StopRequest) Reset()

func (*StopRequest) Size 

func (m *StopRequest) Size() (n int)

func (*StopRequest) String 

func (m *StopRequest) String() string

func (*StopRequest) Unmarshal 

func (m *StopRequest) Unmarshal(dAtA []byte) error

type StopResponse 

type StopResponse struct {
}

func (*StopResponse) Descriptor 

func (*StopResponse) Descriptor() ([]byte, []int)

func (*StopResponse) Marshal 

func (m *StopResponse) Marshal() (dAtA []byte, err error)

func (*StopResponse) MarshalTo 

func (m *StopResponse) MarshalTo(dAtA []byte) (int, error)

func (*StopResponse) ProtoMessage 

func (*StopResponse) ProtoMessage()

func (*StopResponse) Reset 

func (m *StopResponse) Reset()

func (*StopResponse) Size 

func (m *StopResponse) Size() (n int)

func (*StopResponse) String 

func (m *StopResponse) String() string

func (*StopResponse) Unmarshal 

func (m *StopResponse) Unmarshal(dAtA []byte) error

type TeardownRequest 

type TeardownRequest struct {
}

func (*TeardownRequest) Descriptor 

func (*TeardownRequest) Descriptor() ([]byte, []int)

func (*TeardownRequest) Marshal 

func (m *TeardownRequest) Marshal() (dAtA []byte, err error)

func (*TeardownRequest) MarshalTo 

func (m *TeardownRequest) MarshalTo(dAtA []byte) (int, error)

func (*TeardownRequest) ProtoMessage 

func (*TeardownRequest) ProtoMessage()

func (*TeardownRequest) Reset 

func (m *TeardownRequest) Reset()

func (*TeardownRequest) Size 

func (m *TeardownRequest) Size() (n int)

func (*TeardownRequest) String 

func (m *TeardownRequest) String() string

func (*TeardownRequest) Unmarshal 

func (m *TeardownRequest) Unmarshal(dAtA []byte) error

type TeardownResponse 

type TeardownResponse struct {
}

func (*TeardownResponse) Descriptor 

func (*TeardownResponse) Descriptor() ([]byte, []int)

func (*TeardownResponse) Marshal 

func (m *TeardownResponse) Marshal() (dAtA []byte, err error)

func (*TeardownResponse) MarshalTo 

func (m *TeardownResponse) MarshalTo(dAtA []byte) (int, error)

func (*TeardownResponse) ProtoMessage 

func (*TeardownResponse) ProtoMessage()

func (*TeardownResponse) Reset 

func (m *TeardownResponse) Reset()

func (*TeardownResponse) Size 

func (m *TeardownResponse) Size() (n int)

func (*TeardownResponse) String 

func (m *TeardownResponse) String() string

func (*TeardownResponse) Unmarshal 

func (m *TeardownResponse) Unmarshal(dAtA []byte) error

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.