protos

package
v1.0.0-5 Latest Latest
Warning

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

 Go to latest Published: Jan 18, 2023 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var Blobs_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "blobs_v1.Blobs",
	HandlerType: (*BlobsServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "get_blobs_by_filter",
			Handler:    _Blobs_GetBlobsByFilter_Handler,
		},
		{
			MethodName: "get_blobs_by_ids",
			Handler:    _Blobs_GetBlobsByIds_Handler,
		},
		{
			MethodName: "get_blob_by_id",
			Handler:    _Blobs_GetBlobById_Handler,
		},
		{
			MethodName: "get_blob_uri_by_id",
			Handler:    _Blobs_GetBlobUriById_Handler,
		},
		{
			MethodName: "begin_blob_write",
			Handler:    _Blobs_BeginBlobWrite_Handler,
		},
		{
			MethodName: "write_blob_chunk",
			Handler:    _Blobs_WriteBlobChunk_Handler,
		},
		{
			MethodName: "end_blob_write",
			Handler:    _Blobs_EndBlobWrite_Handler,
		},
		{
			MethodName: "abort_blob_write",
			Handler:    _Blobs_AbortBlobWrite_Handler,
		},
		{
			MethodName: "begin_blob_read",
			Handler:    _Blobs_BeginBlobRead_Handler,
		},
		{
			MethodName: "read_blob_chunk",
			Handler:    _Blobs_ReadBlobChunk_Handler,
		},
		{
			MethodName: "end_blob_read",
			Handler:    _Blobs_EndBlobRead_Handler,
		},
		{
			MethodName: "update_blob_info",
			Handler:    _Blobs_UpdateBlobInfo_Handler,
		},
		{
			MethodName: "mark_blobs_completed",
			Handler:    _Blobs_MarkBlobsCompleted_Handler,
		},
		{
			MethodName: "delete_blob_by_id",
			Handler:    _Blobs_DeleteBlobById_Handler,
		},
		{
			MethodName: "delete_blobs_by_ids",
			Handler:    _Blobs_DeleteBlobsByIds_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "protos/blobs_v1.proto",
}

Blobs_ServiceDesc is the grpc.ServiceDesc for Blobs service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_protos_blobs_v1_proto protoreflect.FileDescriptor

Functions

func RegisterBlobsServer 

func RegisterBlobsServer(s grpc.ServiceRegistrar, srv BlobsServer)

Types

type BlobChunkReply 

