proto

package
v0.2.0 Latest Latest
Warning

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

 Go to latest Published: Jun 27, 2022 License: Apache-2.0 Imports: 11 Imported by: 6

Documentation

Index

Constants

View Source 
const (
	S3Prefix    = "s3://"
	LocalPrefix = "local://"
	HdfsPrefix  = "hdfs://"
)

Variables

View Source 
var (
	ErrInvalidLengthAgent        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowAgent          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupAgent = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthStorage        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowStorage          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupStorage = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var ServiceRole_name = map[int32]string{
	0: "UNKNOWN_ROLE",
	1: "META",
	2: "GRAPH",
	3: "STORAGE",
}
View Source 
var ServiceRole_value = map[string]int32{
	"UNKNOWN_ROLE": 0,
	"META":         1,
	"GRAPH":        2,
	"STORAGE":      3,
}
View Source 
var Status_name = map[int32]string{
	0: "UNKNOWN_STATUS",
	1: "RUNNING",
	2: "EXITED",
}
View Source 
var Status_value = map[string]int32{
	"UNKNOWN_STATUS": 0,
	"RUNNING":        1,
	"EXITED":         2,
}

Functions

func RegisterAgentServiceServer 

func RegisterAgentServiceServer(s *grpc.Server, srv AgentServiceServer)

func RegisterStorageServiceServer 

func RegisterStorageServiceServer(s *grpc.Server, srv StorageServiceServer)

Types

type AgentServiceClient 

type AgentServiceClient interface {
	StartService(ctx context.Context, in *StartServiceRequest, opts ...grpc.CallOption) (*StartServiceResponse, error)
	StopService(ctx context.Context, in *StopServiceRequest, opts ...grpc.CallOption) (*StopServiceResponse, error)
	ServiceStatus(ctx context.Context, in *ServiceStatusRequest, opts ...grpc.CallOption) (*ServiceStatusResponse, error)
	BanReadWrite(ctx context.Context, in *BanReadWriteRequest, opts ...grpc.CallOption) (*BanReadWriteResponse, error)
	AllowReadWrite(ctx context.Context, in *AllowReadWriteRequest, opts ...grpc.CallOption) (*AllowReadWriteResponse, error)
	DataPlayBack(ctx context.Context, in *DataPlayBackRequest, opts ...grpc.CallOption) (*DataPlayBackResponse, error)
}

AgentServiceClient is the client API for AgentService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewAgentServiceClient 

func NewAgentServiceClient(cc *grpc.ClientConn) AgentServiceClient

type AgentServiceServer 

type AgentServiceServer interface {
	StartService(context.Context, *StartServiceRequest) (*StartServiceResponse, error)
	StopService(context.Context, *StopServiceRequest) (*StopServiceResponse, error)
	ServiceStatus(context.Context, *ServiceStatusRequest) (*ServiceStatusResponse, error)
	BanReadWrite(context.Context, *BanReadWriteRequest) (*BanReadWriteResponse, error)
	AllowReadWrite(context.Context, *AllowReadWriteRequest) (*AllowReadWriteResponse, error)
	DataPlayBack(context.Context, *DataPlayBackRequest) (*DataPlayBackResponse, error)
}

AgentServiceServer is the server API for AgentService service.

type AllowReadWriteRequest 

type AllowReadWriteRequest struct {
	Role                 ServiceRole `protobuf:"varint,1,opt,name=role,proto3,enum=proto.ServiceRole" json:"role,omitempty"`
	Addr                 string      `protobuf:"bytes,2,opt,name=addr,proto3" json:"addr,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*AllowReadWriteRequest) Descriptor 

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

func (*AllowReadWriteRequest) GetAddr 

func (m *AllowReadWriteRequest) GetAddr() string

func (*AllowReadWriteRequest) GetRole 

func (m *AllowReadWriteRequest) GetRole() ServiceRole

func (*AllowReadWriteRequest) Marshal 

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

func (*AllowReadWriteRequest) MarshalTo 

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

func (*AllowReadWriteRequest) MarshalToSizedBuffer 

func (m *AllowReadWriteRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AllowReadWriteRequest) ProtoMessage 

func (*AllowReadWriteRequest) ProtoMessage()

func (*AllowReadWriteRequest) Reset 

func (m *AllowReadWriteRequest) Reset()

func (*AllowReadWriteRequest) Size 

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

func (*AllowReadWriteRequest) String 

func (m *AllowReadWriteRequest) String() string

func (*AllowReadWriteRequest) Unmarshal 

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

func (*AllowReadWriteRequest) XXX_DiscardUnknown 

func (m *AllowReadWriteRequest) XXX_DiscardUnknown()

func (*AllowReadWriteRequest) XXX_Marshal 

func (m *AllowReadWriteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AllowReadWriteRequest) XXX_Merge 

func (m *AllowReadWriteRequest) XXX_Merge(src proto.Message)

func (*AllowReadWriteRequest) XXX_Size 

func (m *AllowReadWriteRequest) XXX_Size() int

func (*AllowReadWriteRequest) XXX_Unmarshal 

func (m *AllowReadWriteRequest) XXX_Unmarshal(b []byte) error

type AllowReadWriteResponse 

type AllowReadWriteResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AllowReadWriteResponse) Descriptor 

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

func (*AllowReadWriteResponse) Marshal 

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

func (*AllowReadWriteResponse) MarshalTo 

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

func (*AllowReadWriteResponse) MarshalToSizedBuffer 

func (m *AllowReadWriteResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AllowReadWriteResponse) ProtoMessage 

func (*AllowReadWriteResponse) ProtoMessage()

func (*AllowReadWriteResponse) Reset 

func (m *AllowReadWriteResponse) Reset()

func (*AllowReadWriteResponse) Size 

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

func (*AllowReadWriteResponse) String 

func (m *AllowReadWriteResponse) String() string

func (*AllowReadWriteResponse) Unmarshal 

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

func (*AllowReadWriteResponse) XXX_DiscardUnknown 

func (m *AllowReadWriteResponse) XXX_DiscardUnknown()

func (*AllowReadWriteResponse) XXX_Marshal 

func (m *AllowReadWriteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AllowReadWriteResponse) XXX_Merge 

func (m *AllowReadWriteResponse) XXX_Merge(src proto.Message)

func (*AllowReadWriteResponse) XXX_Size 

func (m *AllowReadWriteResponse) XXX_Size() int

func (*AllowReadWriteResponse) XXX_Unmarshal 

func (m *AllowReadWriteResponse) XXX_Unmarshal(b []byte) error

type Backend 

type Backend struct {
	// Types that are valid to be assigned to Storage:
	//	*Backend_Local
	//	*Backend_S3
	//	*Backend_Hdfs
	Storage              isBackend_Storage `protobuf_oneof:"storage"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*Backend) DeepCopy 

func (b *Backend) DeepCopy() *Backend

func (*Backend) Descriptor 

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

func (*Backend) GetHdfs 

func (m *Backend) GetHdfs() *HDFS

func (*Backend) GetLocal 

func (m *Backend) GetLocal() *Local

func (*Backend) GetS3 

func (m *Backend) GetS3() *S3

func (*Backend) GetStorage 

func (m *Backend) GetStorage() isBackend_Storage

func (*Backend) Marshal 

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

func (*Backend) MarshalTo 

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

func (*Backend) MarshalToSizedBuffer 

func (m *Backend) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Backend) ProtoMessage 

