Code generated by protoc-gen-go-ttrpc. DO NOT EDIT. source: github.com/containerd/containerd/api/services/content/v1/content.proto

This section is empty.

var (
	WriteAction_name = map[int32]string{
		0: "STAT",
		1: "WRITE",
		2: "COMMIT",
	}
	WriteAction_value = map[string]int32{
		"STAT":   0,
		"WRITE":  1,
		"COMMIT": 2,
	}
)

Enum value maps for WriteAction.

View Source

var Content_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "containerd.services.content.v1.Content",
	HandlerType: (*ContentServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Info",
			Handler:    _Content_Info_Handler,
		},
		{
			MethodName: "Update",
			Handler:    _Content_Update_Handler,
		},
		{
			MethodName: "Delete",
			Handler:    _Content_Delete_Handler,
		},
		{
			MethodName: "Status",
			Handler:    _Content_Status_Handler,
		},
		{
			MethodName: "ListStatuses",
			Handler:    _Content_ListStatuses_Handler,
		},
		{
			MethodName: "Abort",
			Handler:    _Content_Abort_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "List",
			Handler:       _Content_List_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "Read",
			Handler:       _Content_Read_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "Write",
			Handler:       _Content_Write_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "github.com/containerd/containerd/api/services/content/v1/content.proto",
}

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

type AbortRequest struct {
	Ref string `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`

}

Deprecated: Use AbortRequest.ProtoReflect.Descriptor instead.

func (*AbortRequest) ProtoMessage()

func (x *AbortRequest) Reset()

type ContentClient ¶

