content

package
v1.3.0-k3s.5 Latest Latest
Warning

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

 Go to latest Published: Dec 16, 2019 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthContent = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowContent   = fmt.Errorf("proto: integer overflow")
)
View Source 
var WriteAction_name = map[int32]string{
	0: "STAT",
	1: "WRITE",
	2: "COMMIT",
}
View Source 
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) MarshalTo 

func (m *AbortRequest) MarshalTo(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) 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) Descriptor() ([]byte, []int)

func (*Info) Marshal 

func (m *Info) Marshal() (dAtA []byte, err error)

func (*Info) MarshalTo 

func (m *Info) MarshalTo(dAtA []byte) (int, error)

func (*Info) ProtoMessage 

func (*Info) ProtoMessage()

func (*Info) Reset 

func (m *Info) Reset()

func (*Info) Size 

func (m *Info) Size() (n int)

func (*Info) String 

func (this *Info) String() string

func (*Info) Unmarshal 

func (m *Info) Unmarshal(dAtA []byte) error

func (*Info) XXX_DiscardUnknown 

func (m *Info) XXX_DiscardUnknown()

func (*Info) XXX_Marshal 

func (m *Info) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Info) XXX_Merge 

func (m *Info) XXX_Merge(src proto.Message)

func (*Info) XXX_Size 

func (m *Info) XXX_Size() int

func (*Info) XXX_Unmarshal 

func (m *Info) XXX_Unmarshal(b []byte) error

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) MarshalTo 

func (m *InfoRequest) MarshalTo(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) MarshalTo 

func (m *InfoResponse) MarshalTo(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) 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) 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) 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) 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) 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) 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) Descriptor() ([]byte, []int)

func (*Status) Marshal 

func (m *Status) Marshal() (dAtA []byte, err error)

func (*Status) MarshalTo 

func (m *Status) MarshalTo(dAtA []byte) (int, error)

func (*Status) ProtoMessage 

func (*Status) ProtoMessage()

func (*Status) Reset 

func (m *Status) Reset()

func (*Status) Size 

func (m *Status) Size() (n int)

func (*Status) String 

func (this *Status) String() string

func (*Status) Unmarshal 

func (m *Status) Unmarshal(dAtA []byte) error

func (*Status) XXX_DiscardUnknown 

func (m *Status) XXX_DiscardUnknown()

func (*Status) XXX_Marshal 

func (m *Status) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Status) XXX_Merge 

func (m *Status) XXX_Merge(src proto.Message)

func (*Status) XXX_Size 

func (m *Status) XXX_Size() int

func (*Status) XXX_Unmarshal 

func (m *Status) XXX_Unmarshal(b []byte) error

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) MarshalTo 

func (m *StatusRequest) MarshalTo(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) MarshalTo 

func (m *StatusResponse) MarshalTo(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 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) MarshalTo 

func (m *UpdateRequest) MarshalTo(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) MarshalTo 

func (m *UpdateResponse) MarshalTo(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) 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) 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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.