func (*Backend) ProtoMessage()

func (*Backend) Reset 

func (m *Backend) Reset()

func (*Backend) SetUri 

func (b *Backend) SetUri(uri string) error

func (*Backend) Size 

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

func (*Backend) String 

func (m *Backend) String() string

func (*Backend) Type 

func (b *Backend) Type() BackendType

func (*Backend) Unmarshal 

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

func (*Backend) Uri 

func (b *Backend) Uri() string

func (*Backend) XXX_DiscardUnknown 

func (m *Backend) XXX_DiscardUnknown()

func (*Backend) XXX_Marshal 

func (m *Backend) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Backend) XXX_Merge 

func (m *Backend) XXX_Merge(src proto.Message)

func (*Backend) XXX_OneofWrappers 

func (*Backend) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*Backend) XXX_Size 

func (m *Backend) XXX_Size() int

func (*Backend) XXX_Unmarshal 

func (m *Backend) XXX_Unmarshal(b []byte) error

type BackendType 

type BackendType int
const (
	InvalidType BackendType = iota
	LocalType
	HdfsType
	S3Type
)

func ParseType 

func ParseType(uri string) BackendType

func (BackendType) String added in v0.1.0 

func (t BackendType) String() string

type Backend_Hdfs 

type Backend_Hdfs struct {
	Hdfs *HDFS `protobuf:"bytes,3,opt,name=hdfs,proto3,oneof" json:"hdfs,omitempty"`
}

func (*Backend_Hdfs) MarshalTo 

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

func (*Backend_Hdfs) MarshalToSizedBuffer 

func (m *Backend_Hdfs) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Backend_Hdfs) Size 

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

type Backend_Local 

type Backend_Local struct {
	Local *Local `protobuf:"bytes,1,opt,name=local,proto3,oneof" json:"local,omitempty"`
}

func (*Backend_Local) MarshalTo 

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

func (*Backend_Local) MarshalToSizedBuffer 

func (m *Backend_Local) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Backend_Local) Size 

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

type Backend_S3 

type Backend_S3 struct {
	S3 *S3 `protobuf:"bytes,2,opt,name=s3,proto3,oneof" json:"s3,omitempty"`
}

func (*Backend_S3) MarshalTo 

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

func (*Backend_S3) MarshalToSizedBuffer 

func (m *Backend_S3) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Backend_S3) Size 

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

type BanReadWriteRequest 

type BanReadWriteRequest struct {
	Role                 ServiceRole `protobuf:"varint,1,opt,name=role,proto3,enum=proto.ServiceRole" json:"role,omitempty"`
	Addr                 string      `protobuf:"bytes,2,opt,name=addr,proto3" json:"addr,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*BanReadWriteRequest) Descriptor 

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

func (*BanReadWriteRequest) GetAddr 

func (m *BanReadWriteRequest) GetAddr() string

func (*BanReadWriteRequest) GetRole 

func (m *BanReadWriteRequest) GetRole() ServiceRole

func (*BanReadWriteRequest) Marshal 

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

func (*BanReadWriteRequest) MarshalTo 

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

func (*BanReadWriteRequest) MarshalToSizedBuffer 

func (m *BanReadWriteRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*BanReadWriteRequest) ProtoMessage 

func (*BanReadWriteRequest) ProtoMessage()

func (*BanReadWriteRequest) Reset 

func (m *BanReadWriteRequest) Reset()

func (*BanReadWriteRequest) Size 

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

func (*BanReadWriteRequest) String 

func (m *BanReadWriteRequest) String() string

func (*BanReadWriteRequest) Unmarshal 

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

func (*BanReadWriteRequest) XXX_DiscardUnknown 

func (m *BanReadWriteRequest) XXX_DiscardUnknown()

func (*BanReadWriteRequest) XXX_Marshal 

func (m *BanReadWriteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BanReadWriteRequest) XXX_Merge 

func (m *BanReadWriteRequest) XXX_Merge(src proto.Message)

func (*BanReadWriteRequest) XXX_Size 

func (m *BanReadWriteRequest) XXX_Size() int

func (*BanReadWriteRequest) XXX_Unmarshal 

func (m *BanReadWriteRequest) XXX_Unmarshal(b []byte) error

type BanReadWriteResponse 

type BanReadWriteResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*BanReadWriteResponse) Descriptor 

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

func (*BanReadWriteResponse) Marshal 

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

func (*BanReadWriteResponse) MarshalTo 

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

func (*BanReadWriteResponse) MarshalToSizedBuffer 

func (m *BanReadWriteResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*BanReadWriteResponse) ProtoMessage 

func (*BanReadWriteResponse) ProtoMessage()

func (*BanReadWriteResponse) Reset 

func (m *BanReadWriteResponse) Reset()

func (*BanReadWriteResponse) Size 

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

func (*BanReadWriteResponse) String 

func (m *BanReadWriteResponse) String() string

func (*BanReadWriteResponse) Unmarshal 

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

func (*BanReadWriteResponse) XXX_DiscardUnknown 

func (m *BanReadWriteResponse) XXX_DiscardUnknown()

func (*BanReadWriteResponse) XXX_Marshal 

func (m *BanReadWriteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BanReadWriteResponse) XXX_Merge 

func (m *BanReadWriteResponse) XXX_Merge(src proto.Message)

func (*BanReadWriteResponse) XXX_Size 

func (m *BanReadWriteResponse) XXX_Size() int

func (*BanReadWriteResponse) XXX_Unmarshal 

func (m *BanReadWriteResponse) XXX_Unmarshal(b []byte) error

type DataPlayBackRequest added in v0.2.0 

type DataPlayBackRequest struct {
	Dir                  string   `protobuf:"bytes,1,opt,name=dir,proto3" json:"dir,omitempty"`
	DataPath             string   `protobuf:"bytes,2,opt,name=data_path,json=dataPath,proto3" json:"data_path,omitempty"`
	MetaAddr             string   `protobuf:"bytes,3,opt,name=meta_addr,json=metaAddr,proto3" json:"meta_addr,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DataPlayBackRequest) Descriptor added in v0.2.0 

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

func (*DataPlayBackRequest) GetDataPath added in v0.2.0 

func (m *DataPlayBackRequest) GetDataPath() string

func (*DataPlayBackRequest) GetDir added in v0.2.0 

func (m *DataPlayBackRequest) GetDir() string

func (*DataPlayBackRequest) GetMetaAddr added in v0.2.0 

func (m *DataPlayBackRequest) GetMetaAddr() string

func (*DataPlayBackRequest) Marshal added in v0.2.0 

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

func (*DataPlayBackRequest) MarshalTo added in v0.2.0 

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

func (*DataPlayBackRequest) MarshalToSizedBuffer added in v0.2.0 

func (m *DataPlayBackRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DataPlayBackRequest) ProtoMessage added in v0.2.0 

func (*DataPlayBackRequest) ProtoMessage()

func (*DataPlayBackRequest) Reset added in v0.2.0 

func (m *DataPlayBackRequest) Reset()

func (*DataPlayBackRequest) Size added in v0.2.0 

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

func (*DataPlayBackRequest) String added in v0.2.0 

func (m *DataPlayBackRequest) String() string

func (*DataPlayBackRequest) Unmarshal added in v0.2.0 

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

func (*DataPlayBackRequest) XXX_DiscardUnknown added in v0.2.0 

func (m *DataPlayBackRequest) XXX_DiscardUnknown()

func (*DataPlayBackRequest) XXX_Marshal added in v0.2.0 

func (m *DataPlayBackRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DataPlayBackRequest) XXX_Merge added in v0.2.0 

func (m *DataPlayBackRequest) XXX_Merge(src proto.Message)

func (*DataPlayBackRequest) XXX_Size added in v0.2.0 

func (m *DataPlayBackRequest) XXX_Size() int

func (*DataPlayBackRequest) XXX_Unmarshal added in v0.2.0 

func (m *DataPlayBackRequest) XXX_Unmarshal(b []byte) error

type DataPlayBackResponse added in v0.2.0 

type DataPlayBackResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DataPlayBackResponse) Descriptor added in v0.2.0 

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