type BlobChunkReply struct {
	Error *ErrorDescription `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	Chunk string            `protobuf:"bytes,2,opt,name=chunk,proto3" json:"chunk,omitempty"`
	// contains filtered or unexported fields
}

The response message containing the blob chunk response

func (*BlobChunkReply) Descriptor deprecated 

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

Deprecated: Use BlobChunkReply.ProtoReflect.Descriptor instead.

func (*BlobChunkReply) GetChunk 

func (x *BlobChunkReply) GetChunk() string

func (*BlobChunkReply) GetError 

func (x *BlobChunkReply) GetError() *ErrorDescription

func (*BlobChunkReply) ProtoMessage 

func (*BlobChunkReply) ProtoMessage()

func (*BlobChunkReply) ProtoReflect 

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

func (*BlobChunkReply) Reset 

func (x *BlobChunkReply) Reset()

func (*BlobChunkReply) String 

func (x *BlobChunkReply) String() string

type BlobEmptyReply 

type BlobEmptyReply struct {
	Error *ErrorDescription `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

The response message containing the blob empty response

func (*BlobEmptyReply) Descriptor deprecated 

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

Deprecated: Use BlobEmptyReply.ProtoReflect.Descriptor instead.

func (*BlobEmptyReply) GetError 

func (x *BlobEmptyReply) GetError() *ErrorDescription

func (*BlobEmptyReply) ProtoMessage 

func (*BlobEmptyReply) ProtoMessage()

func (*BlobEmptyReply) ProtoReflect 

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

func (*BlobEmptyReply) Reset 

func (x *BlobEmptyReply) Reset()

func (*BlobEmptyReply) String 

func (x *BlobEmptyReply) String() string

type BlobIdRequest 

type BlobIdRequest struct {
	CorrelationId string `protobuf:"bytes,1,opt,name=correlation_id,json=correlationId,proto3" json:"correlation_id,omitempty"`
	BlobId        string `protobuf:"bytes,2,opt,name=blob_id,json=blobId,proto3" json:"blob_id,omitempty"`
	// contains filtered or unexported fields
}

The request message containing the blob id request.

func (*BlobIdRequest) Descriptor deprecated 

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

Deprecated: Use BlobIdRequest.ProtoReflect.Descriptor instead.

func (*BlobIdRequest) GetBlobId 

func (x *BlobIdRequest) GetBlobId() string

func (*BlobIdRequest) GetCorrelationId 

func (x *BlobIdRequest) GetCorrelationId() string

func (*BlobIdRequest) ProtoMessage 

func (*BlobIdRequest) ProtoMessage()

func (*BlobIdRequest) ProtoReflect 

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

func (*BlobIdRequest) Reset 

func (x *BlobIdRequest) Reset()

func (*BlobIdRequest) String 

func (x *BlobIdRequest) String() string

type BlobIdsRequest 

type BlobIdsRequest struct {
	CorrelationId string   `protobuf:"bytes,1,opt,name=correlation_id,json=correlationId,proto3" json:"correlation_id,omitempty"`
	BlobIds       []string `protobuf:"bytes,2,rep,name=blob_ids,json=blobIds,proto3" json:"blob_ids,omitempty"`
	// contains filtered or unexported fields
}

The request message containing the blob ids request.

func (*BlobIdsRequest) Descriptor deprecated 

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

Deprecated: Use BlobIdsRequest.ProtoReflect.Descriptor instead.

func (*BlobIdsRequest) GetBlobIds 

func (x *BlobIdsRequest) GetBlobIds() []string

func (*BlobIdsRequest) GetCorrelationId 

func (x *BlobIdsRequest) GetCorrelationId() string

func (*BlobIdsRequest) ProtoMessage 

func (*BlobIdsRequest) ProtoMessage()

func (*BlobIdsRequest) ProtoReflect 

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

func (*BlobIdsRequest) Reset 

func (x *BlobIdsRequest) Reset()

func (*BlobIdsRequest) String 

func (x *BlobIdsRequest) String() string

type BlobInfo 

type BlobInfo struct {

	// Identification
	Id    string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Group string `protobuf:"bytes,2,opt,name=group,proto3" json:"group,omitempty"`
	Name  string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	// Content
	Size        int64  `protobuf:"varint,4,opt,name=size,proto3" json:"size,omitempty"`
	ContentType string `protobuf:"bytes,5,opt,name=content_type,json=contentType,proto3" json:"content_type,omitempty"`
	CreateTime  string `protobuf:"bytes,6,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	ExpireTime  string `protobuf:"bytes,7,opt,name=expire_time,json=expireTime,proto3" json:"expire_time,omitempty"`
	Completed   bool   `protobuf:"varint,8,opt,name=completed,proto3" json:"completed,omitempty"`
	// contains filtered or unexported fields
}

func (*BlobInfo) Descriptor deprecated 

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

Deprecated: Use BlobInfo.ProtoReflect.Descriptor instead.

func (*BlobInfo) GetCompleted 

func (x *BlobInfo) GetCompleted() bool

func (*BlobInfo) GetContentType 

func (x *BlobInfo) GetContentType() string

func (*BlobInfo) GetCreateTime 

func (x *BlobInfo) GetCreateTime() string

func (*BlobInfo) GetExpireTime 

func (x *BlobInfo) GetExpireTime() string

func (*BlobInfo) GetGroup 

func (x *BlobInfo) GetGroup() string

func (*BlobInfo) GetId 

func (x *BlobInfo) GetId() string

func (*BlobInfo) GetName 

func (x *BlobInfo) GetName() string

func (*BlobInfo) GetSize 

func (x *BlobInfo) GetSize() int64

func (*BlobInfo) ProtoMessage 

func (*BlobInfo) ProtoMessage()

func (*BlobInfo) ProtoReflect 

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

func (*BlobInfo) Reset 

func (x *BlobInfo) Reset()

func (*BlobInfo) String 

func (x *BlobInfo) String() string

type BlobInfoObjectReply 

type BlobInfoObjectReply struct {
	Error *ErrorDescription `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	Blob  *BlobInfo         `protobuf:"bytes,2,opt,name=blob,proto3" json:"blob,omitempty"`
	// contains filtered or unexported fields
}

The response message containing the blob info object response

func (*BlobInfoObjectReply) Descriptor deprecated 

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

Deprecated: Use BlobInfoObjectReply.ProtoReflect.Descriptor instead.

func (*BlobInfoObjectReply) GetBlob 

func (x *BlobInfoObjectReply) GetBlob() *BlobInfo

func (*BlobInfoObjectReply) GetError 

func (x *BlobInfoObjectReply) GetError() *ErrorDescription

func (*BlobInfoObjectReply) ProtoMessage 

func (*BlobInfoObjectReply) ProtoMessage()

func (*BlobInfoObjectReply) ProtoReflect 

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

func (*BlobInfoObjectReply) Reset 

func (x *BlobInfoObjectReply) Reset()

func (*BlobInfoObjectReply) String 

func (x *BlobInfoObjectReply) String() string

type BlobInfoObjectRequest 

type BlobInfoObjectRequest struct {
	CorrelationId string    `protobuf:"bytes,1,opt,name=correlation_id,json=correlationId,proto3" json:"correlation_id,omitempty"`
	Blob          *BlobInfo `protobuf:"bytes,2,opt,name=blob,proto3" json:"blob,omitempty"`
	// contains filtered or unexported fields
}

The request message containing the blob info object request.

func (*BlobInfoObjectRequest) Descriptor deprecated 

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

Deprecated: Use BlobInfoObjectRequest.ProtoReflect.Descriptor instead.

func (*BlobInfoObjectRequest) GetBlob 

func (x *BlobInfoObjectRequest) GetBlob() *BlobInfo

func (*BlobInfoObjectRequest) GetCorrelationId 

func (x *BlobInfoObjectRequest) GetCorrelationId() string

func (*BlobInfoObjectRequest) ProtoMessage 

func (*BlobInfoObjectRequest) ProtoMessage()

func (*BlobInfoObjectRequest) ProtoReflect 

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

func (*BlobInfoObjectRequest) Reset 

func (x *BlobInfoObjectRequest) Reset()

func (*BlobInfoObjectRequest) String 

func (x *BlobInfoObjectRequest) String() string

type BlobInfoObjectsReply 

type BlobInfoObjectsReply struct {
	Error *ErrorDescription `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	Blobs []*BlobInfo       `protobuf:"bytes,2,rep,name=blobs,proto3" json:"blobs,omitempty"`
	// contains filtered or unexported fields
}

The response message containing the blob info objects response

func (*BlobInfoObjectsReply) Descriptor deprecated 

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

Deprecated: Use BlobInfoObjectsReply.ProtoReflect.Descriptor instead.

func (*BlobInfoObjectsReply) GetBlobs 

func (x *BlobInfoObjectsReply) GetBlobs() []*BlobInfo

func (*BlobInfoObjectsReply) GetError 

func (x *BlobInfoObjectsReply) GetError() *ErrorDescription

func (*BlobInfoObjectsReply) ProtoMessage 

func (*BlobInfoObjectsReply) ProtoMessage()

func (*BlobInfoObjectsReply) ProtoReflect 

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

func (*BlobInfoObjectsReply) Reset 

func (x *BlobInfoObjectsReply) Reset()

func (*BlobInfoObjectsReply) String 

func (x *BlobInfoObjectsReply) String() string

type BlobInfoPage 

type BlobInfoPage struct {
	Total int64       `protobuf:"varint,1,opt,name=total,proto3" json:"total,omitempty"`
	Data  []*BlobInfo `protobuf:"bytes,2,rep,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*BlobInfoPage) Descriptor deprecated 

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

Deprecated: Use BlobInfoPage.ProtoReflect.Descriptor instead.

func (*BlobInfoPage) GetData 

func (x *BlobInfoPage) GetData() []*BlobInfo

func (*BlobInfoPage) GetTotal 

func (x *BlobInfoPage) GetTotal() int64

func (*BlobInfoPage) ProtoMessage 

func (*BlobInfoPage) ProtoMessage()

func (*BlobInfoPage) ProtoReflect 

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

func (*BlobInfoPage) Reset 

func (x *BlobInfoPage) Reset()

func (*BlobInfoPage) String 

func (x *BlobInfoPage) String() string

type BlobInfoPageReply 

type BlobInfoPageReply struct {
	Error *ErrorDescription `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	Page  *BlobInfoPage     `protobuf:"bytes,2,opt,name=page,proto3" json:"page,omitempty"`
	// contains filtered or unexported fields
}

The response message containing the blob info page response

func (*BlobInfoPageReply) Descriptor deprecated 

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

Deprecated: Use BlobInfoPageReply.ProtoReflect.Descriptor instead.

func (*BlobInfoPageReply) GetError 

func (x *BlobInfoPageReply) GetError() *ErrorDescription

func (*BlobInfoPageReply) GetPage 

func (x *BlobInfoPageReply) GetPage() *BlobInfoPage

func (*BlobInfoPageReply) ProtoMessage 

func (*BlobInfoPageReply) ProtoMessage()

func (*BlobInfoPageReply) ProtoReflect 

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

func (*BlobInfoPageReply) Reset 

func (x *BlobInfoPageReply) Reset()

func (*BlobInfoPageReply) String 

func (x *BlobInfoPageReply) String() string

type BlobInfoPageRequest 

type BlobInfoPageRequest struct {
	CorrelationId string            `protobuf:"bytes,1,opt,name=correlation_id,json=correlationId,proto3" json:"correlation_id,omitempty"`
	Filter        map[string]string `` /* 153-byte string literal not displayed */
	Paging        *PagingParams     `protobuf:"bytes,3,opt,name=paging,proto3" json:"paging,omitempty"`
	// contains filtered or unexported fields
}

The request message containing the blob info page request.

func (*BlobInfoPageRequest) Descriptor deprecated 

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

Deprecated: Use BlobInfoPageRequest.ProtoReflect.Descriptor instead.

func (*BlobInfoPageRequest) GetCorrelationId 

func (x *BlobInfoPageRequest) GetCorrelationId() string

func (*BlobInfoPageRequest) GetFilter 

func (x *BlobInfoPageRequest) GetFilter() map[string]string

func (*BlobInfoPageRequest) GetPaging 

func (x *BlobInfoPageRequest) GetPaging() *PagingParams

func (*BlobInfoPageRequest) ProtoMessage 

func (*BlobInfoPageRequest) ProtoMessage()

func (*BlobInfoPageRequest) ProtoReflect 

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

func (*BlobInfoPageRequest) Reset 

func (x *BlobInfoPageRequest) Reset()

func (*BlobInfoPageRequest) String 

func (x *BlobInfoPageRequest) String() string

type BlobReadRequest 

type BlobReadRequest struct {
	CorrelationId string `protobuf:"bytes,1,opt,name=correlation_id,json=correlationId,proto3" json:"correlation_id,omitempty"`
	BlobId        string `protobuf:"bytes,2,opt,name=blob_id,json=blobId,proto3" json:"blob_id,omitempty"`
	Skip          int64  `protobuf:"varint,3,opt,name=skip,proto3" json:"skip,omitempty"`
	Take          int64  `protobuf:"varint,4,opt,name=take,proto3" json:"take,omitempty"`
	// contains filtered or unexported fields
}

The request message containing the blob read request.

func (*BlobReadRequest) Descriptor deprecated 

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

Deprecated: Use BlobReadRequest.ProtoReflect.Descriptor instead.

func (*BlobReadRequest) GetBlobId 

func (x *BlobReadRequest) GetBlobId() string

func (*BlobReadRequest) GetCorrelationId 

func (x *BlobReadRequest) GetCorrelationId() string

func (*BlobReadRequest) GetSkip 

func (x *BlobReadRequest) GetSkip() int64

func (*BlobReadRequest) GetTake 

func (x *BlobReadRequest) GetTake() int64

func (*BlobReadRequest) ProtoMessage 

func (*BlobReadRequest) ProtoMessage()

func (*BlobReadRequest) ProtoReflect 

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

func (*BlobReadRequest) Reset 

func (x *BlobReadRequest) Reset()

func (*BlobReadRequest) String 

func (x *BlobReadRequest) String() string

type BlobTokenReply 

type BlobTokenReply struct {
	Error *ErrorDescription `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	Token string            `protobuf:"bytes,2,opt,name=token,proto3" json:"token,omitempty"`
	// contains filtered or unexported fields
}

The response message containing the blob token response

func (*BlobTokenReply) Descriptor deprecated 

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

Deprecated: Use BlobTokenReply.ProtoReflect.Descriptor instead.

func (*BlobTokenReply) GetError 

func (x *BlobTokenReply) GetError() *ErrorDescription

func (*BlobTokenReply) GetToken 

func (x *BlobTokenReply) GetToken() string

func (*BlobTokenReply) ProtoMessage 

func (*BlobTokenReply) ProtoMessage()

func (*BlobTokenReply) ProtoReflect 

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

func (*BlobTokenReply) Reset 

func (x *BlobTokenReply) Reset()

func (*BlobTokenReply) String 

func (x *BlobTokenReply) String() string

type BlobTokenRequest 

type BlobTokenRequest struct {
	CorrelationId string `protobuf:"bytes,1,opt,name=correlation_id,json=correlationId,proto3" json:"correlation_id,omitempty"`
	Token         string `protobuf:"bytes,2,opt,name=token,proto3" json:"token,omitempty"`
	// contains filtered or unexported fields
}

The request message containing the blob token request.

func (*BlobTokenRequest) Descriptor deprecated 

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

Deprecated: Use BlobTokenRequest.ProtoReflect.Descriptor instead.

func (*BlobTokenRequest) GetCorrelationId 

func (x *BlobTokenRequest) GetCorrelationId() string

func (*BlobTokenRequest) GetToken 

func (x *BlobTokenRequest) GetToken() string

func (*BlobTokenRequest) ProtoMessage 

func (*BlobTokenRequest) ProtoMessage()

func (*BlobTokenRequest) ProtoReflect 

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

func (*BlobTokenRequest) Reset 

func (x *BlobTokenRequest) Reset()

func (*BlobTokenRequest) String 

func (x *BlobTokenRequest) String() string

type BlobTokenWithChunkRequest 

type BlobTokenWithChunkRequest struct {
	CorrelationId string `protobuf:"bytes,1,opt,name=correlation_id,json=correlationId,proto3" json:"correlation_id,omitempty"`
	Token         string `protobuf:"bytes,2,opt,name=token,proto3" json:"token,omitempty"`
	Chunk         string `protobuf:"bytes,3,opt,name=chunk,proto3" json:"chunk,omitempty"`
	// contains filtered or unexported fields
}

The request message containing the blob token with chunk request.

func (*BlobTokenWithChunkRequest) Descriptor deprecated 

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

Deprecated: Use BlobTokenWithChunkRequest.ProtoReflect.Descriptor instead.

func (*BlobTokenWithChunkRequest) GetChunk 

func (x *BlobTokenWithChunkRequest) GetChunk() string

func (*BlobTokenWithChunkRequest) GetCorrelationId 

func (x *BlobTokenWithChunkRequest) GetCorrelationId() string

func (*BlobTokenWithChunkRequest) GetToken 

func (x *BlobTokenWithChunkRequest) GetToken() string

func (*BlobTokenWithChunkRequest) ProtoMessage 

func (*BlobTokenWithChunkRequest) ProtoMessage()

func (*BlobTokenWithChunkRequest) ProtoReflect 

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

func (*BlobTokenWithChunkRequest) Reset 

func (x *BlobTokenWithChunkRequest) Reset()

func (*BlobTokenWithChunkRequest) String 

func (x *BlobTokenWithChunkRequest) String() string

type BlobUriReply 

type BlobUriReply struct {
	Error *ErrorDescription `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	Uri   string            `protobuf:"bytes,2,opt,name=uri,proto3" json:"uri,omitempty"`
	// contains filtered or unexported fields
}

The response message containing the blob uri response

func (*BlobUriReply) Descriptor deprecated 

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

Deprecated: Use BlobUriReply.ProtoReflect.Descriptor instead.

func (*BlobUriReply) GetError 

func (x *BlobUriReply) GetError() *ErrorDescription

func (*BlobUriReply) GetUri 

func (x *BlobUriReply) GetUri() string

func (*BlobUriReply) ProtoMessage 

func (*BlobUriReply) ProtoMessage()

func (*BlobUriReply) ProtoReflect 

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

func (*BlobUriReply) Reset 

func (x *BlobUriReply) Reset()

func (*BlobUriReply) String 

func (x *BlobUriReply) String() string

type BlobsClient 

type BlobsClient interface {
	GetBlobsByFilter(ctx context.Context, in *BlobInfoPageRequest, opts ...grpc.CallOption) (*BlobInfoPageReply, error)
	GetBlobsByIds(ctx context.Context, in *BlobIdsRequest, opts ...grpc.CallOption) (*BlobInfoObjectsReply, error)
	GetBlobById(ctx context.Context, in *BlobIdRequest, opts ...grpc.CallOption) (*BlobInfoObjectReply, error)
	GetBlobUriById(ctx context.Context, in *BlobIdRequest, opts ...grpc.CallOption) (*BlobUriReply, error)
	BeginBlobWrite(ctx context.Context, in *BlobInfoObjectRequest, opts ...grpc.CallOption) (*BlobTokenReply, error)
	WriteBlobChunk(ctx context.Context, in *BlobTokenWithChunkRequest, opts ...grpc.CallOption) (*BlobTokenReply, error)
	EndBlobWrite(ctx context.Context, in *BlobTokenWithChunkRequest, opts ...grpc.CallOption) (*BlobInfoObjectReply, error)
	AbortBlobWrite(ctx context.Context, in *BlobTokenRequest, opts ...grpc.CallOption) (*BlobEmptyReply, error)
	BeginBlobRead(ctx context.Context, in *BlobIdRequest, opts ...grpc.CallOption) (*BlobInfoObjectReply, error)
	ReadBlobChunk(ctx context.Context, in *BlobReadRequest, opts ...grpc.CallOption) (*BlobChunkReply, error)
	EndBlobRead(ctx context.Context, in *BlobIdRequest, opts ...grpc.CallOption) (*BlobEmptyReply, error)
	UpdateBlobInfo(ctx context.Context, in *BlobInfoObjectRequest, opts ...grpc.CallOption) (*BlobInfoObjectReply, error)
	MarkBlobsCompleted(ctx context.Context, in *BlobIdsRequest, opts ...grpc.CallOption) (*BlobEmptyReply, error)
	DeleteBlobById(ctx context.Context, in *BlobIdRequest, opts ...grpc.CallOption) (*BlobEmptyReply, error)
	DeleteBlobsByIds(ctx context.Context, in *BlobIdsRequest, opts ...grpc.CallOption) (*BlobEmptyReply, error)
}

BlobsClient is the client API for Blobs service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewBlobsClient 

func NewBlobsClient(cc grpc.ClientConnInterface) BlobsClient

type BlobsServer 

type BlobsServer interface {
	GetBlobsByFilter(context.Context, *BlobInfoPageRequest) (*BlobInfoPageReply, error)
	GetBlobsByIds(context.Context, *BlobIdsRequest) (*BlobInfoObjectsReply, error)
	GetBlobById(context.Context, *BlobIdRequest) (*BlobInfoObjectReply, error)
	GetBlobUriById(context.Context, *BlobIdRequest) (*BlobUriReply, error)
	BeginBlobWrite(context.Context, *BlobInfoObjectRequest) (*BlobTokenReply, error)
	WriteBlobChunk(context.Context, *BlobTokenWithChunkRequest) (*BlobTokenReply, error)
	EndBlobWrite(context.Context, *BlobTokenWithChunkRequest) (*BlobInfoObjectReply, error)
	AbortBlobWrite(context.Context, *BlobTokenRequest) (*BlobEmptyReply, error)
	BeginBlobRead(context.Context, *BlobIdRequest) (*BlobInfoObjectReply, error)
	ReadBlobChunk(context.Context, *BlobReadRequest) (*BlobChunkReply, error)
	EndBlobRead(context.Context, *BlobIdRequest) (*BlobEmptyReply, error)
	UpdateBlobInfo(context.Context, *BlobInfoObjectRequest) (*BlobInfoObjectReply, error)
	MarkBlobsCompleted(context.Context, *BlobIdsRequest) (*BlobEmptyReply, error)
	DeleteBlobById(context.Context, *BlobIdRequest) (*BlobEmptyReply, error)
	DeleteBlobsByIds(context.Context, *BlobIdsRequest) (*BlobEmptyReply, error)
	// contains filtered or unexported methods
}

BlobsServer is the server API for Blobs service. All implementations must embed UnimplementedBlobsServer for forward compatibility

type ErrorDescription 

type ErrorDescription struct {
	Type          string            `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Category      string            `protobuf:"bytes,2,opt,name=category,proto3" json:"category,omitempty"`
	Code          string            `protobuf:"bytes,3,opt,name=code,proto3" json:"code,omitempty"`
	CorrelationId string            `protobuf:"bytes,4,opt,name=correlation_id,json=correlationId,proto3" json:"correlation_id,omitempty"`
	Status        string            `protobuf:"bytes,5,opt,name=status,proto3" json:"status,omitempty"`
	Message       string            `protobuf:"bytes,6,opt,name=message,proto3" json:"message,omitempty"`
	Cause         string            `protobuf:"bytes,7,opt,name=cause,proto3" json:"cause,omitempty"`
	StackTrace    string            `protobuf:"bytes,8,opt,name=stack_trace,json=stackTrace,proto3" json:"stack_trace,omitempty"`
	Details       map[string]string `` /* 155-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ErrorDescription) Descriptor deprecated 

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

Deprecated: Use ErrorDescription.ProtoReflect.Descriptor instead.

func (*ErrorDescription) GetCategory 

func (x *ErrorDescription) GetCategory() string

func (*ErrorDescription) GetCause 

func (x *ErrorDescription) GetCause() string

func (*ErrorDescription) GetCode 

func (x *ErrorDescription) GetCode() string

func (*ErrorDescription) GetCorrelationId 

func (x *ErrorDescription) GetCorrelationId() string

func (*ErrorDescription) GetDetails 

func (x *ErrorDescription) GetDetails() map[string]string

func (*ErrorDescription) GetMessage 

func (x *ErrorDescription) GetMessage() string

func (*ErrorDescription) GetStackTrace 

func (x *ErrorDescription) GetStackTrace() string

func (*ErrorDescription) GetStatus 

func (x *ErrorDescription) GetStatus() string

func (*ErrorDescription) GetType 

func (x *ErrorDescription) GetType() string

func (*ErrorDescription) ProtoMessage 

func (*ErrorDescription) ProtoMessage()

func (*ErrorDescription) ProtoReflect 

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

func (*ErrorDescription) Reset 

func (x *ErrorDescription) Reset()

func (*ErrorDescription) String 

func (x *ErrorDescription) String() string

type PagingParams 

type PagingParams struct {
	Skip  int64 `protobuf:"varint,1,opt,name=skip,proto3" json:"skip,omitempty"`
	Take  int32 `protobuf:"varint,2,opt,name=take,proto3" json:"take,omitempty"`
	Total bool  `protobuf:"varint,3,opt,name=total,proto3" json:"total,omitempty"`
	// contains filtered or unexported fields
}

func (*PagingParams) Descriptor deprecated 

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

Deprecated: Use PagingParams.ProtoReflect.Descriptor instead.

func (*PagingParams) GetSkip 

func (x *PagingParams) GetSkip() int64

func (*PagingParams) GetTake 

func (x *PagingParams) GetTake() int32

func (*PagingParams) GetTotal 

func (x *PagingParams) GetTotal() bool

func (*PagingParams) ProtoMessage 

func (*PagingParams) ProtoMessage()

func (*PagingParams) ProtoReflect 

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

func (*PagingParams) Reset 

func (x *PagingParams) Reset()

func (*PagingParams) String 

func (x *PagingParams) String() string

type UnimplementedBlobsServer 

type UnimplementedBlobsServer struct {
}

UnimplementedBlobsServer must be embedded to have forward compatible implementations.

func (UnimplementedBlobsServer) AbortBlobWrite 

func (UnimplementedBlobsServer) AbortBlobWrite(context.Context, *BlobTokenRequest) (*BlobEmptyReply, error)

func (UnimplementedBlobsServer) BeginBlobRead 

func (UnimplementedBlobsServer) BeginBlobRead(context.Context, *BlobIdRequest) (*BlobInfoObjectReply, error)

func (UnimplementedBlobsServer) BeginBlobWrite 

func (UnimplementedBlobsServer) BeginBlobWrite(context.Context, *BlobInfoObjectRequest) (*BlobTokenReply, error)

func (UnimplementedBlobsServer) DeleteBlobById 

func (UnimplementedBlobsServer) DeleteBlobById(context.Context, *BlobIdRequest) (*BlobEmptyReply, error)

func (UnimplementedBlobsServer) DeleteBlobsByIds 

func (UnimplementedBlobsServer) DeleteBlobsByIds(context.Context, *BlobIdsRequest) (*BlobEmptyReply, error)

func (UnimplementedBlobsServer) EndBlobRead 

func (UnimplementedBlobsServer) EndBlobRead(context.Context, *BlobIdRequest) (*BlobEmptyReply, error)

func (UnimplementedBlobsServer) EndBlobWrite 

func (UnimplementedBlobsServer) EndBlobWrite(context.Context, *BlobTokenWithChunkRequest) (*BlobInfoObjectReply, error)

func (UnimplementedBlobsServer) GetBlobById 

func (UnimplementedBlobsServer) GetBlobById(context.Context, *BlobIdRequest) (*BlobInfoObjectReply, error)

func (UnimplementedBlobsServer) GetBlobUriById 

func (UnimplementedBlobsServer) GetBlobUriById(context.Context, *BlobIdRequest) (*BlobUriReply, error)

func (UnimplementedBlobsServer) GetBlobsByFilter 

func (UnimplementedBlobsServer) GetBlobsByFilter(context.Context, *BlobInfoPageRequest) (*BlobInfoPageReply, error)

func (UnimplementedBlobsServer) GetBlobsByIds 

func (UnimplementedBlobsServer) GetBlobsByIds(context.Context, *BlobIdsRequest) (*BlobInfoObjectsReply, error)

func (UnimplementedBlobsServer) MarkBlobsCompleted 

func (UnimplementedBlobsServer) MarkBlobsCompleted(context.Context, *BlobIdsRequest) (*BlobEmptyReply, error)

func (UnimplementedBlobsServer) ReadBlobChunk 

func (UnimplementedBlobsServer) ReadBlobChunk(context.Context, *BlobReadRequest) (*BlobChunkReply, error)

func (UnimplementedBlobsServer) UpdateBlobInfo 

func (UnimplementedBlobsServer) UpdateBlobInfo(context.Context, *BlobInfoObjectRequest) (*BlobInfoObjectReply, error)

func (UnimplementedBlobsServer) WriteBlobChunk 

func (UnimplementedBlobsServer) WriteBlobChunk(context.Context, *BlobTokenWithChunkRequest) (*BlobTokenReply, error)

type UnsafeBlobsServer 

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

UnsafeBlobsServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to BlobsServer will result in compilation errors.

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.