cargoToCargo

Documentation

Index

• Variables
• func RegisterRpcCargoToCargoServer(s *grpc.Server, srv RpcCargoToCargoServer)
• type Ack
  • func (*Ack) Descriptor() ([]byte, []int)
  • func (x *Ack) GetAck() string
  • func (*Ack) ProtoMessage()
  • func (x *Ack) ProtoReflect() protoreflect.Message
  • func (x *Ack) Reset()
  • func (x *Ack) String() string
• type ReplicaData
  • func (*ReplicaData) Descriptor() ([]byte, []int)
  • func (x *ReplicaData) GetAppID() string
  • func (x *ReplicaData) GetFileBuffer() []byte
  • func (x *ReplicaData) GetFileName() string
  • func (x *ReplicaData) GetFileSize() int64
  • func (x *ReplicaData) GetFileType() string
  • func (*ReplicaData) ProtoMessage()
  • func (x *ReplicaData) ProtoReflect() protoreflect.Message
  • func (x *ReplicaData) Reset()
  • func (x *ReplicaData) String() string
• type RpcCargoToCargoClient
  • func NewRpcCargoToCargoClient(cc grpc.ClientConnInterface) RpcCargoToCargoClient
• type RpcCargoToCargoServer
• type UnimplementedRpcCargoToCargoServer
  • func (*UnimplementedRpcCargoToCargoServer) StoreInReplica(context.Context, *ReplicaData) (*Ack, error)
  • func (*UnimplementedRpcCargoToCargoServer) WriteInReplica(context.Context, *ReplicaData) (*Ack, error)

Variables

var File_cargoToCargo_proto protoreflect.FileDescriptor

Functions

func RegisterRpcCargoToCargoServer

func RegisterRpcCargoToCargoServer(s *grpc.Server, srv RpcCargoToCargoServer)

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 ReplicaData

type ReplicaData 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 (*ReplicaData) Descriptor

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

Deprecated: Use ReplicaData.ProtoReflect.Descriptor instead.

func (*ReplicaData) GetAppID

func (x *ReplicaData) GetAppID() string

func (*ReplicaData) GetFileBuffer

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

func (*ReplicaData) GetFileName

func (x *ReplicaData) GetFileName() string

func (*ReplicaData) GetFileSize

func (x *ReplicaData) GetFileSize() int64

func (*ReplicaData) GetFileType

func (x *ReplicaData) GetFileType() string

func (*ReplicaData) ProtoMessage

func (*ReplicaData) ProtoMessage()

func (*ReplicaData) ProtoReflect

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

func (*ReplicaData) Reset

func (x *ReplicaData) Reset()

func (*ReplicaData) String

func (x *ReplicaData) String() string

type RpcCargoToCargoClient

type RpcCargoToCargoClient interface {
	StoreInReplica(ctx context.Context, in *ReplicaData, opts ...grpc.CallOption) (*Ack, error)
	WriteInReplica(ctx context.Context, in *ReplicaData, opts ...grpc.CallOption) (*Ack, error)
}

RpcCargoToCargoClient is the client API for RpcCargoToCargo service.

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

func NewRpcCargoToCargoClient

func NewRpcCargoToCargoClient(cc grpc.ClientConnInterface) RpcCargoToCargoClient

type RpcCargoToCargoServer

type RpcCargoToCargoServer interface {
	StoreInReplica(context.Context, *ReplicaData) (*Ack, error)
	WriteInReplica(context.Context, *ReplicaData) (*Ack, error)
}

RpcCargoToCargoServer is the server API for RpcCargoToCargo service.

type UnimplementedRpcCargoToCargoServer

type UnimplementedRpcCargoToCargoServer struct {
}

UnimplementedRpcCargoToCargoServer can be embedded to have forward compatible implementations.

func (*UnimplementedRpcCargoToCargoServer) StoreInReplica

func (*UnimplementedRpcCargoToCargoServer) StoreInReplica(context.Context, *ReplicaData) (*Ack, error)

func (*UnimplementedRpcCargoToCargoServer) WriteInReplica

func (*UnimplementedRpcCargoToCargoServer) WriteInReplica(context.Context, *ReplicaData) (*Ack, error)