func (*DataPlayBackResponse) Marshal added in v0.2.0 

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

func (*DataPlayBackResponse) MarshalTo added in v0.2.0 

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

func (*DataPlayBackResponse) MarshalToSizedBuffer added in v0.2.0 

func (m *DataPlayBackResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DataPlayBackResponse) ProtoMessage added in v0.2.0 

func (*DataPlayBackResponse) ProtoMessage()

func (*DataPlayBackResponse) Reset added in v0.2.0 

func (m *DataPlayBackResponse) Reset()

func (*DataPlayBackResponse) Size added in v0.2.0 

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

func (*DataPlayBackResponse) String added in v0.2.0 

func (m *DataPlayBackResponse) String() string

func (*DataPlayBackResponse) Unmarshal added in v0.2.0 

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

func (*DataPlayBackResponse) XXX_DiscardUnknown added in v0.2.0 

func (m *DataPlayBackResponse) XXX_DiscardUnknown()

func (*DataPlayBackResponse) XXX_Marshal added in v0.2.0 

func (m *DataPlayBackResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DataPlayBackResponse) XXX_Merge added in v0.2.0 

func (m *DataPlayBackResponse) XXX_Merge(src proto.Message)

func (*DataPlayBackResponse) XXX_Size added in v0.2.0 

func (m *DataPlayBackResponse) XXX_Size() int

func (*DataPlayBackResponse) XXX_Unmarshal added in v0.2.0 

func (m *DataPlayBackResponse) XXX_Unmarshal(b []byte) error

type DownloadFileRequest 

type DownloadFileRequest struct {
	SessionId            string   `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	Recursively          bool     `protobuf:"varint,2,opt,name=recursively,proto3" json:"recursively,omitempty"`
	SourceBackend        *Backend `protobuf:"bytes,3,opt,name=source_backend,json=sourceBackend,proto3" json:"source_backend,omitempty"`
	TargetPath           string   `protobuf:"bytes,4,opt,name=target_path,json=targetPath,proto3" json:"target_path,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DownloadFileRequest) Descriptor 

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

func (*DownloadFileRequest) GetRecursively 

func (m *DownloadFileRequest) GetRecursively() bool

func (*DownloadFileRequest) GetSessionId 

func (m *DownloadFileRequest) GetSessionId() string

func (*DownloadFileRequest) GetSourceBackend 

func (m *DownloadFileRequest) GetSourceBackend() *Backend

func (*DownloadFileRequest) GetTargetPath 

func (m *DownloadFileRequest) GetTargetPath() string

func (*DownloadFileRequest) Marshal 

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

func (*DownloadFileRequest) MarshalTo 

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

func (*DownloadFileRequest) MarshalToSizedBuffer 

func (m *DownloadFileRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DownloadFileRequest) ProtoMessage 

func (*DownloadFileRequest) ProtoMessage()

func (*DownloadFileRequest) Reset 

func (m *DownloadFileRequest) Reset()

func (*DownloadFileRequest) Size 

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

func (*DownloadFileRequest) String 

func (m *DownloadFileRequest) String() string

func (*DownloadFileRequest) Unmarshal 

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

func (*DownloadFileRequest) XXX_DiscardUnknown 

func (m *DownloadFileRequest) XXX_DiscardUnknown()

func (*DownloadFileRequest) XXX_Marshal 

func (m *DownloadFileRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DownloadFileRequest) XXX_Merge 

func (m *DownloadFileRequest) XXX_Merge(src proto.Message)

func (*DownloadFileRequest) XXX_Size 

func (m *DownloadFileRequest) XXX_Size() int

func (*DownloadFileRequest) XXX_Unmarshal 

func (m *DownloadFileRequest) XXX_Unmarshal(b []byte) error

type DownloadFileResponse 

type DownloadFileResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DownloadFileResponse) Descriptor 

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

func (*DownloadFileResponse) Marshal 

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

func (*DownloadFileResponse) MarshalTo 

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

func (*DownloadFileResponse) MarshalToSizedBuffer 

func (m *DownloadFileResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DownloadFileResponse) ProtoMessage 

func (*DownloadFileResponse) ProtoMessage()

func (*DownloadFileResponse) Reset 

func (m *DownloadFileResponse) Reset()

func (*DownloadFileResponse) Size 

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

func (*DownloadFileResponse) String 

func (m *DownloadFileResponse) String() string

func (*DownloadFileResponse) Unmarshal 

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

func (*DownloadFileResponse) XXX_DiscardUnknown 

func (m *DownloadFileResponse) XXX_DiscardUnknown()

func (*DownloadFileResponse) XXX_Marshal 

func (m *DownloadFileResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DownloadFileResponse) XXX_Merge 

func (m *DownloadFileResponse) XXX_Merge(src proto.Message)

func (*DownloadFileResponse) XXX_Size 

func (m *DownloadFileResponse) XXX_Size() int

func (*DownloadFileResponse) XXX_Unmarshal 

func (m *DownloadFileResponse) XXX_Unmarshal(b []byte) error

type ExistDirRequest added in v0.1.1 

