taskToCargo

package
v0.0.0-...-31d405b Latest Latest
Warning

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

 Go to latest Published: May 19, 2021 License: MIT Imports: 9 Imported by: 2

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 deprecated 

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 deprecated 

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 deprecated 

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 deprecated 

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 deprecated 

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 deprecated 

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.

func NewRpcTaskToCargoClient 

func NewRpcTaskToCargoClient(cc grpc.ClientConnInterface) RpcTaskToCargoClient

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) LoadFromCargo(context.Context, *FileInfo) (*DataToLoad, error)

func (*UnimplementedRpcTaskToCargoServer) ReadFromCargo 

func (*UnimplementedRpcTaskToCargoServer) ReadFromCargo(context.Context, *ReadInfo) (*ReadData, error)

func (*UnimplementedRpcTaskToCargoServer) StoreInCargo 

func (*UnimplementedRpcTaskToCargoServer) StoreInCargo(context.Context, *DataToStore) (*Ack, error)

func (*UnimplementedRpcTaskToCargoServer) WriteToCargo 

func (*UnimplementedRpcTaskToCargoServer) WriteToCargo(context.Context, *WriteData) (*Ack, error)

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 deprecated 

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

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.