Documentation

Index

Constants

This section is empty.

Variables

View Source
var File_taskToCargo_proto protoreflect.FileDescriptor

Functions

func RegisterRpcTaskToCargoServer

func RegisterRpcTaskToCargoServer(s *grpc.Server, srv RpcTaskToCargoServer)

Types

type Ack

type Ack struct {
	Ack string `protobuf:"bytes,2,opt,name=ack,proto3" json:"ack,omitempty"`
	// contains filtered or unexported fields
}

func (*Ack) Descriptor

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

    Deprecated: Use Ack.ProtoReflect.Descriptor instead.

    func (*Ack) GetAck

    func (x *Ack) GetAck() string

    func (*Ack) ProtoMessage

    func (*Ack) ProtoMessage()

    func (*Ack) ProtoReflect

    func (x *Ack) ProtoReflect() protoreflect.Message

    func (*Ack) Reset

    func (x *Ack) Reset()

    func (*Ack) String

    func (x *Ack) String() string

    type DataToLoad

    type DataToLoad struct {
    	FileName   string `protobuf:"bytes,1,opt,name=fileName,proto3" json:"fileName,omitempty"`
    	FileBuffer []byte `protobuf:"bytes,2,opt,name=fileBuffer,proto3" json:"fileBuffer,omitempty"`
    	FileSize   int64  `protobuf:"varint,3,opt,name=fileSize,proto3" json:"fileSize,omitempty"`
    	FileType   string `protobuf:"bytes,4,opt,name=fileType,proto3" json:"fileType,omitempty"`
    	AppID      string `protobuf:"bytes,5,opt,name=appID,proto3" json:"appID,omitempty"`
    	// contains filtered or unexported fields
    }

    func (*DataToLoad) Descriptor

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

      Deprecated: Use DataToLoad.ProtoReflect.Descriptor instead.

      func (*DataToLoad) GetAppID

      func (x *DataToLoad) GetAppID() string

      func (*DataToLoad) GetFileBuffer

      func (x *DataToLoad) GetFileBuffer() []byte

      func (*DataToLoad) GetFileName

      func (x *DataToLoad) GetFileName() string

      func (*DataToLoad) GetFileSize

      func (x *DataToLoad) GetFileSize() int64

      func (*DataToLoad) GetFileType

      func (x *DataToLoad) GetFileType() string

      func (*DataToLoad) ProtoMessage

      func (*DataToLoad) ProtoMessage()

      func (*DataToLoad) ProtoReflect

      func (x *DataToLoad) ProtoReflect() protoreflect.Message

      func (*DataToLoad) Reset

      func (x *DataToLoad) Reset()

      func (*DataToLoad) String

      func (x *DataToLoad) String() string

      type DataToStore

      type DataToStore struct {
      	FileName   string `protobuf:"bytes,1,opt,name=fileName,proto3" json:"fileName,omitempty"`
      	FileBuffer []byte `protobuf:"bytes,2,opt,name=fileBuffer,proto3" json:"fileBuffer,omitempty"`
      	FileSize   int64  `protobuf:"varint,3,opt,name=fileSize,proto3" json:"fileSize,omitempty"`
      	FileType   string `protobuf:"bytes,4,opt,name=fileType,proto3" json:"fileType,omitempty"`
      	AppID      string `protobuf:"bytes,5,opt,name=appID,proto3" json:"appID,omitempty"`
      	// contains filtered or unexported fields
      }

        entire file read/write

        func (*DataToStore) Descriptor

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

          Deprecated: Use DataToStore.ProtoReflect.Descriptor instead.

          func (*DataToStore) GetAppID

          func (x *DataToStore) GetAppID() string

          func (*DataToStore) GetFileBuffer

          func (x *DataToStore) GetFileBuffer() []byte

          func (*DataToStore) GetFileName

          func (x *DataToStore) GetFileName() string

          func (*DataToStore) GetFileSize

          func (x *DataToStore) GetFileSize() int64

          func (*DataToStore) GetFileType

          func (x *DataToStore) GetFileType() string

          func (*DataToStore) ProtoMessage

          func (*DataToStore) ProtoMessage()

          func (*DataToStore) ProtoReflect

          func (x *DataToStore) ProtoReflect() protoreflect.Message

          func (*DataToStore) Reset

          func (x *DataToStore) Reset()

          func (*DataToStore) String

          func (x *DataToStore) String() string

          type FileInfo

          type FileInfo struct {
          	FileName string `protobuf:"bytes,1,opt,name=fileName,proto3" json:"fileName,omitempty"`
          	// contains filtered or unexported fields
          }

          func (*FileInfo) Descriptor

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

            Deprecated: Use FileInfo.ProtoReflect.Descriptor instead.

            func (*FileInfo) GetFileName

            func (x *FileInfo) GetFileName() string

            func (*FileInfo) ProtoMessage

            func (*FileInfo) ProtoMessage()

            func (*FileInfo) ProtoReflect

            func (x *FileInfo) ProtoReflect() protoreflect.Message

            func (*FileInfo) Reset

            func (x *FileInfo) Reset()

            func (*FileInfo) String

            func (x *FileInfo) String() string

            type ReadData

            type ReadData struct {
            	FileName   string `protobuf:"bytes,1,opt,name=fileName,proto3" json:"fileName,omitempty"`
            	FileBuffer []byte `protobuf:"bytes,2,opt,name=fileBuffer,proto3" json:"fileBuffer,omitempty"`
            	ReadSize   int64  `protobuf:"varint,3,opt,name=readSize,proto3" json:"readSize,omitempty"`
            	// contains filtered or unexported fields
            }

            func (*ReadData) Descriptor

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

              Deprecated: Use ReadData.ProtoReflect.Descriptor instead.

              func (*ReadData) GetFileBuffer

              func (x *ReadData) GetFileBuffer() []byte

              func (*ReadData) GetFileName

              func (x *ReadData) GetFileName() string

              func (*ReadData) GetReadSize

              func (x *ReadData) GetReadSize() int64

              func (*ReadData) ProtoMessage

              func (*ReadData) ProtoMessage()

              func (*ReadData) ProtoReflect

              func (x *ReadData) ProtoReflect() protoreflect.Message

              func (*ReadData) Reset

              func (x *ReadData) Reset()

              func (*ReadData) String

              func (x *ReadData) String() string

              type ReadInfo

              type ReadInfo struct {
              	FileName string `protobuf:"bytes,1,opt,name=fileName,proto3" json:"fileName,omitempty"`
              	AppID    string `protobuf:"bytes,2,opt,name=appID,proto3" json:"appID,omitempty"`
              	// contains filtered or unexported fields
              }

              func (*ReadInfo) Descriptor

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

                Deprecated: Use ReadInfo.ProtoReflect.Descriptor instead.

                func (*ReadInfo) GetAppID

                func (x *ReadInfo) GetAppID() string

                func (*ReadInfo) GetFileName

                func (x *ReadInfo) GetFileName() string

                func (*ReadInfo) ProtoMessage

                func (*ReadInfo) ProtoMessage()

                func (*ReadInfo) ProtoReflect

                func (x *ReadInfo) ProtoReflect() protoreflect.Message

                func (*ReadInfo) Reset

                func (x *ReadInfo) Reset()

                func (*ReadInfo) String

                func (x *ReadInfo) String() string

                type RpcTaskToCargoClient

                type RpcTaskToCargoClient interface {
                	StoreInCargo(ctx context.Context, in *DataToStore, opts ...grpc.CallOption) (*Ack, error)
                	LoadFromCargo(ctx context.Context, in *FileInfo, opts ...grpc.CallOption) (*DataToLoad, error)
                	WriteToCargo(ctx context.Context, in *WriteData, opts ...grpc.CallOption) (*Ack, error)
                	ReadFromCargo(ctx context.Context, in *ReadInfo, opts ...grpc.CallOption) (*ReadData, error)
                }

                  RpcTaskToCargoClient is the client API for RpcTaskToCargo service.

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

                  type RpcTaskToCargoServer

                  type RpcTaskToCargoServer interface {
                  	StoreInCargo(context.Context, *DataToStore) (*Ack, error)
                  	LoadFromCargo(context.Context, *FileInfo) (*DataToLoad, error)
                  	WriteToCargo(context.Context, *WriteData) (*Ack, error)
                  	ReadFromCargo(context.Context, *ReadInfo) (*ReadData, error)
                  }

                    RpcTaskToCargoServer is the server API for RpcTaskToCargo service.

                    type UnimplementedRpcTaskToCargoServer

                    type UnimplementedRpcTaskToCargoServer struct {
                    }

                      UnimplementedRpcTaskToCargoServer can be embedded to have forward compatible implementations.

                      func (*UnimplementedRpcTaskToCargoServer) LoadFromCargo

                      func (*UnimplementedRpcTaskToCargoServer) ReadFromCargo

                      func (*UnimplementedRpcTaskToCargoServer) StoreInCargo

                      func (*UnimplementedRpcTaskToCargoServer) WriteToCargo

                      type WriteData

                      type WriteData struct {
                      	FileName   string `protobuf:"bytes,1,opt,name=fileName,proto3" json:"fileName,omitempty"`
                      	FileBuffer []byte `protobuf:"bytes,2,opt,name=fileBuffer,proto3" json:"fileBuffer,omitempty"`
                      	WriteSize  int64  `protobuf:"varint,3,opt,name=writeSize,proto3" json:"writeSize,omitempty"`
                      	AppID      string `protobuf:"bytes,4,opt,name=appID,proto3" json:"appID,omitempty"`
                      	// contains filtered or unexported fields
                      }

                        read/write into a file

                        func (*WriteData) Descriptor

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

                          Deprecated: Use WriteData.ProtoReflect.Descriptor instead.

                          func (*WriteData) GetAppID

                          func (x *WriteData) GetAppID() string

                          func (*WriteData) GetFileBuffer

                          func (x *WriteData) GetFileBuffer() []byte

                          func (*WriteData) GetFileName

                          func (x *WriteData) GetFileName() string

                          func (*WriteData) GetWriteSize

                          func (x *WriteData) GetWriteSize() int64

                          func (*WriteData) ProtoMessage

                          func (*WriteData) ProtoMessage()

                          func (*WriteData) ProtoReflect

                          func (x *WriteData) ProtoReflect() protoreflect.Message

                          func (*WriteData) Reset

                          func (x *WriteData) Reset()

                          func (*WriteData) String

                          func (x *WriteData) String() string