type ExistDirRequest struct {
	Path                 string   `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ExistDirRequest) Descriptor added in v0.1.1 

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

func (*ExistDirRequest) GetPath added in v0.1.1 

func (m *ExistDirRequest) GetPath() string

func (*ExistDirRequest) Marshal added in v0.1.1 

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

func (*ExistDirRequest) MarshalTo added in v0.1.1 

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

func (*ExistDirRequest) MarshalToSizedBuffer added in v0.1.1 

func (m *ExistDirRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ExistDirRequest) ProtoMessage added in v0.1.1 

func (*ExistDirRequest) ProtoMessage()

func (*ExistDirRequest) Reset added in v0.1.1 

func (m *ExistDirRequest) Reset()

func (*ExistDirRequest) Size added in v0.1.1 

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

func (*ExistDirRequest) String added in v0.1.1 

func (m *ExistDirRequest) String() string

func (*ExistDirRequest) Unmarshal added in v0.1.1 

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

func (*ExistDirRequest) XXX_DiscardUnknown added in v0.1.1 

func (m *ExistDirRequest) XXX_DiscardUnknown()

func (*ExistDirRequest) XXX_Marshal added in v0.1.1 

func (m *ExistDirRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExistDirRequest) XXX_Merge added in v0.1.1 

func (m *ExistDirRequest) XXX_Merge(src proto.Message)

func (*ExistDirRequest) XXX_Size added in v0.1.1 

func (m *ExistDirRequest) XXX_Size() int

func (*ExistDirRequest) XXX_Unmarshal added in v0.1.1 

func (m *ExistDirRequest) XXX_Unmarshal(b []byte) error

type ExistDirResponse added in v0.1.1 

type ExistDirResponse struct {
	Exist                bool     `protobuf:"varint,1,opt,name=exist,proto3" json:"exist,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ExistDirResponse) Descriptor added in v0.1.1 

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

func (*ExistDirResponse) GetExist added in v0.1.1 

func (m *ExistDirResponse) GetExist() bool

func (*ExistDirResponse) Marshal added in v0.1.1 

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

func (*ExistDirResponse) MarshalTo added in v0.1.1 

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

func (*ExistDirResponse) MarshalToSizedBuffer added in v0.1.1 

func (m *ExistDirResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ExistDirResponse) ProtoMessage added in v0.1.1 

func (*ExistDirResponse) ProtoMessage()

func (*ExistDirResponse) Reset added in v0.1.1 

func (m *ExistDirResponse) Reset()

func (*ExistDirResponse) Size added in v0.1.1 

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

func (*ExistDirResponse) String added in v0.1.1 

func (m *ExistDirResponse) String() string

func (*ExistDirResponse) Unmarshal added in v0.1.1 

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

func (*ExistDirResponse) XXX_DiscardUnknown added in v0.1.1 

func (m *ExistDirResponse) XXX_DiscardUnknown()

func (*ExistDirResponse) XXX_Marshal added in v0.1.1 

func (m *ExistDirResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExistDirResponse) XXX_Merge added in v0.1.1 

func (m *ExistDirResponse) XXX_Merge(src proto.Message)

func (*ExistDirResponse) XXX_Size added in v0.1.1 

func (m *ExistDirResponse) XXX_Size() int

func (*ExistDirResponse) XXX_Unmarshal added in v0.1.1 

func (m *ExistDirResponse) XXX_Unmarshal(b []byte) error

type HDFS 

type HDFS struct {
	Remote               string   `protobuf:"bytes,1,opt,name=remote,proto3" json:"remote,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*HDFS) Descriptor 

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

func (*HDFS) GetRemote 

func (m *HDFS) GetRemote() string

func (*HDFS) Marshal 

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

func (*HDFS) MarshalTo 

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

func (*HDFS) MarshalToSizedBuffer 

func (m *HDFS) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*HDFS) ProtoMessage 

func (*HDFS) ProtoMessage()

func (*HDFS) Reset 

func (m *HDFS) Reset()

func (*HDFS) Size 

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

func (*HDFS) String 

func (m *HDFS) String() string

func (*HDFS) Unmarshal 

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

func (*HDFS) XXX_DiscardUnknown 

func (m *HDFS) XXX_DiscardUnknown()

func (*HDFS) XXX_Marshal 

func (m *HDFS) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HDFS) XXX_Merge 

func (m *HDFS) XXX_Merge(src proto.Message)

func (*HDFS) XXX_Size 

func (m *HDFS) XXX_Size() int

func (*HDFS) XXX_Unmarshal 

func (m *HDFS) XXX_Unmarshal(b []byte) error

type IncrUploadFileRequest added in v0.2.0 

type IncrUploadFileRequest struct {
	SessionId            string   `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	SourcePath           string   `protobuf:"bytes,2,opt,name=source_path,json=sourcePath,proto3" json:"source_path,omitempty"`
	TargetBackend        *Backend `protobuf:"bytes,3,opt,name=target_backend,json=targetBackend,proto3" json:"target_backend,omitempty"`
	CommitLogId          int64    `protobuf:"varint,4,opt,name=commit_log_id,json=commitLogId,proto3" json:"commit_log_id,omitempty"`
	LastLogId            int64    `protobuf:"varint,5,opt,name=last_log_id,json=lastLogId,proto3" json:"last_log_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*IncrUploadFileRequest) Descriptor added in v0.2.0 

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

func (*IncrUploadFileRequest) GetCommitLogId added in v0.2.0 

func (m *IncrUploadFileRequest) GetCommitLogId() int64

func (*IncrUploadFileRequest) GetLastLogId added in v0.2.0 

func (m *IncrUploadFileRequest) GetLastLogId() int64

func (*IncrUploadFileRequest) GetSessionId added in v0.2.0 

func (m *IncrUploadFileRequest) GetSessionId() string

func (*IncrUploadFileRequest) GetSourcePath added in v0.2.0 

func (m *IncrUploadFileRequest) GetSourcePath() string

func (*IncrUploadFileRequest) GetTargetBackend added in v0.2.0 

func (m *IncrUploadFileRequest) GetTargetBackend() *Backend

func (*IncrUploadFileRequest) Marshal added in v0.2.0 

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

func (*IncrUploadFileRequest) MarshalTo added in v0.2.0 

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

func (*IncrUploadFileRequest) MarshalToSizedBuffer added in v0.2.0 

func (m *IncrUploadFileRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*IncrUploadFileRequest) ProtoMessage added in v0.2.0 

func (*IncrUploadFileRequest) ProtoMessage()

func (*IncrUploadFileRequest) Reset added in v0.2.0 

func (m *IncrUploadFileRequest) Reset()

func (*IncrUploadFileRequest) Size added in v0.2.0 

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

func (*IncrUploadFileRequest) String added in v0.2.0 

func (m *IncrUploadFileRequest) String() string

func (*IncrUploadFileRequest) Unmarshal added in v0.2.0 

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

func (*IncrUploadFileRequest) XXX_DiscardUnknown added in v0.2.0 

func (m *IncrUploadFileRequest) XXX_DiscardUnknown()

func (*IncrUploadFileRequest) XXX_Marshal added in v0.2.0 

func (m *IncrUploadFileRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*IncrUploadFileRequest) XXX_Merge added in v0.2.0 

func (m *IncrUploadFileRequest) XXX_Merge(src proto.Message)

func (*IncrUploadFileRequest) XXX_Size added in v0.2.0 

func (m *IncrUploadFileRequest) XXX_Size() int

func (*IncrUploadFileRequest) XXX_Unmarshal added in v0.2.0 

func (m *IncrUploadFileRequest) XXX_Unmarshal(b []byte) error

type IncrUploadFileResponse added in v0.2.0 

type IncrUploadFileResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*IncrUploadFileResponse) Descriptor added in v0.2.0 

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

func (*IncrUploadFileResponse) Marshal added in v0.2.0 

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

func (*IncrUploadFileResponse) MarshalTo added in v0.2.0 

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

func (*IncrUploadFileResponse) MarshalToSizedBuffer added in v0.2.0 

func (m *IncrUploadFileResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*IncrUploadFileResponse) ProtoMessage added in v0.2.0 

func (*IncrUploadFileResponse) ProtoMessage()

func (*IncrUploadFileResponse) Reset added in v0.2.0 

func (m *IncrUploadFileResponse) Reset()

func (*IncrUploadFileResponse) Size added in v0.2.0 

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

func (*IncrUploadFileResponse) String added in v0.2.0 

func (m *IncrUploadFileResponse) String() string

func (*IncrUploadFileResponse) Unmarshal added in v0.2.0 

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

func (*IncrUploadFileResponse) XXX_DiscardUnknown added in v0.2.0 

func (m *IncrUploadFileResponse) XXX_DiscardUnknown()

func (*IncrUploadFileResponse) XXX_Marshal added in v0.2.0 

func (m *IncrUploadFileResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*IncrUploadFileResponse) XXX_Merge added in v0.2.0 

func (m *IncrUploadFileResponse) XXX_Merge(src proto.Message)

func (*IncrUploadFileResponse) XXX_Size added in v0.2.0 

func (m *IncrUploadFileResponse) XXX_Size() int

func (*IncrUploadFileResponse) XXX_Unmarshal added in v0.2.0 

func (m *IncrUploadFileResponse) XXX_Unmarshal(b []byte) error

type Local 

type Local struct {
	Path                 string   `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Local) Descriptor 

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

func (*Local) GetPath 

func (m *Local) GetPath() string

func (*Local) Marshal 

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

func (*Local) MarshalTo 

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

func (*Local) MarshalToSizedBuffer 

func (m *Local) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Local) ProtoMessage 

