upload

type BeginRequest struct {
	Tenant *tenant.ID `protobuf:"bytes,1,opt,name=tenant,proto3" json:"tenant,omitempty"`
	Path   string     `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	// For trivially small (or empty) files, we'd like to be able to
	// effect the transfer in a single request.
	//
	// Types that are assignable to Committed:
	//	*BeginRequest_Contents
	//	*BeginRequest_Empty
	Committed isBeginRequest_Committed `protobuf_oneof:"committed"`
	// contains filtered or unexported fields
}

type BeginRequest_Contents struct {
	// The contents of the file.  This should generally be under
	// 1 MiB. If the contents exceed the server's configured maximum,
	// an error may be returned.
	Contents []byte `protobuf:"bytes,3,opt,name=contents,proto3,oneof"`
}

type BeginRequest_Empty struct {
	// If true, an empty file will be committed.
	Empty bool `protobuf:"varint,4,opt,name=empty,proto3,oneof"`
}

type BeginResponse struct {

	// Continuation data to provide to TransferRequest.
	State *TransferState `protobuf:"bytes,1,opt,name=state,proto3" json:"state,omitempty"`
	// The maximum number of bytes to include in a single transfer.
	MaxChunkSize int32 `protobuf:"varint,2,opt,name=max_chunk_size,json=maxChunkSize,proto3" json:"max_chunk_size,omitempty"`
	// If this field is true, the contents in the BeginRequest were
	// committed successfully and the transfer is finished.  If false,
	// the client can use the returned TransferState to perform the
	// file transfer as usual.
	Committed bool `protobuf:"varint,3,opt,name=committed,proto3" json:"committed,omitempty"`
	// contains filtered or unexported fields
}

type CommitRequest struct {

	// Continuation data from a previous TransferRequest.
	State *TransferState `protobuf:"bytes,1,opt,name=state,proto3" json:"state,omitempty"`
	// Additional metadata to be returned when subsequently fetching the
	// file. The metadata is placed on the CommitRequest so that stream-
	// based operations (e.g. computing a checksum) may be performed
	// during the transfer process.
	Meta map[string]string `` /* 149-byte string literal not displayed */
	// contains filtered or unexported fields
}

type CommitResponse struct {
	// contains filtered or unexported fields
}

type FetchRequest struct {
	Tenant *tenant.ID `protobuf:"bytes,1,opt,name=tenant,proto3" json:"tenant,omitempty"`
	Path   string     `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	// The URL to fetch.
	RemoteUrl string `protobuf:"bytes,3,opt,name=remote_url,json=remoteUrl,proto3" json:"remote_url,omitempty"`
	// Additional headers to append to the request, (e.g. Authorization).
	RemoteHeaders map[string]string `` /* 188-byte string literal not displayed */
	// The HTTP method to make the request with.
	// Defaults to GET if unspecified.
	RemoteMethod string `protobuf:"bytes,5,opt,name=remote_method,json=remoteMethod,proto3" json:"remote_method,omitempty"`
	// contains filtered or unexported fields
}

type FetchResponse struct {
	RemoteHttpCode    int32  `protobuf:"varint,1,opt,name=remote_http_code,json=remoteHttpCode,proto3" json:"remote_http_code,omitempty"`
	RemoteHttpMessage string `protobuf:"bytes,2,opt,name=remote_http_message,json=remoteHttpMessage,proto3" json:"remote_http_message,omitempty"`
	// contains filtered or unexported fields
}

type ID struct {
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

type TransferRequest struct {

	// This state must be provided from either BeginResponse or a
	// previous TransferResponse.
	State *TransferState `protobuf:"bytes,1,opt,name=state,proto3" json:"state,omitempty"`
	// The size of data must not exceed BeginResponse.max_chunk_size.
	Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

type TransferResponse struct {

	// The state to pass into the next TransferRequest.
	State *TransferState `protobuf:"bytes,1,opt,name=state,proto3" json:"state,omitempty"`
	// contains filtered or unexported fields
}

type TransferState struct {
	ID        *ID                    `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	Offset    int64                  `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"`
	Data      []byte                 `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	Deadline  *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=deadline,proto3" json:"deadline,omitempty"`
	TenantId  *tenant.ID             `protobuf:"bytes,5,opt,name=tenant_id,json=tenantId,proto3" json:"tenant_id,omitempty"`
	Signature []byte                 `protobuf:"bytes,15,opt,name=signature,proto3" json:"signature,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedUploadsServer struct {
}

type UnsafeUploadsServer interface {
	// contains filtered or unexported methods
}

type UploadsClient interface {
	Begin(ctx context.Context, in *BeginRequest, opts ...grpc.CallOption) (*BeginResponse, error)
	Commit(ctx context.Context, in *CommitRequest, opts ...grpc.CallOption) (*CommitResponse, error)
	Fetch(ctx context.Context, in *FetchRequest, opts ...grpc.CallOption) (*FetchResponse, error)
	Transfer(ctx context.Context, in *TransferRequest, opts ...grpc.CallOption) (*TransferResponse, error)
}

type UploadsServer interface {
	Begin(context.Context, *BeginRequest) (*BeginResponse, error)
	Commit(context.Context, *CommitRequest) (*CommitResponse, error)
	Fetch(context.Context, *FetchRequest) (*FetchResponse, error)
	Transfer(context.Context, *TransferRequest) (*TransferResponse, error)
	// contains filtered or unexported methods
}