Documentation ¶
Index ¶
- Variables
- func RegisterContentServer(s *grpc.Server, srv ContentServer)
- type AbortRequest
- func (*AbortRequest) Descriptor() ([]byte, []int)
- func (m *AbortRequest) Marshal() (dAtA []byte, err error)
- func (m *AbortRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *AbortRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*AbortRequest) ProtoMessage()
- func (m *AbortRequest) Reset()
- func (m *AbortRequest) Size() (n int)
- func (this *AbortRequest) String() string
- func (m *AbortRequest) Unmarshal(dAtA []byte) error
- func (m *AbortRequest) XXX_DiscardUnknown()
- func (m *AbortRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *AbortRequest) XXX_Merge(src proto.Message)
- func (m *AbortRequest) XXX_Size() int
- func (m *AbortRequest) XXX_Unmarshal(b []byte) error
- type ContentClient
- type ContentServer
- type Content_ListClient
- type Content_ListServer
- type Content_ReadClient
- type Content_ReadServer
- type Content_WriteClient
- type Content_WriteServer
- type DeleteContentRequest
- func (*DeleteContentRequest) Descriptor() ([]byte, []int)
- func (m *DeleteContentRequest) Marshal() (dAtA []byte, err error)
- func (m *DeleteContentRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *DeleteContentRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*DeleteContentRequest) ProtoMessage()
- func (m *DeleteContentRequest) Reset()
- func (m *DeleteContentRequest) Size() (n int)
- func (this *DeleteContentRequest) String() string
- func (m *DeleteContentRequest) Unmarshal(dAtA []byte) error
- func (m *DeleteContentRequest) XXX_DiscardUnknown()
- func (m *DeleteContentRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DeleteContentRequest) XXX_Merge(src proto.Message)
- func (m *DeleteContentRequest) XXX_Size() int
- func (m *DeleteContentRequest) XXX_Unmarshal(b []byte) error
- type Info
- func (*Info) Descriptor() ([]byte, []int)
- func (m *Info) Marshal() (dAtA []byte, err error)
- func (m *Info) MarshalTo(dAtA []byte) (int, error)
- func (m *Info) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Info) ProtoMessage()
- func (m *Info) Reset()
- func (m *Info) Size() (n int)
- func (this *Info) String() string
- func (m *Info) Unmarshal(dAtA []byte) error
- func (m *Info) XXX_DiscardUnknown()
- func (m *Info) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Info) XXX_Merge(src proto.Message)
- func (m *Info) XXX_Size() int
- func (m *Info) XXX_Unmarshal(b []byte) error
- type InfoRequest
- func (*InfoRequest) Descriptor() ([]byte, []int)
- func (m *InfoRequest) Marshal() (dAtA []byte, err error)
- func (m *InfoRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *InfoRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*InfoRequest) ProtoMessage()
- func (m *InfoRequest) Reset()
- func (m *InfoRequest) Size() (n int)
- func (this *InfoRequest) String() string
- func (m *InfoRequest) Unmarshal(dAtA []byte) error
- func (m *InfoRequest) XXX_DiscardUnknown()
- func (m *InfoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *InfoRequest) XXX_Merge(src proto.Message)
- func (m *InfoRequest) XXX_Size() int
- func (m *InfoRequest) XXX_Unmarshal(b []byte) error
- type InfoResponse
- func (*InfoResponse) Descriptor() ([]byte, []int)
- func (m *InfoResponse) Marshal() (dAtA []byte, err error)
- func (m *InfoResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *InfoResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*InfoResponse) ProtoMessage()
- func (m *InfoResponse) Reset()
- func (m *InfoResponse) Size() (n int)
- func (this *InfoResponse) String() string
- func (m *InfoResponse) Unmarshal(dAtA []byte) error
- func (m *InfoResponse) XXX_DiscardUnknown()
- func (m *InfoResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *InfoResponse) XXX_Merge(src proto.Message)
- func (m *InfoResponse) XXX_Size() int
- func (m *InfoResponse) XXX_Unmarshal(b []byte) error
- type ListContentRequest
- func (*ListContentRequest) Descriptor() ([]byte, []int)
- func (m *ListContentRequest) Marshal() (dAtA []byte, err error)
- func (m *ListContentRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *ListContentRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ListContentRequest) ProtoMessage()
- func (m *ListContentRequest) Reset()
- func (m *ListContentRequest) Size() (n int)
- func (this *ListContentRequest) String() string
- func (m *ListContentRequest) Unmarshal(dAtA []byte) error
- func (m *ListContentRequest) XXX_DiscardUnknown()
- func (m *ListContentRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ListContentRequest) XXX_Merge(src proto.Message)
- func (m *ListContentRequest) XXX_Size() int
- func (m *ListContentRequest) XXX_Unmarshal(b []byte) error
- type ListContentResponse
- func (*ListContentResponse) Descriptor() ([]byte, []int)
- func (m *ListContentResponse) Marshal() (dAtA []byte, err error)
- func (m *ListContentResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *ListContentResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ListContentResponse) ProtoMessage()
- func (m *ListContentResponse) Reset()
- func (m *ListContentResponse) Size() (n int)
- func (this *ListContentResponse) String() string
- func (m *ListContentResponse) Unmarshal(dAtA []byte) error
- func (m *ListContentResponse) XXX_DiscardUnknown()
- func (m *ListContentResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ListContentResponse) XXX_Merge(src proto.Message)
- func (m *ListContentResponse) XXX_Size() int
- func (m *ListContentResponse) XXX_Unmarshal(b []byte) error
- type ListStatusesRequest
- func (*ListStatusesRequest) Descriptor() ([]byte, []int)
- func (m *ListStatusesRequest) Marshal() (dAtA []byte, err error)
- func (m *ListStatusesRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *ListStatusesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ListStatusesRequest) ProtoMessage()
- func (m *ListStatusesRequest) Reset()
- func (m *ListStatusesRequest) Size() (n int)
- func (this *ListStatusesRequest) String() string
- func (m *ListStatusesRequest) Unmarshal(dAtA []byte) error
- func (m *ListStatusesRequest) XXX_DiscardUnknown()
- func (m *ListStatusesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ListStatusesRequest) XXX_Merge(src proto.Message)
- func (m *ListStatusesRequest) XXX_Size() int
- func (m *ListStatusesRequest) XXX_Unmarshal(b []byte) error
- type ListStatusesResponse
- func (*ListStatusesResponse) Descriptor() ([]byte, []int)
- func (m *ListStatusesResponse) Marshal() (dAtA []byte, err error)
- func (m *ListStatusesResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *ListStatusesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ListStatusesResponse) ProtoMessage()
- func (m *ListStatusesResponse) Reset()
- func (m *ListStatusesResponse) Size() (n int)
- func (this *ListStatusesResponse) String() string
- func (m *ListStatusesResponse) Unmarshal(dAtA []byte) error
- func (m *ListStatusesResponse) XXX_DiscardUnknown()
- func (m *ListStatusesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ListStatusesResponse) XXX_Merge(src proto.Message)
- func (m *ListStatusesResponse) XXX_Size() int
- func (m *ListStatusesResponse) XXX_Unmarshal(b []byte) error
- type ReadContentRequest
- func (*ReadContentRequest) Descriptor() ([]byte, []int)
- func (m *ReadContentRequest) Marshal() (dAtA []byte, err error)
- func (m *ReadContentRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *ReadContentRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ReadContentRequest) ProtoMessage()
- func (m *ReadContentRequest) Reset()
- func (m *ReadContentRequest) Size() (n int)
- func (this *ReadContentRequest) String() string
- func (m *ReadContentRequest) Unmarshal(dAtA []byte) error
- func (m *ReadContentRequest) XXX_DiscardUnknown()
- func (m *ReadContentRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ReadContentRequest) XXX_Merge(src proto.Message)
- func (m *ReadContentRequest) XXX_Size() int
- func (m *ReadContentRequest) XXX_Unmarshal(b []byte) error
- type ReadContentResponse
- func (*ReadContentResponse) Descriptor() ([]byte, []int)
- func (m *ReadContentResponse) Marshal() (dAtA []byte, err error)
- func (m *ReadContentResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *ReadContentResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ReadContentResponse) ProtoMessage()
- func (m *ReadContentResponse) Reset()
- func (m *ReadContentResponse) Size() (n int)
- func (this *ReadContentResponse) String() string
- func (m *ReadContentResponse) Unmarshal(dAtA []byte) error
- func (m *ReadContentResponse) XXX_DiscardUnknown()
- func (m *ReadContentResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ReadContentResponse) XXX_Merge(src proto.Message)
- func (m *ReadContentResponse) XXX_Size() int
- func (m *ReadContentResponse) XXX_Unmarshal(b []byte) error
- type Status
- func (*Status) Descriptor() ([]byte, []int)
- func (m *Status) Marshal() (dAtA []byte, err error)
- func (m *Status) MarshalTo(dAtA []byte) (int, error)
- func (m *Status) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Status) ProtoMessage()
- func (m *Status) Reset()
- func (m *Status) Size() (n int)
- func (this *Status) String() string
- func (m *Status) Unmarshal(dAtA []byte) error
- func (m *Status) XXX_DiscardUnknown()
- func (m *Status) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Status) XXX_Merge(src proto.Message)
- func (m *Status) XXX_Size() int
- func (m *Status) XXX_Unmarshal(b []byte) error
- type StatusRequest
- func (*StatusRequest) Descriptor() ([]byte, []int)
- func (m *StatusRequest) Marshal() (dAtA []byte, err error)
- func (m *StatusRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *StatusRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*StatusRequest) ProtoMessage()
- func (m *StatusRequest) Reset()
- func (m *StatusRequest) Size() (n int)
- func (this *StatusRequest) String() string
- func (m *StatusRequest) Unmarshal(dAtA []byte) error
- func (m *StatusRequest) XXX_DiscardUnknown()
- func (m *StatusRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StatusRequest) XXX_Merge(src proto.Message)
- func (m *StatusRequest) XXX_Size() int
- func (m *StatusRequest) XXX_Unmarshal(b []byte) error
- type StatusResponse
- func (*StatusResponse) Descriptor() ([]byte, []int)
- func (m *StatusResponse) Marshal() (dAtA []byte, err error)
- func (m *StatusResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *StatusResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*StatusResponse) ProtoMessage()
- func (m *StatusResponse) Reset()
- func (m *StatusResponse) Size() (n int)
- func (this *StatusResponse) String() string
- func (m *StatusResponse) Unmarshal(dAtA []byte) error
- func (m *StatusResponse) XXX_DiscardUnknown()
- func (m *StatusResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StatusResponse) XXX_Merge(src proto.Message)
- func (m *StatusResponse) XXX_Size() int
- func (m *StatusResponse) XXX_Unmarshal(b []byte) error
- type UnimplementedContentServer
- func (*UnimplementedContentServer) Abort(ctx context.Context, req *AbortRequest) (*types.Empty, error)
- func (*UnimplementedContentServer) Delete(ctx context.Context, req *DeleteContentRequest) (*types.Empty, error)
- func (*UnimplementedContentServer) Info(ctx context.Context, req *InfoRequest) (*InfoResponse, error)
- func (*UnimplementedContentServer) List(req *ListContentRequest, srv Content_ListServer) error
- func (*UnimplementedContentServer) ListStatuses(ctx context.Context, req *ListStatusesRequest) (*ListStatusesResponse, error)
- func (*UnimplementedContentServer) Read(req *ReadContentRequest, srv Content_ReadServer) error
- func (*UnimplementedContentServer) Status(ctx context.Context, req *StatusRequest) (*StatusResponse, error)
- func (*UnimplementedContentServer) Update(ctx context.Context, req *UpdateRequest) (*UpdateResponse, error)
- func (*UnimplementedContentServer) Write(srv Content_WriteServer) error
- type UpdateRequest
- func (*UpdateRequest) Descriptor() ([]byte, []int)
- func (m *UpdateRequest) Marshal() (dAtA []byte, err error)
- func (m *UpdateRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *UpdateRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*UpdateRequest) ProtoMessage()
- func (m *UpdateRequest) Reset()
- func (m *UpdateRequest) Size() (n int)
- func (this *UpdateRequest) String() string
- func (m *UpdateRequest) Unmarshal(dAtA []byte) error
- func (m *UpdateRequest) XXX_DiscardUnknown()
- func (m *UpdateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *UpdateRequest) XXX_Merge(src proto.Message)
- func (m *UpdateRequest) XXX_Size() int
- func (m *UpdateRequest) XXX_Unmarshal(b []byte) error
- type UpdateResponse
- func (*UpdateResponse) Descriptor() ([]byte, []int)
- func (m *UpdateResponse) Marshal() (dAtA []byte, err error)
- func (m *UpdateResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *UpdateResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*UpdateResponse) ProtoMessage()
- func (m *UpdateResponse) Reset()
- func (m *UpdateResponse) Size() (n int)
- func (this *UpdateResponse) String() string
- func (m *UpdateResponse) Unmarshal(dAtA []byte) error
- func (m *UpdateResponse) XXX_DiscardUnknown()
- func (m *UpdateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *UpdateResponse) XXX_Merge(src proto.Message)
- func (m *UpdateResponse) XXX_Size() int
- func (m *UpdateResponse) XXX_Unmarshal(b []byte) error
- type WriteAction
- type WriteContentRequest
- func (*WriteContentRequest) Descriptor() ([]byte, []int)
- func (m *WriteContentRequest) Marshal() (dAtA []byte, err error)
- func (m *WriteContentRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *WriteContentRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*WriteContentRequest) ProtoMessage()
- func (m *WriteContentRequest) Reset()
- func (m *WriteContentRequest) Size() (n int)
- func (this *WriteContentRequest) String() string
- func (m *WriteContentRequest) Unmarshal(dAtA []byte) error
- func (m *WriteContentRequest) XXX_DiscardUnknown()
- func (m *WriteContentRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *WriteContentRequest) XXX_Merge(src proto.Message)
- func (m *WriteContentRequest) XXX_Size() int
- func (m *WriteContentRequest) XXX_Unmarshal(b []byte) error
- type WriteContentResponse
- func (*WriteContentResponse) Descriptor() ([]byte, []int)
- func (m *WriteContentResponse) Marshal() (dAtA []byte, err error)
- func (m *WriteContentResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *WriteContentResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*WriteContentResponse) ProtoMessage()
- func (m *WriteContentResponse) Reset()
- func (m *WriteContentResponse) Size() (n int)
- func (this *WriteContentResponse) String() string
- func (m *WriteContentResponse) Unmarshal(dAtA []byte) error
- func (m *WriteContentResponse) XXX_DiscardUnknown()
- func (m *WriteContentResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *WriteContentResponse) XXX_Merge(src proto.Message)
- func (m *WriteContentResponse) XXX_Size() int
- func (m *WriteContentResponse) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
var ( ErrInvalidLengthContent = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowContent = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupContent = fmt.Errorf("proto: unexpected end of group") )
var WriteAction_name = map[int32]string{
0: "STAT",
1: "WRITE",
2: "COMMIT",
}
var WriteAction_value = map[string]int32{
"STAT": 0,
"WRITE": 1,
"COMMIT": 2,
}
Functions ¶
func RegisterContentServer ¶
func RegisterContentServer(s *grpc.Server, srv ContentServer)
Types ¶
type AbortRequest ¶
type AbortRequest struct { Ref string `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*AbortRequest) Descriptor ¶
func (*AbortRequest) Descriptor() ([]byte, []int)
func (*AbortRequest) Marshal ¶
func (m *AbortRequest) Marshal() (dAtA []byte, err error)
func (*AbortRequest) MarshalToSizedBuffer ¶
func (m *AbortRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*AbortRequest) ProtoMessage ¶
func (*AbortRequest) ProtoMessage()
func (*AbortRequest) Reset ¶
func (m *AbortRequest) Reset()
func (*AbortRequest) Size ¶
func (m *AbortRequest) Size() (n int)
func (*AbortRequest) String ¶
func (this *AbortRequest) String() string
func (*AbortRequest) Unmarshal ¶
func (m *AbortRequest) Unmarshal(dAtA []byte) error
func (*AbortRequest) XXX_DiscardUnknown ¶
func (m *AbortRequest) XXX_DiscardUnknown()
func (*AbortRequest) XXX_Marshal ¶
func (m *AbortRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*AbortRequest) XXX_Merge ¶
func (m *AbortRequest) XXX_Merge(src proto.Message)
func (*AbortRequest) XXX_Size ¶
func (m *AbortRequest) XXX_Size() int
func (*AbortRequest) XXX_Unmarshal ¶
func (m *AbortRequest) XXX_Unmarshal(b []byte) error
type ContentClient ¶
type ContentClient interface { // Info returns information about a committed object. // // This call can be used for getting the size of content and checking for // existence. Info(ctx context.Context, in *InfoRequest, opts ...grpc.CallOption) (*InfoResponse, error) // Update updates content metadata. // // This call can be used to manage the mutable content labels. The // immutable metadata such as digest, size, and committed at cannot // be updated. Update(ctx context.Context, in *UpdateRequest, opts ...grpc.CallOption) (*UpdateResponse, error) // List streams the entire set of content as Info objects and closes the // stream. // // Typically, this will yield a large response, chunked into messages. // Clients should make provisions to ensure they can handle the entire data // set. List(ctx context.Context, in *ListContentRequest, opts ...grpc.CallOption) (Content_ListClient, error) // Delete will delete the referenced object. Delete(ctx context.Context, in *DeleteContentRequest, opts ...grpc.CallOption) (*types.Empty, error) // Read allows one to read an object based on the offset into the content. // // The requested data may be returned in one or more messages. Read(ctx context.Context, in *ReadContentRequest, opts ...grpc.CallOption) (Content_ReadClient, error) // Status returns the status for a single reference. Status(ctx context.Context, in *StatusRequest, opts ...grpc.CallOption) (*StatusResponse, error) // ListStatuses returns the status of ongoing object ingestions, started via // Write. // // Only those matching the regular expression will be provided in the // response. If the provided regular expression is empty, all ingestions // will be provided. ListStatuses(ctx context.Context, in *ListStatusesRequest, opts ...grpc.CallOption) (*ListStatusesResponse, error) // Write begins or resumes writes to a resource identified by a unique ref. // Only one active stream may exist at a time for each ref. // // Once a write stream has started, it may only write to a single ref, thus // once a stream is started, the ref may be omitted on subsequent writes. // // For any write transaction represented by a ref, only a single write may // be made to a given offset. If overlapping writes occur, it is an error. // Writes should be sequential and implementations may throw an error if // this is required. // // If expected_digest is set and already part of the content store, the // write will fail. // // When completed, the commit flag should be set to true. If expected size // or digest is set, the content will be validated against those values. Write(ctx context.Context, opts ...grpc.CallOption) (Content_WriteClient, error) // Abort cancels the ongoing write named in the request. Any resources // associated with the write will be collected. Abort(ctx context.Context, in *AbortRequest, opts ...grpc.CallOption) (*types.Empty, error) }
ContentClient is the client API for Content service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewContentClient ¶
func NewContentClient(cc *grpc.ClientConn) ContentClient
type ContentServer ¶
type ContentServer interface { // Info returns information about a committed object. // // This call can be used for getting the size of content and checking for // existence. Info(context.Context, *InfoRequest) (*InfoResponse, error) // Update updates content metadata. // // This call can be used to manage the mutable content labels. The // immutable metadata such as digest, size, and committed at cannot // be updated. Update(context.Context, *UpdateRequest) (*UpdateResponse, error) // List streams the entire set of content as Info objects and closes the // stream. // // Typically, this will yield a large response, chunked into messages. // Clients should make provisions to ensure they can handle the entire data // set. List(*ListContentRequest, Content_ListServer) error // Delete will delete the referenced object. Delete(context.Context, *DeleteContentRequest) (*types.Empty, error) // Read allows one to read an object based on the offset into the content. // // The requested data may be returned in one or more messages. Read(*ReadContentRequest, Content_ReadServer) error // Status returns the status for a single reference. Status(context.Context, *StatusRequest) (*StatusResponse, error) // ListStatuses returns the status of ongoing object ingestions, started via // Write. // // Only those matching the regular expression will be provided in the // response. If the provided regular expression is empty, all ingestions // will be provided. ListStatuses(context.Context, *ListStatusesRequest) (*ListStatusesResponse, error) // Write begins or resumes writes to a resource identified by a unique ref. // Only one active stream may exist at a time for each ref. // // Once a write stream has started, it may only write to a single ref, thus // once a stream is started, the ref may be omitted on subsequent writes. // // For any write transaction represented by a ref, only a single write may // be made to a given offset. If overlapping writes occur, it is an error. // Writes should be sequential and implementations may throw an error if // this is required. // // If expected_digest is set and already part of the content store, the // write will fail. // // When completed, the commit flag should be set to true. If expected size // or digest is set, the content will be validated against those values. Write(Content_WriteServer) error // Abort cancels the ongoing write named in the request. Any resources // associated with the write will be collected. Abort(context.Context, *AbortRequest) (*types.Empty, error) }
ContentServer is the server API for Content service.
type Content_ListClient ¶
type Content_ListClient interface { Recv() (*ListContentResponse, error) grpc.ClientStream }
type Content_ListServer ¶
type Content_ListServer interface { Send(*ListContentResponse) error grpc.ServerStream }
type Content_ReadClient ¶
type Content_ReadClient interface { Recv() (*ReadContentResponse, error) grpc.ClientStream }
type Content_ReadServer ¶
type Content_ReadServer interface { Send(*ReadContentResponse) error grpc.ServerStream }
type Content_WriteClient ¶
type Content_WriteClient interface { Send(*WriteContentRequest) error Recv() (*WriteContentResponse, error) grpc.ClientStream }
type Content_WriteServer ¶
type Content_WriteServer interface { Send(*WriteContentResponse) error Recv() (*WriteContentRequest, error) grpc.ServerStream }
type DeleteContentRequest ¶
type DeleteContentRequest struct { // Digest specifies which content to delete. Digest github_com_opencontainers_go_digest.Digest `protobuf:"bytes,1,opt,name=digest,proto3,customtype=github.com/opencontainers/go-digest.Digest" json:"digest"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*DeleteContentRequest) Descriptor ¶
func (*DeleteContentRequest) Descriptor() ([]byte, []int)
func (*DeleteContentRequest) Marshal ¶
func (m *DeleteContentRequest) Marshal() (dAtA []byte, err error)
func (*DeleteContentRequest) MarshalTo ¶
func (m *DeleteContentRequest) MarshalTo(dAtA []byte) (int, error)
func (*DeleteContentRequest) MarshalToSizedBuffer ¶
func (m *DeleteContentRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*DeleteContentRequest) ProtoMessage ¶
func (*DeleteContentRequest) ProtoMessage()
func (*DeleteContentRequest) Reset ¶
func (m *DeleteContentRequest) Reset()
func (*DeleteContentRequest) Size ¶
func (m *DeleteContentRequest) Size() (n int)
func (*DeleteContentRequest) String ¶
func (this *DeleteContentRequest) String() string
func (*DeleteContentRequest) Unmarshal ¶
func (m *DeleteContentRequest) Unmarshal(dAtA []byte) error
func (*DeleteContentRequest) XXX_DiscardUnknown ¶
func (m *DeleteContentRequest) XXX_DiscardUnknown()
func (*DeleteContentRequest) XXX_Marshal ¶
func (m *DeleteContentRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DeleteContentRequest) XXX_Merge ¶
func (m *DeleteContentRequest) XXX_Merge(src proto.Message)
func (*DeleteContentRequest) XXX_Size ¶
func (m *DeleteContentRequest) XXX_Size() int
func (*DeleteContentRequest) XXX_Unmarshal ¶
func (m *DeleteContentRequest) XXX_Unmarshal(b []byte) error
type Info ¶
type Info struct { // Digest is the hash identity of the blob. Digest github_com_opencontainers_go_digest.Digest `protobuf:"bytes,1,opt,name=digest,proto3,customtype=github.com/opencontainers/go-digest.Digest" json:"digest"` // Size is the total number of bytes in the blob. Size_ int64 `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"` // CreatedAt provides the time at which the blob was committed. CreatedAt time.Time `protobuf:"bytes,3,opt,name=created_at,json=createdAt,proto3,stdtime" json:"created_at"` // UpdatedAt provides the time the info was last updated. UpdatedAt time.Time `protobuf:"bytes,4,opt,name=updated_at,json=updatedAt,proto3,stdtime" json:"updated_at"` // Labels are arbitrary data on snapshots. // // The combined size of a key/value pair cannot exceed 4096 bytes. Labels map[string]string `` /* 153-byte string literal not displayed */ XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Info) Descriptor ¶
func (*Info) ProtoMessage ¶
func (*Info) ProtoMessage()
func (*Info) XXX_DiscardUnknown ¶
func (m *Info) XXX_DiscardUnknown()
func (*Info) XXX_Unmarshal ¶
type InfoRequest ¶
type InfoRequest struct { Digest github_com_opencontainers_go_digest.Digest `protobuf:"bytes,1,opt,name=digest,proto3,customtype=github.com/opencontainers/go-digest.Digest" json:"digest"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*InfoRequest) Descriptor ¶
func (*InfoRequest) Descriptor() ([]byte, []int)
func (*InfoRequest) Marshal ¶
func (m *InfoRequest) Marshal() (dAtA []byte, err error)
func (*InfoRequest) MarshalToSizedBuffer ¶
func (m *InfoRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*InfoRequest) ProtoMessage ¶
func (*InfoRequest) ProtoMessage()
func (*InfoRequest) Reset ¶
func (m *InfoRequest) Reset()
func (*InfoRequest) Size ¶
func (m *InfoRequest) Size() (n int)
func (*InfoRequest) String ¶
func (this *InfoRequest) String() string
func (*InfoRequest) Unmarshal ¶
func (m *InfoRequest) Unmarshal(dAtA []byte) error
func (*InfoRequest) XXX_DiscardUnknown ¶
func (m *InfoRequest) XXX_DiscardUnknown()
func (*InfoRequest) XXX_Marshal ¶
func (m *InfoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*InfoRequest) XXX_Merge ¶
func (m *InfoRequest) XXX_Merge(src proto.Message)
func (*InfoRequest) XXX_Size ¶
func (m *InfoRequest) XXX_Size() int
func (*InfoRequest) XXX_Unmarshal ¶
func (m *InfoRequest) XXX_Unmarshal(b []byte) error
type InfoResponse ¶
type InfoResponse struct { Info Info `protobuf:"bytes,1,opt,name=info,proto3" json:"info"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*InfoResponse) Descriptor ¶
func (*InfoResponse) Descriptor() ([]byte, []int)
func (*InfoResponse) Marshal ¶
func (m *InfoResponse) Marshal() (dAtA []byte, err error)
func (*InfoResponse) MarshalToSizedBuffer ¶
func (m *InfoResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*InfoResponse) ProtoMessage ¶
func (*InfoResponse) ProtoMessage()
func (*InfoResponse) Reset ¶
func (m *InfoResponse) Reset()
func (*InfoResponse) Size ¶
func (m *InfoResponse) Size() (n int)
func (*InfoResponse) String ¶
func (this *InfoResponse) String() string
func (*InfoResponse) Unmarshal ¶
func (m *InfoResponse) Unmarshal(dAtA []byte) error
func (*InfoResponse) XXX_DiscardUnknown ¶
func (m *InfoResponse) XXX_DiscardUnknown()
func (*InfoResponse) XXX_Marshal ¶
func (m *InfoResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*InfoResponse) XXX_Merge ¶
func (m *InfoResponse) XXX_Merge(src proto.Message)
func (*InfoResponse) XXX_Size ¶
func (m *InfoResponse) XXX_Size() int
func (*InfoResponse) XXX_Unmarshal ¶
func (m *InfoResponse) XXX_Unmarshal(b []byte) error
type ListContentRequest ¶
type ListContentRequest struct { // Filters contains one or more filters using the syntax defined in the // containerd filter package. // // The returned result will be those that match any of the provided // filters. Expanded, containers that match the following will be // returned: // // filters[0] or filters[1] or ... or filters[n-1] or filters[n] // // If filters is zero-length or nil, all items will be returned. Filters []string `protobuf:"bytes,1,rep,name=filters,proto3" json:"filters,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ListContentRequest) Descriptor ¶
func (*ListContentRequest) Descriptor() ([]byte, []int)
func (*ListContentRequest) Marshal ¶
func (m *ListContentRequest) Marshal() (dAtA []byte, err error)
func (*ListContentRequest) MarshalTo ¶
func (m *ListContentRequest) MarshalTo(dAtA []byte) (int, error)
func (*ListContentRequest) MarshalToSizedBuffer ¶
func (m *ListContentRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ListContentRequest) ProtoMessage ¶
func (*ListContentRequest) ProtoMessage()
func (*ListContentRequest) Reset ¶
func (m *ListContentRequest) Reset()
func (*ListContentRequest) Size ¶
func (m *ListContentRequest) Size() (n int)
func (*ListContentRequest) String ¶
func (this *ListContentRequest) String() string
func (*ListContentRequest) Unmarshal ¶
func (m *ListContentRequest) Unmarshal(dAtA []byte) error
func (*ListContentRequest) XXX_DiscardUnknown ¶
func (m *ListContentRequest) XXX_DiscardUnknown()
func (*ListContentRequest) XXX_Marshal ¶
func (m *ListContentRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ListContentRequest) XXX_Merge ¶
func (m *ListContentRequest) XXX_Merge(src proto.Message)
func (*ListContentRequest) XXX_Size ¶
func (m *ListContentRequest) XXX_Size() int
func (*ListContentRequest) XXX_Unmarshal ¶
func (m *ListContentRequest) XXX_Unmarshal(b []byte) error
type ListContentResponse ¶
type ListContentResponse struct { Info []Info `protobuf:"bytes,1,rep,name=info,proto3" json:"info"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ListContentResponse) Descriptor ¶
func (*ListContentResponse) Descriptor() ([]byte, []int)
func (*ListContentResponse) Marshal ¶
func (m *ListContentResponse) Marshal() (dAtA []byte, err error)
func (*ListContentResponse) MarshalTo ¶
func (m *ListContentResponse) MarshalTo(dAtA []byte) (int, error)
func (*ListContentResponse) MarshalToSizedBuffer ¶
func (m *ListContentResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ListContentResponse) ProtoMessage ¶
func (*ListContentResponse) ProtoMessage()
func (*ListContentResponse) Reset ¶
func (m *ListContentResponse) Reset()
func (*ListContentResponse) Size ¶
func (m *ListContentResponse) Size() (n int)
func (*ListContentResponse) String ¶
func (this *ListContentResponse) String() string
func (*ListContentResponse) Unmarshal ¶
func (m *ListContentResponse) Unmarshal(dAtA []byte) error
func (*ListContentResponse) XXX_DiscardUnknown ¶
func (m *ListContentResponse) XXX_DiscardUnknown()
func (*ListContentResponse) XXX_Marshal ¶
func (m *ListContentResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ListContentResponse) XXX_Merge ¶
func (m *ListContentResponse) XXX_Merge(src proto.Message)
func (*ListContentResponse) XXX_Size ¶
func (m *ListContentResponse) XXX_Size() int
func (*ListContentResponse) XXX_Unmarshal ¶
func (m *ListContentResponse) XXX_Unmarshal(b []byte) error
type ListStatusesRequest ¶
type ListStatusesRequest struct { Filters []string `protobuf:"bytes,1,rep,name=filters,proto3" json:"filters,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ListStatusesRequest) Descriptor ¶
func (*ListStatusesRequest) Descriptor() ([]byte, []int)
func (*ListStatusesRequest) Marshal ¶
func (m *ListStatusesRequest) Marshal() (dAtA []byte, err error)
func (*ListStatusesRequest) MarshalTo ¶
func (m *ListStatusesRequest) MarshalTo(dAtA []byte) (int, error)
func (*ListStatusesRequest) MarshalToSizedBuffer ¶
func (m *ListStatusesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ListStatusesRequest) ProtoMessage ¶
func (*ListStatusesRequest) ProtoMessage()
func (*ListStatusesRequest) Reset ¶
func (m *ListStatusesRequest) Reset()
func (*ListStatusesRequest) Size ¶
func (m *ListStatusesRequest) Size() (n int)
func (*ListStatusesRequest) String ¶
func (this *ListStatusesRequest) String() string
func (*ListStatusesRequest) Unmarshal ¶
func (m *ListStatusesRequest) Unmarshal(dAtA []byte) error
func (*ListStatusesRequest) XXX_DiscardUnknown ¶
func (m *ListStatusesRequest) XXX_DiscardUnknown()
func (*ListStatusesRequest) XXX_Marshal ¶
func (m *ListStatusesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ListStatusesRequest) XXX_Merge ¶
func (m *ListStatusesRequest) XXX_Merge(src proto.Message)
func (*ListStatusesRequest) XXX_Size ¶
func (m *ListStatusesRequest) XXX_Size() int
func (*ListStatusesRequest) XXX_Unmarshal ¶
func (m *ListStatusesRequest) XXX_Unmarshal(b []byte) error
type ListStatusesResponse ¶
type ListStatusesResponse struct { Statuses []Status `protobuf:"bytes,1,rep,name=statuses,proto3" json:"statuses"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ListStatusesResponse) Descriptor ¶
func (*ListStatusesResponse) Descriptor() ([]byte, []int)
func (*ListStatusesResponse) Marshal ¶
func (m *ListStatusesResponse) Marshal() (dAtA []byte, err error)
func (*ListStatusesResponse) MarshalTo ¶
func (m *ListStatusesResponse) MarshalTo(dAtA []byte) (int, error)
func (*ListStatusesResponse) MarshalToSizedBuffer ¶
func (m *ListStatusesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ListStatusesResponse) ProtoMessage ¶
func (*ListStatusesResponse) ProtoMessage()
func (*ListStatusesResponse) Reset ¶
func (m *ListStatusesResponse) Reset()
func (*ListStatusesResponse) Size ¶
func (m *ListStatusesResponse) Size() (n int)
func (*ListStatusesResponse) String ¶
func (this *ListStatusesResponse) String() string
func (*ListStatusesResponse) Unmarshal ¶
func (m *ListStatusesResponse) Unmarshal(dAtA []byte) error
func (*ListStatusesResponse) XXX_DiscardUnknown ¶
func (m *ListStatusesResponse) XXX_DiscardUnknown()
func (*ListStatusesResponse) XXX_Marshal ¶
func (m *ListStatusesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ListStatusesResponse) XXX_Merge ¶
func (m *ListStatusesResponse) XXX_Merge(src proto.Message)
func (*ListStatusesResponse) XXX_Size ¶
func (m *ListStatusesResponse) XXX_Size() int
func (*ListStatusesResponse) XXX_Unmarshal ¶
func (m *ListStatusesResponse) XXX_Unmarshal(b []byte) error
type ReadContentRequest ¶
type ReadContentRequest struct { // Digest is the hash identity to read. Digest github_com_opencontainers_go_digest.Digest `protobuf:"bytes,1,opt,name=digest,proto3,customtype=github.com/opencontainers/go-digest.Digest" json:"digest"` // Offset specifies the number of bytes from the start at which to begin // the read. If zero or less, the read will be from the start. This uses // standard zero-indexed semantics. Offset int64 `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"` // size is the total size of the read. If zero, the entire blob will be // returned by the service. Size_ int64 `protobuf:"varint,3,opt,name=size,proto3" json:"size,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
ReadContentRequest defines the fields that make up a request to read a portion of data from a stored object.
func (*ReadContentRequest) Descriptor ¶
func (*ReadContentRequest) Descriptor() ([]byte, []int)
func (*ReadContentRequest) Marshal ¶
func (m *ReadContentRequest) Marshal() (dAtA []byte, err error)
func (*ReadContentRequest) MarshalTo ¶
func (m *ReadContentRequest) MarshalTo(dAtA []byte) (int, error)
func (*ReadContentRequest) MarshalToSizedBuffer ¶
func (m *ReadContentRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ReadContentRequest) ProtoMessage ¶
func (*ReadContentRequest) ProtoMessage()
func (*ReadContentRequest) Reset ¶
func (m *ReadContentRequest) Reset()
func (*ReadContentRequest) Size ¶
func (m *ReadContentRequest) Size() (n int)
func (*ReadContentRequest) String ¶
func (this *ReadContentRequest) String() string
func (*ReadContentRequest) Unmarshal ¶
func (m *ReadContentRequest) Unmarshal(dAtA []byte) error
func (*ReadContentRequest) XXX_DiscardUnknown ¶
func (m *ReadContentRequest) XXX_DiscardUnknown()
func (*ReadContentRequest) XXX_Marshal ¶
func (m *ReadContentRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ReadContentRequest) XXX_Merge ¶
func (m *ReadContentRequest) XXX_Merge(src proto.Message)
func (*ReadContentRequest) XXX_Size ¶
func (m *ReadContentRequest) XXX_Size() int
func (*ReadContentRequest) XXX_Unmarshal ¶
func (m *ReadContentRequest) XXX_Unmarshal(b []byte) error
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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
ReadContentResponse carries byte data for a read request.
func (*ReadContentResponse) Descriptor ¶
func (*ReadContentResponse) Descriptor() ([]byte, []int)
func (*ReadContentResponse) Marshal ¶
func (m *ReadContentResponse) Marshal() (dAtA []byte, err error)
func (*ReadContentResponse) MarshalTo ¶
func (m *ReadContentResponse) MarshalTo(dAtA []byte) (int, error)
func (*ReadContentResponse) MarshalToSizedBuffer ¶
func (m *ReadContentResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ReadContentResponse) ProtoMessage ¶
func (*ReadContentResponse) ProtoMessage()
func (*ReadContentResponse) Reset ¶
func (m *ReadContentResponse) Reset()
func (*ReadContentResponse) Size ¶
func (m *ReadContentResponse) Size() (n int)
func (*ReadContentResponse) String ¶
func (this *ReadContentResponse) String() string
func (*ReadContentResponse) Unmarshal ¶
func (m *ReadContentResponse) Unmarshal(dAtA []byte) error
func (*ReadContentResponse) XXX_DiscardUnknown ¶
func (m *ReadContentResponse) XXX_DiscardUnknown()
func (*ReadContentResponse) XXX_Marshal ¶
func (m *ReadContentResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ReadContentResponse) XXX_Merge ¶
func (m *ReadContentResponse) XXX_Merge(src proto.Message)
func (*ReadContentResponse) XXX_Size ¶
func (m *ReadContentResponse) XXX_Size() int
func (*ReadContentResponse) XXX_Unmarshal ¶
func (m *ReadContentResponse) XXX_Unmarshal(b []byte) error
type Status ¶
type Status struct { StartedAt time.Time `protobuf:"bytes,1,opt,name=started_at,json=startedAt,proto3,stdtime" json:"started_at"` UpdatedAt time.Time `protobuf:"bytes,2,opt,name=updated_at,json=updatedAt,proto3,stdtime" json:"updated_at"` 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 github_com_opencontainers_go_digest.Digest `protobuf:"bytes,6,opt,name=expected,proto3,customtype=github.com/opencontainers/go-digest.Digest" json:"expected"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Status) Descriptor ¶
func (*Status) MarshalToSizedBuffer ¶
func (*Status) ProtoMessage ¶
func (*Status) ProtoMessage()
func (*Status) XXX_DiscardUnknown ¶
func (m *Status) XXX_DiscardUnknown()
func (*Status) XXX_Marshal ¶
func (*Status) XXX_Unmarshal ¶
type StatusRequest ¶
type StatusRequest struct { Ref string `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*StatusRequest) Descriptor ¶
func (*StatusRequest) Descriptor() ([]byte, []int)
func (*StatusRequest) Marshal ¶
func (m *StatusRequest) Marshal() (dAtA []byte, err error)
func (*StatusRequest) MarshalToSizedBuffer ¶
func (m *StatusRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*StatusRequest) ProtoMessage ¶
func (*StatusRequest) ProtoMessage()
func (*StatusRequest) Reset ¶
func (m *StatusRequest) Reset()
func (*StatusRequest) Size ¶
func (m *StatusRequest) Size() (n int)
func (*StatusRequest) String ¶
func (this *StatusRequest) String() string
func (*StatusRequest) Unmarshal ¶
func (m *StatusRequest) Unmarshal(dAtA []byte) error
func (*StatusRequest) XXX_DiscardUnknown ¶
func (m *StatusRequest) XXX_DiscardUnknown()
func (*StatusRequest) XXX_Marshal ¶
func (m *StatusRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StatusRequest) XXX_Merge ¶
func (m *StatusRequest) XXX_Merge(src proto.Message)
func (*StatusRequest) XXX_Size ¶
func (m *StatusRequest) XXX_Size() int
func (*StatusRequest) XXX_Unmarshal ¶
func (m *StatusRequest) XXX_Unmarshal(b []byte) error
type StatusResponse ¶
type StatusResponse struct { Status *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*StatusResponse) Descriptor ¶
func (*StatusResponse) Descriptor() ([]byte, []int)
func (*StatusResponse) Marshal ¶
func (m *StatusResponse) Marshal() (dAtA []byte, err error)
func (*StatusResponse) MarshalToSizedBuffer ¶
func (m *StatusResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*StatusResponse) ProtoMessage ¶
func (*StatusResponse) ProtoMessage()
func (*StatusResponse) Reset ¶
func (m *StatusResponse) Reset()
func (*StatusResponse) Size ¶
func (m *StatusResponse) Size() (n int)
func (*StatusResponse) String ¶
func (this *StatusResponse) String() string
func (*StatusResponse) Unmarshal ¶
func (m *StatusResponse) Unmarshal(dAtA []byte) error
func (*StatusResponse) XXX_DiscardUnknown ¶
func (m *StatusResponse) XXX_DiscardUnknown()
func (*StatusResponse) XXX_Marshal ¶
func (m *StatusResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StatusResponse) XXX_Merge ¶
func (m *StatusResponse) XXX_Merge(src proto.Message)
func (*StatusResponse) XXX_Size ¶
func (m *StatusResponse) XXX_Size() int
func (*StatusResponse) XXX_Unmarshal ¶
func (m *StatusResponse) XXX_Unmarshal(b []byte) error
type UnimplementedContentServer ¶
type UnimplementedContentServer struct { }
UnimplementedContentServer can be embedded to have forward compatible implementations.
func (*UnimplementedContentServer) Abort ¶
func (*UnimplementedContentServer) Abort(ctx context.Context, req *AbortRequest) (*types.Empty, error)
func (*UnimplementedContentServer) Delete ¶
func (*UnimplementedContentServer) Delete(ctx context.Context, req *DeleteContentRequest) (*types.Empty, error)
func (*UnimplementedContentServer) Info ¶
func (*UnimplementedContentServer) Info(ctx context.Context, req *InfoRequest) (*InfoResponse, error)
func (*UnimplementedContentServer) List ¶
func (*UnimplementedContentServer) List(req *ListContentRequest, srv Content_ListServer) error
func (*UnimplementedContentServer) ListStatuses ¶
func (*UnimplementedContentServer) ListStatuses(ctx context.Context, req *ListStatusesRequest) (*ListStatusesResponse, error)
func (*UnimplementedContentServer) Read ¶
func (*UnimplementedContentServer) Read(req *ReadContentRequest, srv Content_ReadServer) error
func (*UnimplementedContentServer) Status ¶
func (*UnimplementedContentServer) Status(ctx context.Context, req *StatusRequest) (*StatusResponse, error)
func (*UnimplementedContentServer) Update ¶
func (*UnimplementedContentServer) Update(ctx context.Context, req *UpdateRequest) (*UpdateResponse, error)
func (*UnimplementedContentServer) Write ¶
func (*UnimplementedContentServer) Write(srv Content_WriteServer) error
type UpdateRequest ¶
type UpdateRequest struct { Info Info `protobuf:"bytes,1,opt,name=info,proto3" json:"info"` // UpdateMask specifies which fields to perform the update on. If empty, // the operation applies to all fields. // // In info, Digest, Size, and CreatedAt are immutable, // other field may be updated using this mask. // If no mask is provided, all mutable field are updated. UpdateMask *types.FieldMask `protobuf:"bytes,2,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*UpdateRequest) Descriptor ¶
func (*UpdateRequest) Descriptor() ([]byte, []int)
func (*UpdateRequest) Marshal ¶
func (m *UpdateRequest) Marshal() (dAtA []byte, err error)
func (*UpdateRequest) MarshalToSizedBuffer ¶
func (m *UpdateRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*UpdateRequest) ProtoMessage ¶
func (*UpdateRequest) ProtoMessage()
func (*UpdateRequest) Reset ¶
func (m *UpdateRequest) Reset()
func (*UpdateRequest) Size ¶
func (m *UpdateRequest) Size() (n int)
func (*UpdateRequest) String ¶
func (this *UpdateRequest) String() string
func (*UpdateRequest) Unmarshal ¶
func (m *UpdateRequest) Unmarshal(dAtA []byte) error
func (*UpdateRequest) XXX_DiscardUnknown ¶
func (m *UpdateRequest) XXX_DiscardUnknown()
func (*UpdateRequest) XXX_Marshal ¶
func (m *UpdateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*UpdateRequest) XXX_Merge ¶
func (m *UpdateRequest) XXX_Merge(src proto.Message)
func (*UpdateRequest) XXX_Size ¶
func (m *UpdateRequest) XXX_Size() int
func (*UpdateRequest) XXX_Unmarshal ¶
func (m *UpdateRequest) XXX_Unmarshal(b []byte) error
type UpdateResponse ¶
type UpdateResponse struct { Info Info `protobuf:"bytes,1,opt,name=info,proto3" json:"info"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*UpdateResponse) Descriptor ¶
func (*UpdateResponse) Descriptor() ([]byte, []int)
func (*UpdateResponse) Marshal ¶
func (m *UpdateResponse) Marshal() (dAtA []byte, err error)
func (*UpdateResponse) MarshalToSizedBuffer ¶
func (m *UpdateResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*UpdateResponse) ProtoMessage ¶
func (*UpdateResponse) ProtoMessage()
func (*UpdateResponse) Reset ¶
func (m *UpdateResponse) Reset()
func (*UpdateResponse) Size ¶
func (m *UpdateResponse) Size() (n int)
func (*UpdateResponse) String ¶
func (this *UpdateResponse) String() string
func (*UpdateResponse) Unmarshal ¶
func (m *UpdateResponse) Unmarshal(dAtA []byte) error
func (*UpdateResponse) XXX_DiscardUnknown ¶
func (m *UpdateResponse) XXX_DiscardUnknown()
func (*UpdateResponse) XXX_Marshal ¶
func (m *UpdateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*UpdateResponse) XXX_Merge ¶
func (m *UpdateResponse) XXX_Merge(src proto.Message)
func (*UpdateResponse) XXX_Size ¶
func (m *UpdateResponse) XXX_Size() int
func (*UpdateResponse) XXX_Unmarshal ¶
func (m *UpdateResponse) XXX_Unmarshal(b []byte) error
type WriteAction ¶
type WriteAction int32
WriteAction defines the behavior of a WriteRequest.
const ( // WriteActionStat instructs the writer to return the current status while // holding the lock on the write. WriteActionStat WriteAction = 0 // WriteActionWrite sets the action for the write request to write data. // // Any data included will be written at the provided offset. The // transaction will be left open for further writes. // // This is the default. WriteActionWrite WriteAction = 1 // WriteActionCommit will write any outstanding data in the message and // commit the write, storing it under the digest. // // This can be used in a single message to send the data, verify it and // commit it. // // This action will always terminate the write. WriteActionCommit WriteAction = 2 )
func (WriteAction) EnumDescriptor ¶
func (WriteAction) EnumDescriptor() ([]byte, []int)
func (WriteAction) String ¶
func (x WriteAction) String() string
type WriteContentRequest ¶
type WriteContentRequest struct { // Action sets the behavior of the write. // // When this is a write and the ref is not yet allocated, the ref will be // allocated and the data will be written at offset. // // If the action is write and the ref is allocated, it will accept data to // an offset that has not yet been written. // // If the action is write and there is no data, the current write status // will be returned. This works differently from status because the stream // holds a lock. Action WriteAction `protobuf:"varint,1,opt,name=action,proto3,enum=containerd.services.content.v1.WriteAction" json:"action,omitempty"` // Ref identifies the pre-commit object to write to. Ref string `protobuf:"bytes,2,opt,name=ref,proto3" json:"ref,omitempty"` // Total can be set to have the service validate the total size of the // committed content. // // The latest value before or with the commit action message will be use to // validate the content. If the offset overflows total, the service may // report an error. It is only required on one message for the write. // // If the value is zero or less, no validation of the final content will be // performed. Total int64 `protobuf:"varint,3,opt,name=total,proto3" json:"total,omitempty"` // Expected can be set to have the service validate the final content against // the provided digest. // // If the digest is already present in the object store, an AlreadyExists // error will be returned. // // Only the latest version will be used to check the content against the // digest. It is only required to include it on a single message, before or // with the commit action message. Expected github_com_opencontainers_go_digest.Digest `protobuf:"bytes,4,opt,name=expected,proto3,customtype=github.com/opencontainers/go-digest.Digest" json:"expected"` // Offset specifies the number of bytes from the start at which to begin // the write. For most implementations, this means from the start of the // file. This uses standard, zero-indexed semantics. // // If the action is write, the remote may remove all previously written // data after the offset. Implementations may support arbitrary offsets but // MUST support reseting this value to zero with a write. If an // implementation does not support a write at a particular offset, an // OutOfRange error must be returned. Offset int64 `protobuf:"varint,5,opt,name=offset,proto3" json:"offset,omitempty"` // Data is the actual bytes to be written. // // If this is empty and the message is not a commit, a response will be // returned with the current write state. Data []byte `protobuf:"bytes,6,opt,name=data,proto3" json:"data,omitempty"` // Labels are arbitrary data on snapshots. // // The combined size of a key/value pair cannot exceed 4096 bytes. Labels map[string]string `` /* 153-byte string literal not displayed */ XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
WriteContentRequest writes data to the request ref at offset.
func (*WriteContentRequest) Descriptor ¶
func (*WriteContentRequest) Descriptor() ([]byte, []int)
func (*WriteContentRequest) Marshal ¶
func (m *WriteContentRequest) Marshal() (dAtA []byte, err error)
func (*WriteContentRequest) MarshalTo ¶
func (m *WriteContentRequest) MarshalTo(dAtA []byte) (int, error)
func (*WriteContentRequest) MarshalToSizedBuffer ¶
func (m *WriteContentRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*WriteContentRequest) ProtoMessage ¶
func (*WriteContentRequest) ProtoMessage()
func (*WriteContentRequest) Reset ¶
func (m *WriteContentRequest) Reset()
func (*WriteContentRequest) Size ¶
func (m *WriteContentRequest) Size() (n int)
func (*WriteContentRequest) String ¶
func (this *WriteContentRequest) String() string
func (*WriteContentRequest) Unmarshal ¶
func (m *WriteContentRequest) Unmarshal(dAtA []byte) error
func (*WriteContentRequest) XXX_DiscardUnknown ¶
func (m *WriteContentRequest) XXX_DiscardUnknown()
func (*WriteContentRequest) XXX_Marshal ¶
func (m *WriteContentRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*WriteContentRequest) XXX_Merge ¶
func (m *WriteContentRequest) XXX_Merge(src proto.Message)
func (*WriteContentRequest) XXX_Size ¶
func (m *WriteContentRequest) XXX_Size() int
func (*WriteContentRequest) XXX_Unmarshal ¶
func (m *WriteContentRequest) XXX_Unmarshal(b []byte) error
type WriteContentResponse ¶
type WriteContentResponse struct { // Action contains the action for the final message of the stream. A writer // should confirm that they match the intended result. Action WriteAction `protobuf:"varint,1,opt,name=action,proto3,enum=containerd.services.content.v1.WriteAction" json:"action,omitempty"` // StartedAt provides the time at which the write began. // // This must be set for stat and commit write actions. All other write // actions may omit this. StartedAt time.Time `protobuf:"bytes,2,opt,name=started_at,json=startedAt,proto3,stdtime" json:"started_at"` // UpdatedAt provides the last time of a successful write. // // This must be set for stat and commit write actions. All other write // actions may omit this. UpdatedAt time.Time `protobuf:"bytes,3,opt,name=updated_at,json=updatedAt,proto3,stdtime" json:"updated_at"` // Offset is the current committed size for the write. Offset int64 `protobuf:"varint,4,opt,name=offset,proto3" json:"offset,omitempty"` // Total provides the current, expected total size of the write. // // We include this to provide consistency with the Status structure on the // client writer. // // This is only valid on the Stat and Commit response. Total int64 `protobuf:"varint,5,opt,name=total,proto3" json:"total,omitempty"` // Digest, if present, includes the digest up to the currently committed // bytes. If action is commit, this field will be set. It is implementation // defined if this is set for other actions. Digest github_com_opencontainers_go_digest.Digest `protobuf:"bytes,6,opt,name=digest,proto3,customtype=github.com/opencontainers/go-digest.Digest" json:"digest"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
WriteContentResponse is returned on the culmination of a write call.
func (*WriteContentResponse) Descriptor ¶
func (*WriteContentResponse) Descriptor() ([]byte, []int)
func (*WriteContentResponse) Marshal ¶
func (m *WriteContentResponse) Marshal() (dAtA []byte, err error)
func (*WriteContentResponse) MarshalTo ¶
func (m *WriteContentResponse) MarshalTo(dAtA []byte) (int, error)
func (*WriteContentResponse) MarshalToSizedBuffer ¶
func (m *WriteContentResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*WriteContentResponse) ProtoMessage ¶
func (*WriteContentResponse) ProtoMessage()
func (*WriteContentResponse) Reset ¶
func (m *WriteContentResponse) Reset()
func (*WriteContentResponse) Size ¶
func (m *WriteContentResponse) Size() (n int)
func (*WriteContentResponse) String ¶
func (this *WriteContentResponse) String() string
func (*WriteContentResponse) Unmarshal ¶
func (m *WriteContentResponse) Unmarshal(dAtA []byte) error
func (*WriteContentResponse) XXX_DiscardUnknown ¶
func (m *WriteContentResponse) XXX_DiscardUnknown()
func (*WriteContentResponse) XXX_Marshal ¶
func (m *WriteContentResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*WriteContentResponse) XXX_Merge ¶
func (m *WriteContentResponse) XXX_Merge(src proto.Message)
func (*WriteContentResponse) XXX_Size ¶
func (m *WriteContentResponse) XXX_Size() int
func (*WriteContentResponse) XXX_Unmarshal ¶
func (m *WriteContentResponse) XXX_Unmarshal(b []byte) error