func (*Local) ProtoMessage()

func (*Local) Reset 

func (m *Local) Reset()

func (*Local) Size 

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

func (*Local) String 

func (m *Local) String() string

func (*Local) Unmarshal 

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

func (*Local) XXX_DiscardUnknown 

func (m *Local) XXX_DiscardUnknown()

func (*Local) XXX_Marshal 

func (m *Local) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Local) XXX_Merge 

func (m *Local) XXX_Merge(src proto.Message)

func (*Local) XXX_Size 

func (m *Local) XXX_Size() int

func (*Local) XXX_Unmarshal 

func (m *Local) XXX_Unmarshal(b []byte) error

type MoveDirRequest 

type MoveDirRequest struct {
	SrcPath              string   `protobuf:"bytes,1,opt,name=src_path,json=srcPath,proto3" json:"src_path,omitempty"`
	DstPath              string   `protobuf:"bytes,2,opt,name=dst_path,json=dstPath,proto3" json:"dst_path,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MoveDirRequest) Descriptor 

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

func (*MoveDirRequest) GetDstPath 

func (m *MoveDirRequest) GetDstPath() string

func (*MoveDirRequest) GetSrcPath 

func (m *MoveDirRequest) GetSrcPath() string

func (*MoveDirRequest) Marshal 

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

func (*MoveDirRequest) MarshalTo 

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

func (*MoveDirRequest) MarshalToSizedBuffer 

func (m *MoveDirRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MoveDirRequest) ProtoMessage 

func (*MoveDirRequest) ProtoMessage()

func (*MoveDirRequest) Reset 

func (m *MoveDirRequest) Reset()

func (*MoveDirRequest) Size 

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

func (*MoveDirRequest) String 

func (m *MoveDirRequest) String() string

func (*MoveDirRequest) Unmarshal 

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

func (*MoveDirRequest) XXX_DiscardUnknown 

func (m *MoveDirRequest) XXX_DiscardUnknown()

func (*MoveDirRequest) XXX_Marshal 

func (m *MoveDirRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MoveDirRequest) XXX_Merge 

func (m *MoveDirRequest) XXX_Merge(src proto.Message)

func (*MoveDirRequest) XXX_Size 

func (m *MoveDirRequest) XXX_Size() int

func (*MoveDirRequest) XXX_Unmarshal 

func (m *MoveDirRequest) XXX_Unmarshal(b []byte) error

type MoveDirResponse 

type MoveDirResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MoveDirResponse) Descriptor 

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

func (*MoveDirResponse) Marshal 

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

func (*MoveDirResponse) MarshalTo 

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

func (*MoveDirResponse) MarshalToSizedBuffer 

func (m *MoveDirResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MoveDirResponse) ProtoMessage 

func (*MoveDirResponse) ProtoMessage()

func (*MoveDirResponse) Reset 

func (m *MoveDirResponse) Reset()

func (*MoveDirResponse) Size 

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

func (*MoveDirResponse) String 

func (m *MoveDirResponse) String() string

func (*MoveDirResponse) Unmarshal 

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

func (*MoveDirResponse) XXX_DiscardUnknown 

func (m *MoveDirResponse) XXX_DiscardUnknown()

func (*MoveDirResponse) XXX_Marshal 

func (m *MoveDirResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MoveDirResponse) XXX_Merge 

func (m *MoveDirResponse) XXX_Merge(src proto.Message)

func (*MoveDirResponse) XXX_Size 

func (m *MoveDirResponse) XXX_Size() int

func (*MoveDirResponse) XXX_Unmarshal 

func (m *MoveDirResponse) XXX_Unmarshal(b []byte) error

type RemoveDirRequest 

type RemoveDirRequest struct {
	Path                 string   `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RemoveDirRequest) Descriptor 

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

func (*RemoveDirRequest) GetPath 

func (m *RemoveDirRequest) GetPath() string

func (*RemoveDirRequest) Marshal 

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

func (*RemoveDirRequest) MarshalTo 

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

func (*RemoveDirRequest) MarshalToSizedBuffer 

func (m *RemoveDirRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RemoveDirRequest) ProtoMessage 

func (*RemoveDirRequest) ProtoMessage()

func (*RemoveDirRequest) Reset 

func (m *RemoveDirRequest) Reset()

func (*RemoveDirRequest) Size 

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

func (*RemoveDirRequest) String 

func (m *RemoveDirRequest) String() string

func (*RemoveDirRequest) Unmarshal 

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

func (*RemoveDirRequest) XXX_DiscardUnknown 

func (m *RemoveDirRequest) XXX_DiscardUnknown()

func (*RemoveDirRequest) XXX_Marshal 

func (m *RemoveDirRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RemoveDirRequest) XXX_Merge 

func (m *RemoveDirRequest) XXX_Merge(src proto.Message)

func (*RemoveDirRequest) XXX_Size 

func (m *RemoveDirRequest) XXX_Size() int

func (*RemoveDirRequest) XXX_Unmarshal 

func (m *RemoveDirRequest) XXX_Unmarshal(b []byte) error

type RemoveDirResponse 

type RemoveDirResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RemoveDirResponse) Descriptor 

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

func (*RemoveDirResponse) Marshal 

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

func (*RemoveDirResponse) MarshalTo 

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

func (*RemoveDirResponse) MarshalToSizedBuffer 

func (m *RemoveDirResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RemoveDirResponse) ProtoMessage 

func (*RemoveDirResponse) ProtoMessage()

func (*RemoveDirResponse) Reset 

func (m *RemoveDirResponse) Reset()

func (*RemoveDirResponse) Size 

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

func (*RemoveDirResponse) String 

func (m *RemoveDirResponse) String() string

func (*RemoveDirResponse) Unmarshal 

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

func (*RemoveDirResponse) XXX_DiscardUnknown 

func (m *RemoveDirResponse) XXX_DiscardUnknown()

func (*RemoveDirResponse) XXX_Marshal 

func (m *RemoveDirResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RemoveDirResponse) XXX_Merge 

func (m *RemoveDirResponse) XXX_Merge(src proto.Message)

