 Documentation
      ¶
      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