type ContentClient interface {


	Info(ctx context.Context, in *InfoRequest, opts ...grpc.CallOption) (*InfoResponse, error)


	Update(ctx context.Context, in *UpdateRequest, opts ...grpc.CallOption) (*UpdateResponse, error)


	List(ctx context.Context, in *ListContentRequest, opts ...grpc.CallOption) (Content_ListClient, error)

	Delete(ctx context.Context, in *DeleteContentRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)


	Read(ctx context.Context, in *ReadContentRequest, opts ...grpc.CallOption) (Content_ReadClient, error)

	Status(ctx context.Context, in *StatusRequest, opts ...grpc.CallOption) (*StatusResponse, error)


	ListStatuses(ctx context.Context, in *ListStatusesRequest, opts ...grpc.CallOption) (*ListStatusesResponse, error)


	Write(ctx context.Context, opts ...grpc.CallOption) (Content_WriteClient, error)


	Abort(ctx context.Context, in *AbortRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

ContentClient is the client API for Content 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.

type ContentServer ¶

type ContentServer interface {


	Info(context.Context, *InfoRequest) (*InfoResponse, error)


	Update(context.Context, *UpdateRequest) (*UpdateResponse, error)


	List(*ListContentRequest, Content_ListServer) error

	Delete(context.Context, *DeleteContentRequest) (*emptypb.Empty, error)


	Read(*ReadContentRequest, Content_ReadServer) error

	Status(context.Context, *StatusRequest) (*StatusResponse, error)


	ListStatuses(context.Context, *ListStatusesRequest) (*ListStatusesResponse, error)


	Write(Content_WriteServer) error


	Abort(context.Context, *AbortRequest) (*emptypb.Empty, error)
}

ContentServer is the server API for Content service. All implementations must embed UnimplementedContentServer for forward compatibility

type DeleteContentRequest ¶

type DeleteContentRequest struct {

	Digest string `protobuf:"bytes,1,opt,name=digest,proto3" json:"digest,omitempty"`
}

func (*DeleteContentRequest) Descriptor deprecated

Deprecated: Use DeleteContentRequest.ProtoReflect.Descriptor instead.

func (*DeleteContentRequest) Reset ¶

func (x *DeleteContentRequest) Reset()

func (*DeleteContentRequest) String ¶

type Info struct {

	Digest string `protobuf:"bytes,1,opt,name=digest,proto3" json:"digest,omitempty"`

	Size int64 `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"`

	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`

	UpdatedAt *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`


	Labels map[string]string ``
}

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

Deprecated: Use Info.ProtoReflect.Descriptor instead.

func (*Info) ProtoMessage()

type InfoRequest struct {
	Digest string `protobuf:"bytes,1,opt,name=digest,proto3" json:"digest,omitempty"`

}

Deprecated: Use InfoRequest.ProtoReflect.Descriptor instead.

func (*InfoRequest) ProtoMessage()

func (x *InfoRequest) Reset()

type InfoResponse struct {
	Info *Info `protobuf:"bytes,1,opt,name=info,proto3" json:"info,omitempty"`

}

Deprecated: Use InfoResponse.ProtoReflect.Descriptor instead.

func (x *InfoResponse) GetInfo() *Info

func (*InfoResponse) ProtoMessage()

func (x *InfoResponse) Reset()

type ListContentRequest ¶

type ListContentRequest struct {


	Filters []string `protobuf:"bytes,1,rep,name=filters,proto3" json:"filters,omitempty"`
}

func (*ListContentRequest) Descriptor deprecated

Deprecated: Use ListContentRequest.ProtoReflect.Descriptor instead.

func (*ListContentRequest) Reset ¶

func (x *ListContentRequest) Reset()

func (*ListContentRequest) String ¶

type ListContentResponse ¶

type ListContentResponse struct {
	Info []*Info `protobuf:"bytes,1,rep,name=info,proto3" json:"info,omitempty"`

}

func (*ListContentResponse) Descriptor deprecated

Deprecated: Use ListContentResponse.ProtoReflect.Descriptor instead.

func (*ListContentResponse) GetInfo ¶

func (x *ListContentResponse) GetInfo() []*Info

func (*ListContentResponse) Reset ¶

func (x *ListContentResponse) Reset()

func (*ListContentResponse) String ¶

type ListStatusesRequest struct {
	Filters []string `protobuf:"bytes,1,rep,name=filters,proto3" json:"filters,omitempty"`

}

Deprecated: Use ListStatusesRequest.ProtoReflect.Descriptor instead.

func (*ListStatusesRequest) ProtoMessage()

func (x *ListStatusesRequest) Reset()

type ListStatusesResponse struct {
	Statuses []*Status `protobuf:"bytes,1,rep,name=statuses,proto3" json:"statuses,omitempty"`

}

Deprecated: Use ListStatusesResponse.ProtoReflect.Descriptor instead.

func (x *ListStatusesResponse) GetStatuses() []*Status

func (*ListStatusesResponse) ProtoMessage()

func (x *ListStatusesResponse) Reset()

type ReadContentRequest ¶

type ReadContentRequest struct {

	Digest string `protobuf:"bytes,1,opt,name=digest,proto3" json:"digest,omitempty"`


	Offset int64 `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"`


	Size int64 `protobuf:"varint,3,opt,name=size,proto3" json:"size,omitempty"`
}

ReadContentRequest defines the fields that make up a request to read a portion of data from a stored object.

func (*ReadContentRequest) Descriptor deprecated

Deprecated: Use ReadContentRequest.ProtoReflect.Descriptor instead.

func (*ReadContentRequest) Reset ¶

func (x *ReadContentRequest) Reset()

func (*ReadContentRequest) String ¶

type ReadContentResponse ¶

type ReadContentResponse struct {
	Offset int64  `protobuf:"varint,1,opt,name=offset,proto3" json:"offset,omitempty"`
	Data   []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`

}

ReadContentResponse carries byte data for a read request.

func (*ReadContentResponse) Descriptor deprecated

Deprecated: Use ReadContentResponse.ProtoReflect.Descriptor instead.

func (*ReadContentResponse) GetData ¶

func (*ReadContentResponse) Reset ¶

func (x *ReadContentResponse) Reset()

func (*ReadContentResponse) String ¶

type Status struct {
	StartedAt *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=started_at,json=startedAt,proto3" json:"started_at,omitempty"`
	UpdatedAt *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	Ref       string                 `protobuf:"bytes,3,opt,name=ref,proto3" json:"ref,omitempty"`
	Offset    int64                  `protobuf:"varint,4,opt,name=offset,proto3" json:"offset,omitempty"`
	Total     int64                  `protobuf:"varint,5,opt,name=total,proto3" json:"total,omitempty"`
	Expected  string                 `protobuf:"bytes,6,opt,name=expected,proto3" json:"expected,omitempty"`

}

Deprecated: Use Status.ProtoReflect.Descriptor instead.

func (x *Status) GetOffset() int64

func (*Status) ProtoMessage()

type StatusRequest struct {
	Ref string `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`

}

Deprecated: Use StatusRequest.ProtoReflect.Descriptor instead.

func (*StatusRequest) ProtoMessage()

func (x *StatusRequest) Reset()

type StatusResponse struct {
	Status *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`

}

Deprecated: Use StatusResponse.ProtoReflect.Descriptor instead.

func (x *StatusResponse) GetStatus() *Status

func (*StatusResponse) ProtoMessage()

func (x *StatusResponse) Reset()

type TTRPCContentClient ¶

type TTRPCContentClient interface {
	Info(context.Context, *InfoRequest) (*InfoResponse, error)
	Update(context.Context, *UpdateRequest) (*UpdateResponse, error)
	List(context.Context, *ListContentRequest) (TTRPCContent_ListClient, error)
	Delete(context.Context, *DeleteContentRequest) (*emptypb.Empty, error)
	Read(context.Context, *ReadContentRequest) (TTRPCContent_ReadClient, error)
	Status(context.Context, *StatusRequest) (*StatusResponse, error)
	ListStatuses(context.Context, *ListStatusesRequest) (*ListStatusesResponse, error)
	Write(context.Context) (TTRPCContent_WriteClient, error)
	Abort(context.Context, *AbortRequest) (*emptypb.Empty, error)
}

type TTRPCContentService ¶

type TTRPCContentService interface {
	Info(context.Context, *InfoRequest) (*InfoResponse, error)
	Update(context.Context, *UpdateRequest) (*UpdateResponse, error)
	List(context.Context, *ListContentRequest, TTRPCContent_ListServer) error
	Delete(context.Context, *DeleteContentRequest) (*emptypb.Empty, error)
	Read(context.Context, *ReadContentRequest, TTRPCContent_ReadServer) error
	Status(context.Context, *StatusRequest) (*StatusResponse, error)
	ListStatuses(context.Context, *ListStatusesRequest) (*ListStatusesResponse, error)
	Write(context.Context, TTRPCContent_WriteServer) error
	Abort(context.Context, *AbortRequest) (*emptypb.Empty, error)
}

type UnimplementedContentServer ¶

type UnimplementedContentServer struct {
}

UnimplementedContentServer must be embedded to have forward compatible implementations.

func (UnimplementedContentServer) Abort ¶

func (UnimplementedContentServer) Delete ¶

func (UnimplementedContentServer) Info ¶

func (UnimplementedContentServer) List ¶

func (UnimplementedContentServer) Read ¶

func (UnimplementedContentServer) Status ¶

func (UnimplementedContentServer) Update ¶

func (UnimplementedContentServer) Write ¶

type UnsafeContentServer ¶

type UnsafeContentServer interface {
}

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

type UpdateRequest struct {
	Info *Info `protobuf:"bytes,1,opt,name=info,proto3" json:"info,omitempty"`


	UpdateMask *fieldmaskpb.FieldMask `protobuf:"bytes,2,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"`
}

Deprecated: Use UpdateRequest.ProtoReflect.Descriptor instead.

func (x *UpdateRequest) GetInfo() *Info

func (*UpdateRequest) ProtoMessage()

func (x *UpdateRequest) Reset()

type UpdateResponse struct {
	Info *Info `protobuf:"bytes,1,opt,name=info,proto3" json:"info,omitempty"`

}

Deprecated: Use UpdateResponse.ProtoReflect.Descriptor instead.

func (x *UpdateResponse) GetInfo() *Info

func (*UpdateResponse) ProtoMessage()

func (x *UpdateResponse) Reset()

WriteAction defines the behavior of a WriteRequest.

const (


	WriteAction_STAT WriteAction = 0


	WriteAction_WRITE WriteAction = 1


	WriteAction_COMMIT WriteAction = 2
)

func (x WriteAction) Enum() *WriteAction

Deprecated: Use WriteAction.Descriptor instead.

type WriteContentRequest ¶

type WriteContentRequest struct {


	Action WriteAction `protobuf:"varint,1,opt,name=action,proto3,enum=containerd.services.content.v1.WriteAction" json:"action,omitempty"`

	Ref string `protobuf:"bytes,2,opt,name=ref,proto3" json:"ref,omitempty"`


	Total int64 `protobuf:"varint,3,opt,name=total,proto3" json:"total,omitempty"`


	Expected string `protobuf:"bytes,4,opt,name=expected,proto3" json:"expected,omitempty"`


	Offset int64 `protobuf:"varint,5,opt,name=offset,proto3" json:"offset,omitempty"`


	Data []byte `protobuf:"bytes,6,opt,name=data,proto3" json:"data,omitempty"`


	Labels map[string]string ``
}

WriteContentRequest writes data to the request ref at offset.

func (*WriteContentRequest) Descriptor deprecated

Deprecated: Use WriteContentRequest.ProtoReflect.Descriptor instead.

func (*WriteContentRequest) GetAction ¶

func (x *WriteContentRequest) GetAction() WriteAction

func (*WriteContentRequest) GetData ¶

func (*WriteContentRequest) GetRef ¶

func (*WriteContentRequest) Reset ¶

func (x *WriteContentRequest) Reset()

func (*WriteContentRequest) String ¶

type WriteContentResponse ¶

type WriteContentResponse struct {


	Action WriteAction `protobuf:"varint,1,opt,name=action,proto3,enum=containerd.services.content.v1.WriteAction" json:"action,omitempty"`


	StartedAt *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=started_at,json=startedAt,proto3" json:"started_at,omitempty"`


	UpdatedAt *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`

	Offset int64 `protobuf:"varint,4,opt,name=offset,proto3" json:"offset,omitempty"`


	Total int64 `protobuf:"varint,5,opt,name=total,proto3" json:"total,omitempty"`


	Digest string `protobuf:"bytes,6,opt,name=digest,proto3" json:"digest,omitempty"`
}

WriteContentResponse is returned on the culmination of a write call.

func (*WriteContentResponse) Descriptor deprecated

Deprecated: Use WriteContentResponse.ProtoReflect.Descriptor instead.

func (*WriteContentResponse) GetAction ¶

func (x *WriteContentResponse) GetAction() WriteAction

func (*WriteContentResponse) Reset ¶

func (x *WriteContentResponse) Reset()