func (*RemoveDirResponse) XXX_Size 

func (m *RemoveDirResponse) XXX_Size() int

func (*RemoveDirResponse) XXX_Unmarshal 

func (m *RemoveDirResponse) XXX_Unmarshal(b []byte) error

type S3 

type S3 struct {
	Endpoint             string   `protobuf:"bytes,1,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	Region               string   `protobuf:"bytes,2,opt,name=region,proto3" json:"region,omitempty"`
	Bucket               string   `protobuf:"bytes,3,opt,name=bucket,proto3" json:"bucket,omitempty"`
	Path                 string   `protobuf:"bytes,4,opt,name=path,proto3" json:"path,omitempty"`
	StorageClass         string   `protobuf:"bytes,5,opt,name=storage_class,json=storageClass,proto3" json:"storage_class,omitempty"`
	AccessKey            string   `protobuf:"bytes,6,opt,name=access_key,json=accessKey,proto3" json:"access_key,omitempty"`
	SecretKey            string   `protobuf:"bytes,7,opt,name=secret_key,json=secretKey,proto3" json:"secret_key,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*S3) Descriptor 

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

func (*S3) GetAccessKey 

func (m *S3) GetAccessKey() string

func (*S3) GetBucket 

func (m *S3) GetBucket() string

func (*S3) GetEndpoint 

func (m *S3) GetEndpoint() string

func (*S3) GetPath 

func (m *S3) GetPath() string

func (*S3) GetRegion 

func (m *S3) GetRegion() string

func (*S3) GetSecretKey 

func (m *S3) GetSecretKey() string

func (*S3) GetStorageClass 

func (m *S3) GetStorageClass() string

func (*S3) Marshal 

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

func (*S3) MarshalTo 

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

func (*S3) MarshalToSizedBuffer 

func (m *S3) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*S3) ProtoMessage 

func (*S3) ProtoMessage()

func (*S3) Reset 

func (m *S3) Reset()

func (*S3) Size 

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

func (*S3) String 

func (m *S3) String() string

func (*S3) Unmarshal 

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

func (*S3) XXX_DiscardUnknown 

func (m *S3) XXX_DiscardUnknown()

func (*S3) XXX_Marshal 

func (m *S3) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*S3) XXX_Merge 

func (m *S3) XXX_Merge(src proto.Message)

func (*S3) XXX_Size 

func (m *S3) XXX_Size() int

func (*S3) XXX_Unmarshal 

func (m *S3) XXX_Unmarshal(b []byte) error

type ServiceRole 

type ServiceRole int32
const (
	ServiceRole_UNKNOWN_ROLE ServiceRole = 0
	ServiceRole_META         ServiceRole = 1
	ServiceRole_GRAPH        ServiceRole = 2
	ServiceRole_STORAGE      ServiceRole = 3
)

func (ServiceRole) EnumDescriptor 

func (ServiceRole) EnumDescriptor() ([]byte, []int)

func (ServiceRole) String 

func (x ServiceRole) String() string

type ServiceStatusRequest added in v0.1.1 

type ServiceStatusRequest struct {
	Role                 ServiceRole `protobuf:"varint,1,opt,name=role,proto3,enum=proto.ServiceRole" json:"role,omitempty"`
	Dir                  string      `protobuf:"bytes,2,opt,name=dir,proto3" json:"dir,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*ServiceStatusRequest) Descriptor added in v0.1.1 

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

func (*ServiceStatusRequest) GetDir added in v0.1.1 

func (m *ServiceStatusRequest) GetDir() string

func (*ServiceStatusRequest) GetRole added in v0.1.1 

func (m *ServiceStatusRequest) GetRole() ServiceRole

func (*ServiceStatusRequest) Marshal added in v0.1.1 

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

func (*ServiceStatusRequest) MarshalTo added in v0.1.1 

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

func (*ServiceStatusRequest) MarshalToSizedBuffer added in v0.1.1 

func (m *ServiceStatusRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ServiceStatusRequest) ProtoMessage added in v0.1.1 

func (*ServiceStatusRequest) ProtoMessage()

func (*ServiceStatusRequest) Reset added in v0.1.1 

func (m *ServiceStatusRequest) Reset()

func (*ServiceStatusRequest) Size added in v0.1.1 

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

func (*ServiceStatusRequest) String added in v0.1.1 

func (m *ServiceStatusRequest) String() string

func (*ServiceStatusRequest) Unmarshal added in v0.1.1 

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

func (*ServiceStatusRequest) XXX_DiscardUnknown added in v0.1.1 

func (m *ServiceStatusRequest) XXX_DiscardUnknown()

func (*ServiceStatusRequest) XXX_Marshal added in v0.1.1 

func (m *ServiceStatusRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ServiceStatusRequest) XXX_Merge added in v0.1.1 

func (m *ServiceStatusRequest) XXX_Merge(src proto.Message)

func (*ServiceStatusRequest) XXX_Size added in v0.1.1 

func (m *ServiceStatusRequest) XXX_Size() int

func (*ServiceStatusRequest) XXX_Unmarshal added in v0.1.1 

func (m *ServiceStatusRequest) XXX_Unmarshal(b []byte) error

type ServiceStatusResponse added in v0.1.1 

type ServiceStatusResponse struct {
	Status               Status   `protobuf:"varint,1,opt,name=status,proto3,enum=proto.Status" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ServiceStatusResponse) Descriptor added in v0.1.1 

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

func (*ServiceStatusResponse) GetStatus added in v0.1.1 

func (m *ServiceStatusResponse) GetStatus() Status

func (*ServiceStatusResponse) Marshal added in v0.1.1 

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

func (*ServiceStatusResponse) MarshalTo added in v0.1.1 

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

func (*ServiceStatusResponse) MarshalToSizedBuffer added in v0.1.1 

func (m *ServiceStatusResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ServiceStatusResponse) ProtoMessage added in v0.1.1 

func (*ServiceStatusResponse) ProtoMessage()

func (*ServiceStatusResponse) Reset added in v0.1.1 

func (m *ServiceStatusResponse) Reset()

func (*ServiceStatusResponse) Size added in v0.1.1 

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

func (*ServiceStatusResponse) String added in v0.1.1 

func (m *ServiceStatusResponse) String() string

func (*ServiceStatusResponse) Unmarshal added in v0.1.1 

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

func (*ServiceStatusResponse) XXX_DiscardUnknown added in v0.1.1 

func (m *ServiceStatusResponse) XXX_DiscardUnknown()

func (*ServiceStatusResponse) XXX_Marshal added in v0.1.1 

func (m *ServiceStatusResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ServiceStatusResponse) XXX_Merge added in v0.1.1 

func (m *ServiceStatusResponse) XXX_Merge(src proto.Message)

func (*ServiceStatusResponse) XXX_Size added in v0.1.1 

func (m *ServiceStatusResponse) XXX_Size() int

func (*ServiceStatusResponse) XXX_Unmarshal added in v0.1.1 

func (m *ServiceStatusResponse) XXX_Unmarshal(b []byte) error

type StartServiceRequest 

