Versions in this module Expand all Collapse all v0 v0.1.0 Mar 30, 2021 Changes in this version + var File_upload_proto protoreflect.FileDescriptor + func RegisterUploadsServer(s grpc.ServiceRegistrar, srv UploadsServer) + type BeginRequest struct + Committed isBeginRequest_Committed + Path string + Tenant *tenant.ID + func (*BeginRequest) Descriptor() ([]byte, []int) + func (*BeginRequest) ProtoMessage() + func (m *BeginRequest) GetCommitted() isBeginRequest_Committed + func (x *BeginRequest) GetContents() []byte + func (x *BeginRequest) GetEmpty() bool + func (x *BeginRequest) GetPath() string + func (x *BeginRequest) GetTenant() *tenant.ID + func (x *BeginRequest) ProtoReflect() protoreflect.Message + func (x *BeginRequest) Reset() + func (x *BeginRequest) String() string + type BeginRequest_Contents struct + Contents []byte + type BeginRequest_Empty struct + Empty bool + type BeginResponse struct + Committed bool + MaxChunkSize int32 + State *TransferState + func (*BeginResponse) Descriptor() ([]byte, []int) + func (*BeginResponse) ProtoMessage() + func (x *BeginResponse) GetCommitted() bool + func (x *BeginResponse) GetMaxChunkSize() int32 + func (x *BeginResponse) GetState() *TransferState + func (x *BeginResponse) ProtoReflect() protoreflect.Message + func (x *BeginResponse) Reset() + func (x *BeginResponse) String() string + type CommitRequest struct + Meta map[string]string + State *TransferState + func (*CommitRequest) Descriptor() ([]byte, []int) + func (*CommitRequest) ProtoMessage() + func (x *CommitRequest) GetMeta() map[string]string + func (x *CommitRequest) GetState() *TransferState + func (x *CommitRequest) ProtoReflect() protoreflect.Message + func (x *CommitRequest) Reset() + func (x *CommitRequest) String() string + type CommitResponse struct + func (*CommitResponse) Descriptor() ([]byte, []int) + func (*CommitResponse) ProtoMessage() + func (x *CommitResponse) ProtoReflect() protoreflect.Message + func (x *CommitResponse) Reset() + func (x *CommitResponse) String() string + type FetchRequest struct + Path string + RemoteHeaders map[string]string + RemoteMethod string + RemoteUrl string + Tenant *tenant.ID + func (*FetchRequest) Descriptor() ([]byte, []int) + func (*FetchRequest) ProtoMessage() + func (x *FetchRequest) GetPath() string + func (x *FetchRequest) GetRemoteHeaders() map[string]string + func (x *FetchRequest) GetRemoteMethod() string + func (x *FetchRequest) GetRemoteUrl() string + func (x *FetchRequest) GetTenant() *tenant.ID + func (x *FetchRequest) ProtoReflect() protoreflect.Message + func (x *FetchRequest) Reset() + func (x *FetchRequest) String() string + type FetchResponse struct + RemoteHttpCode int32 + RemoteHttpMessage string + func (*FetchResponse) Descriptor() ([]byte, []int) + func (*FetchResponse) ProtoMessage() + func (x *FetchResponse) GetRemoteHttpCode() int32 + func (x *FetchResponse) GetRemoteHttpMessage() string + func (x *FetchResponse) ProtoReflect() protoreflect.Message + func (x *FetchResponse) Reset() + func (x *FetchResponse) String() string + type ID struct + Data []byte + func NewID() *ID + func (*ID) Descriptor() ([]byte, []int) + func (*ID) ProtoMessage() + func (x *ID) AsUUID() uuid.UUID + func (x *ID) GetData() []byte + func (x *ID) ProtoReflect() protoreflect.Message + func (x *ID) Reset() + func (x *ID) Scan(v interface{}) error + func (x *ID) String() string + func (x *ID) Value() (driver.Value, error) + func (x *ID) Zero() bool + type TransferRequest struct + Data []byte + State *TransferState + func (*TransferRequest) Descriptor() ([]byte, []int) + func (*TransferRequest) ProtoMessage() + func (x *TransferRequest) GetData() []byte + func (x *TransferRequest) GetState() *TransferState + func (x *TransferRequest) ProtoReflect() protoreflect.Message + func (x *TransferRequest) Reset() + func (x *TransferRequest) String() string + type TransferResponse struct + State *TransferState + func (*TransferResponse) Descriptor() ([]byte, []int) + func (*TransferResponse) ProtoMessage() + func (x *TransferResponse) GetState() *TransferState + func (x *TransferResponse) ProtoReflect() protoreflect.Message + func (x *TransferResponse) Reset() + func (x *TransferResponse) String() string + type TransferState struct + Data []byte + Deadline *timestamppb.Timestamp + ID *ID + Offset int64 + Signature []byte + TenantId *tenant.ID + func (*TransferState) Descriptor() ([]byte, []int) + func (*TransferState) ProtoMessage() + func (x *TransferState) GetData() []byte + func (x *TransferState) GetDeadline() *timestamppb.Timestamp + func (x *TransferState) GetID() *ID + func (x *TransferState) GetOffset() int64 + func (x *TransferState) GetSignature() []byte + func (x *TransferState) GetTenantId() *tenant.ID + func (x *TransferState) ProtoReflect() protoreflect.Message + func (x *TransferState) Reset() + func (x *TransferState) String() string + type UnimplementedUploadsServer struct + func (UnimplementedUploadsServer) Begin(context.Context, *BeginRequest) (*BeginResponse, error) + func (UnimplementedUploadsServer) Commit(context.Context, *CommitRequest) (*CommitResponse, error) + func (UnimplementedUploadsServer) Fetch(context.Context, *FetchRequest) (*FetchResponse, error) + func (UnimplementedUploadsServer) Transfer(context.Context, *TransferRequest) (*TransferResponse, error) + type UnsafeUploadsServer interface + type UploadsClient interface + Begin func(ctx context.Context, in *BeginRequest, opts ...grpc.CallOption) (*BeginResponse, error) + Commit func(ctx context.Context, in *CommitRequest, opts ...grpc.CallOption) (*CommitResponse, error) + Fetch func(ctx context.Context, in *FetchRequest, opts ...grpc.CallOption) (*FetchResponse, error) + Transfer func(ctx context.Context, in *TransferRequest, opts ...grpc.CallOption) (*TransferResponse, error) + func NewUploadsClient(cc grpc.ClientConnInterface) UploadsClient + type UploadsServer interface + Begin func(context.Context, *BeginRequest) (*BeginResponse, error) + Commit func(context.Context, *CommitRequest) (*CommitResponse, error) + Fetch func(context.Context, *FetchRequest) (*FetchResponse, error) + Transfer func(context.Context, *TransferRequest) (*TransferResponse, error)
Go to main page