type StartServiceRequest struct {
	Role                 ServiceRole `protobuf:"varint,1,opt,name=role,proto3,enum=proto.ServiceRole" json:"role,omitempty"`
	Dir                  string      `protobuf:"bytes,2,opt,name=dir,proto3" json:"dir,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*StartServiceRequest) Descriptor 

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

func (*StartServiceRequest) GetDir 

func (m *StartServiceRequest) GetDir() string

func (*StartServiceRequest) GetRole 

func (m *StartServiceRequest) GetRole() ServiceRole

func (*StartServiceRequest) Marshal 

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

func (*StartServiceRequest) MarshalTo 

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

func (*StartServiceRequest) MarshalToSizedBuffer 

func (m *StartServiceRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StartServiceRequest) ProtoMessage 

func (*StartServiceRequest) ProtoMessage()

func (*StartServiceRequest) Reset 

func (m *StartServiceRequest) Reset()

func (*StartServiceRequest) Size 

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

func (*StartServiceRequest) String 

func (m *StartServiceRequest) String() string

func (*StartServiceRequest) Unmarshal 

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

func (*StartServiceRequest) XXX_DiscardUnknown 

func (m *StartServiceRequest) XXX_DiscardUnknown()

func (*StartServiceRequest) XXX_Marshal 

func (m *StartServiceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StartServiceRequest) XXX_Merge 

func (m *StartServiceRequest) XXX_Merge(src proto.Message)

func (*StartServiceRequest) XXX_Size 

func (m *StartServiceRequest) XXX_Size() int

func (*StartServiceRequest) XXX_Unmarshal 

func (m *StartServiceRequest) XXX_Unmarshal(b []byte) error

type StartServiceResponse 

type StartServiceResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StartServiceResponse) Descriptor 

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

func (*StartServiceResponse) Marshal 

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

func (*StartServiceResponse) MarshalTo 

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

func (*StartServiceResponse) MarshalToSizedBuffer 

func (m *StartServiceResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StartServiceResponse) ProtoMessage 

func (*StartServiceResponse) ProtoMessage()

func (*StartServiceResponse) Reset 

func (m *StartServiceResponse) Reset()

func (*StartServiceResponse) Size 

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

func (*StartServiceResponse) String 

func (m *StartServiceResponse) String() string

func (*StartServiceResponse) Unmarshal 

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

func (*StartServiceResponse) XXX_DiscardUnknown 

func (m *StartServiceResponse) XXX_DiscardUnknown()

func (*StartServiceResponse) XXX_Marshal 

func (m *StartServiceResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StartServiceResponse) XXX_Merge 

func (m *StartServiceResponse) XXX_Merge(src proto.Message)

func (*StartServiceResponse) XXX_Size 

func (m *StartServiceResponse) XXX_Size() int

func (*StartServiceResponse) XXX_Unmarshal 

func (m *StartServiceResponse) XXX_Unmarshal(b []byte) error

type Status 

type Status int32
const (
	Status_UNKNOWN_STATUS Status = 0
	Status_RUNNING        Status = 1
	Status_EXITED         Status = 2
)

func (Status) EnumDescriptor added in v0.1.1 

func (Status) EnumDescriptor() ([]byte, []int)

func (Status) String 

func (x Status) String() string

type StopServiceRequest 

type StopServiceRequest struct {
	Role                 ServiceRole `protobuf:"varint,1,opt,name=role,proto3,enum=proto.ServiceRole" json:"role,omitempty"`
	Dir                  string      `protobuf:"bytes,2,opt,name=dir,proto3" json:"dir,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*StopServiceRequest) Descriptor 

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

func (*StopServiceRequest) GetDir 

func (m *StopServiceRequest) GetDir() string

func (*StopServiceRequest) GetRole 

func (m *StopServiceRequest) GetRole() ServiceRole

func (*StopServiceRequest) Marshal 

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

func (*StopServiceRequest) MarshalTo 

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

func (*StopServiceRequest) MarshalToSizedBuffer 

func (m *StopServiceRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StopServiceRequest) ProtoMessage 

func (*StopServiceRequest) ProtoMessage()

func (*StopServiceRequest) Reset 

func (m *StopServiceRequest) Reset()

func (*StopServiceRequest) Size 

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

func (*StopServiceRequest) String 

func (m *StopServiceRequest) String() string

func (*StopServiceRequest) Unmarshal 

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

func (*StopServiceRequest) XXX_DiscardUnknown 

func (m *StopServiceRequest) XXX_DiscardUnknown()

func (*StopServiceRequest) XXX_Marshal 

func (m *StopServiceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StopServiceRequest) XXX_Merge 

func (m *StopServiceRequest) XXX_Merge(src proto.Message)

func (*StopServiceRequest) XXX_Size 

func (m *StopServiceRequest) XXX_Size() int

func (*StopServiceRequest) XXX_Unmarshal 

func (m *StopServiceRequest) XXX_Unmarshal(b []byte) error

type StopServiceResponse 

type StopServiceResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StopServiceResponse) Descriptor 

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

func (*StopServiceResponse) Marshal 

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

func (*StopServiceResponse) MarshalTo 

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

func (*StopServiceResponse) MarshalToSizedBuffer 

func (m *StopServiceResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StopServiceResponse) ProtoMessage 

func (*StopServiceResponse) ProtoMessage()

func (*StopServiceResponse) Reset 

func (m *StopServiceResponse) Reset()

func (*StopServiceResponse) Size 

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

func (*StopServiceResponse) String 

func (m *StopServiceResponse) String() string

func (*StopServiceResponse) Unmarshal 

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

func (*StopServiceResponse) XXX_DiscardUnknown 

func (m *StopServiceResponse) XXX_DiscardUnknown()

func (*StopServiceResponse) XXX_Marshal 

func (m *StopServiceResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StopServiceResponse) XXX_Merge 

func (m *StopServiceResponse) XXX_Merge(src proto.Message)

func (*StopServiceResponse) XXX_Size 

func (m *StopServiceResponse) XXX_Size() int

func (*StopServiceResponse) XXX_Unmarshal 

func (m *StopServiceResponse) XXX_Unmarshal(b []byte) error

type StorageServiceClient 

type StorageServiceClient interface {
	// UploadFile upload file from agent machine to external storage
	UploadFile(ctx context.Context, in *UploadFileRequest, opts ...grpc.CallOption) (*UploadFileResponse, error)
	// IncrUploadFile upload incremental file from agent machine to external storage
	IncrUploadFile(ctx context.Context, in *IncrUploadFileRequest, opts ...grpc.CallOption) (*IncrUploadFileResponse, error)
	// DownloadFile download file from external storage to agent machine
	DownloadFile(ctx context.Context, in *DownloadFileRequest, opts ...grpc.CallOption) (*DownloadFileResponse, error)
	// MoveDir rename dir in agent machine
	MoveDir(ctx context.Context, in *MoveDirRequest, opts ...grpc.CallOption) (*MoveDirResponse, error)
	// RemoveDir delete dir in agent machine
	RemoveDir(ctx context.Context, in *RemoveDirRequest, opts ...grpc.CallOption) (*RemoveDirResponse, error)
	// ExistDir check if dir in agent machine exist
	ExistDir(ctx context.Context, in *ExistDirRequest, opts ...grpc.CallOption) (*ExistDirResponse, error)
}

StorageServiceClient is the client API for StorageService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewStorageServiceClient 

func NewStorageServiceClient(cc *grpc.ClientConn) StorageServiceClient

type StorageServiceServer 

type StorageServiceServer interface {
	// UploadFile upload file from agent machine to external storage
	UploadFile(context.Context, *UploadFileRequest) (*UploadFileResponse, error)
	// IncrUploadFile upload incremental file from agent machine to external storage
	IncrUploadFile(context.Context, *IncrUploadFileRequest) (*IncrUploadFileResponse, error)
	// DownloadFile download file from external storage to agent machine
	DownloadFile(context.Context, *DownloadFileRequest) (*DownloadFileResponse, error)
	// MoveDir rename dir in agent machine
	MoveDir(context.Context, *MoveDirRequest) (*MoveDirResponse, error)
	// RemoveDir delete dir in agent machine
	RemoveDir(context.Context, *RemoveDirRequest) (*RemoveDirResponse, error)
	// ExistDir check if dir in agent machine exist
	ExistDir(context.Context, *ExistDirRequest) (*ExistDirResponse, error)
}

StorageServiceServer is the server API for StorageService service.

type UnimplementedAgentServiceServer 

type UnimplementedAgentServiceServer struct {
}

UnimplementedAgentServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedAgentServiceServer) AllowReadWrite 

func (*UnimplementedAgentServiceServer) AllowReadWrite(ctx context.Context, req *AllowReadWriteRequest) (*AllowReadWriteResponse, error)

func (*UnimplementedAgentServiceServer) BanReadWrite 

func (*UnimplementedAgentServiceServer) BanReadWrite(ctx context.Context, req *BanReadWriteRequest) (*BanReadWriteResponse, error)

func (*UnimplementedAgentServiceServer) DataPlayBack added in v0.2.0 

func (*UnimplementedAgentServiceServer) DataPlayBack(ctx context.Context, req *DataPlayBackRequest) (*DataPlayBackResponse, error)

func (*UnimplementedAgentServiceServer) ServiceStatus added in v0.1.1 

func (*UnimplementedAgentServiceServer) ServiceStatus(ctx context.Context, req *ServiceStatusRequest) (*ServiceStatusResponse, error)

func (*UnimplementedAgentServiceServer) StartService 

func (*UnimplementedAgentServiceServer) StartService(ctx context.Context, req *StartServiceRequest) (*StartServiceResponse, error)

func (*UnimplementedAgentServiceServer) StopService 

func (*UnimplementedAgentServiceServer) StopService(ctx context.Context, req *StopServiceRequest) (*StopServiceResponse, error)

type UnimplementedStorageServiceServer 

type UnimplementedStorageServiceServer struct {
}

UnimplementedStorageServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedStorageServiceServer) DownloadFile 

func (*UnimplementedStorageServiceServer) DownloadFile(ctx context.Context, req *DownloadFileRequest) (*DownloadFileResponse, error)

func (*UnimplementedStorageServiceServer) ExistDir added in v0.1.1 

func (*UnimplementedStorageServiceServer) ExistDir(ctx context.Context, req *ExistDirRequest) (*ExistDirResponse, error)

func (*UnimplementedStorageServiceServer) IncrUploadFile added in v0.2.0 

func (*UnimplementedStorageServiceServer) IncrUploadFile(ctx context.Context, req *IncrUploadFileRequest) (*IncrUploadFileResponse, error)

func (*UnimplementedStorageServiceServer) MoveDir 

func (*UnimplementedStorageServiceServer) MoveDir(ctx context.Context, req *MoveDirRequest) (*MoveDirResponse, error)

func (*UnimplementedStorageServiceServer) RemoveDir 

func (*UnimplementedStorageServiceServer) RemoveDir(ctx context.Context, req *RemoveDirRequest) (*RemoveDirResponse, error)

func (*UnimplementedStorageServiceServer) UploadFile 

func (*UnimplementedStorageServiceServer) UploadFile(ctx context.Context, req *UploadFileRequest) (*UploadFileResponse, error)

type UploadFileRequest 

type UploadFileRequest struct {
	SessionId            string   `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	Recursively          bool     `protobuf:"varint,2,opt,name=recursively,proto3" json:"recursively,omitempty"`
	SourcePath           string   `protobuf:"bytes,3,opt,name=source_path,json=sourcePath,proto3" json:"source_path,omitempty"`
	TargetBackend        *Backend `protobuf:"bytes,4,opt,name=target_backend,json=targetBackend,proto3" json:"target_backend,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

every request should include the storage info, because there is no explicit session management in the interface

func (*UploadFileRequest) Descriptor 

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

func (*UploadFileRequest) GetRecursively 

func (m *UploadFileRequest) GetRecursively() bool

func (*UploadFileRequest) GetSessionId 

func (m *UploadFileRequest) GetSessionId() string

func (*UploadFileRequest) GetSourcePath 

func (m *UploadFileRequest) GetSourcePath() string

func (*UploadFileRequest) GetTargetBackend 

func (m *UploadFileRequest) GetTargetBackend() *Backend

func (*UploadFileRequest) Marshal 

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

func (*UploadFileRequest) MarshalTo 

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

func (*UploadFileRequest) MarshalToSizedBuffer 

func (m *UploadFileRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UploadFileRequest) ProtoMessage 

func (*UploadFileRequest) ProtoMessage()

func (*UploadFileRequest) Reset 

func (m *UploadFileRequest) Reset()

func (*UploadFileRequest) Size 

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

func (*UploadFileRequest) String 

func (m *UploadFileRequest) String() string

func (*UploadFileRequest) Unmarshal 

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

func (*UploadFileRequest) XXX_DiscardUnknown 

func (m *UploadFileRequest) XXX_DiscardUnknown()

func (*UploadFileRequest) XXX_Marshal 

func (m *UploadFileRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UploadFileRequest) XXX_Merge 

func (m *UploadFileRequest) XXX_Merge(src proto.Message)

func (*UploadFileRequest) XXX_Size 

func (m *UploadFileRequest) XXX_Size() int

func (*UploadFileRequest) XXX_Unmarshal 

func (m *UploadFileRequest) XXX_Unmarshal(b []byte) error

type UploadFileResponse 

type UploadFileResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UploadFileResponse) Descriptor 

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

func (*UploadFileResponse) Marshal 

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

func (*UploadFileResponse) MarshalTo 

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

func (*UploadFileResponse) MarshalToSizedBuffer 

func (m *UploadFileResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UploadFileResponse) ProtoMessage 

func (*UploadFileResponse) ProtoMessage()

func (*UploadFileResponse) Reset 

func (m *UploadFileResponse) Reset()

func (*UploadFileResponse) Size 

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

func (*UploadFileResponse) String 

func (m *UploadFileResponse) String() string

func (*UploadFileResponse) Unmarshal 

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

func (*UploadFileResponse) XXX_DiscardUnknown 

func (m *UploadFileResponse) XXX_DiscardUnknown()

func (*UploadFileResponse) XXX_Marshal 

func (m *UploadFileResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UploadFileResponse) XXX_Merge 

func (m *UploadFileResponse) XXX_Merge(src proto.Message)

func (*UploadFileResponse) XXX_Size 

func (m *UploadFileResponse) XXX_Size() int

func (*UploadFileResponse) XXX_Unmarshal 

func (m *UploadFileResponse) XXX_Unmarshal(b []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.