container

package
v2.0.0-...-d29d931 Latest Latest
Warning

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

 Go to latest Published: Feb 25, 2021 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

View Source 
const SysAttributePrefix = "__NEOFS__"

SysAttributePrefix is a prefix of key to system attribute.

View Source 
const (
	// SysAttributeSubnet is a string ID of container's storage subnet.
	SysAttributeSubnet = SysAttributePrefix + "SUBNET"
)

Variables

This section is empty.

Functions

func AnnounceUsedSpaceRequestBodyToGRPCMessage 

func AnnounceUsedSpaceRequestBodyToGRPCMessage(r *AnnounceUsedSpaceRequestBody) *container.AnnounceUsedSpaceRequest_Body

func AnnounceUsedSpaceRequestToGRPCMessage 

func AnnounceUsedSpaceRequestToGRPCMessage(r *AnnounceUsedSpaceRequest) *container.AnnounceUsedSpaceRequest

func AnnounceUsedSpaceResponseBodyToGRPCMessage 

func AnnounceUsedSpaceResponseBodyToGRPCMessage(r *AnnounceUsedSpaceResponseBody) *container.AnnounceUsedSpaceResponse_Body

func AnnounceUsedSpaceResponseToGRPCMessage 

func AnnounceUsedSpaceResponseToGRPCMessage(r *AnnounceUsedSpaceResponse) *container.AnnounceUsedSpaceResponse

func AttributeToGRPCMessage 

func AttributeToGRPCMessage(a *Attribute) *container.Container_Attribute

func ContainerToGRPCMessage 

func ContainerToGRPCMessage(c *Container) *container.Container

func DeleteRequestBodyToGRPCMessage 

func DeleteRequestBodyToGRPCMessage(r *DeleteRequestBody) *container.DeleteRequest_Body

func DeleteRequestToGRPCMessage 

func DeleteRequestToGRPCMessage(r *DeleteRequest) *container.DeleteRequest

func DeleteResponseBodyToGRPCMessage 

func DeleteResponseBodyToGRPCMessage(r *DeleteResponseBody) *container.DeleteResponse_Body

func DeleteResponseToGRPCMessage 

func DeleteResponseToGRPCMessage(r *DeleteResponse) *container.DeleteResponse

func GetExtendedACLRequestBodyToGRPCMessage 

func GetExtendedACLRequestBodyToGRPCMessage(r *GetExtendedACLRequestBody) *container.GetExtendedACLRequest_Body

func GetExtendedACLRequestToGRPCMessage 

func GetExtendedACLRequestToGRPCMessage(r *GetExtendedACLRequest) *container.GetExtendedACLRequest

func GetExtendedACLResponseBodyToGRPCMessage 

func GetExtendedACLResponseBodyToGRPCMessage(r *GetExtendedACLResponseBody) *container.GetExtendedACLResponse_Body

func GetExtendedACLResponseToGRPCMessage 

func GetExtendedACLResponseToGRPCMessage(r *GetExtendedACLResponse) *container.GetExtendedACLResponse

func GetRequestBodyToGRPCMessage 

func GetRequestBodyToGRPCMessage(r *GetRequestBody) *container.GetRequest_Body

func GetRequestToGRPCMessage 

func GetRequestToGRPCMessage(r *GetRequest) *container.GetRequest

func GetResponseBodyToGRPCMessage 

func GetResponseBodyToGRPCMessage(r *GetResponseBody) *container.GetResponse_Body

func GetResponseToGRPCMessage 

func GetResponseToGRPCMessage(r *GetResponse) *container.GetResponse

func ListRequestBodyToGRPCMessage 

func ListRequestBodyToGRPCMessage(r *ListRequestBody) *container.ListRequest_Body

func ListRequestToGRPCMessage 

func ListRequestToGRPCMessage(r *ListRequest) *container.ListRequest

func ListResponseBodyToGRPCMessage 

func ListResponseBodyToGRPCMessage(r *ListResponseBody) *container.ListResponse_Body

func ListResponseToGRPCMessage 

func ListResponseToGRPCMessage(r *ListResponse) *container.ListResponse

func PutRequestBodyToGRPCMessage 

func PutRequestBodyToGRPCMessage(r *PutRequestBody) *container.PutRequest_Body

func PutRequestToGRPCMessage 

func PutRequestToGRPCMessage(r *PutRequest) *container.PutRequest

func PutResponseBodyToGRPCMessage 

func PutResponseBodyToGRPCMessage(r *PutResponseBody) *container.PutResponse_Body

func PutResponseToGRPCMessage 

func PutResponseToGRPCMessage(r *PutResponse) *container.PutResponse

func SetExtendedACLRequestBodyToGRPCMessage 

func SetExtendedACLRequestBodyToGRPCMessage(r *SetExtendedACLRequestBody) *container.SetExtendedACLRequest_Body

func SetExtendedACLRequestToGRPCMessage 

func SetExtendedACLRequestToGRPCMessage(r *SetExtendedACLRequest) *container.SetExtendedACLRequest

func SetExtendedACLResponseBodyToGRPCMessage 

func SetExtendedACLResponseBodyToGRPCMessage(r *SetExtendedACLResponseBody) *container.SetExtendedACLResponse_Body

func SetExtendedACLResponseToGRPCMessage 

func SetExtendedACLResponseToGRPCMessage(r *SetExtendedACLResponse) *container.SetExtendedACLResponse

func UsedSpaceAnnouncementToGRPCMessage 

func UsedSpaceAnnouncementToGRPCMessage(a *UsedSpaceAnnouncement) *container.AnnounceUsedSpaceRequest_Body_Announcement

Types

type AnnounceUsedSpaceRequest 

type AnnounceUsedSpaceRequest struct {
	// contains filtered or unexported fields
}

func AnnounceUsedSpaceRequestFromGRPCMessage 

func AnnounceUsedSpaceRequestFromGRPCMessage(m *container.AnnounceUsedSpaceRequest) *AnnounceUsedSpaceRequest

func (*AnnounceUsedSpaceRequest) GetBody 

func (r *AnnounceUsedSpaceRequest) GetBody() *AnnounceUsedSpaceRequestBody

func (*AnnounceUsedSpaceRequest) GetMetaHeader 

func (r *AnnounceUsedSpaceRequest) GetMetaHeader() *session.RequestMetaHeader

func (*AnnounceUsedSpaceRequest) GetVerificationHeader 

func (r *AnnounceUsedSpaceRequest) GetVerificationHeader() *session.RequestVerificationHeader

func (*AnnounceUsedSpaceRequest) SetBody 

func (r *AnnounceUsedSpaceRequest) SetBody(v *AnnounceUsedSpaceRequestBody)

func (*AnnounceUsedSpaceRequest) SetMetaHeader 

func (r *AnnounceUsedSpaceRequest) SetMetaHeader(v *session.RequestMetaHeader)

func (*AnnounceUsedSpaceRequest) SetVerificationHeader 

func (r *AnnounceUsedSpaceRequest) SetVerificationHeader(v *session.RequestVerificationHeader)

type AnnounceUsedSpaceRequestBody 

type AnnounceUsedSpaceRequestBody struct {
	// contains filtered or unexported fields
}

func AnnounceUsedSpaceRequestBodyFromGRPCMessage 

func AnnounceUsedSpaceRequestBodyFromGRPCMessage(m *container.AnnounceUsedSpaceRequest_Body) *AnnounceUsedSpaceRequestBody

func (*AnnounceUsedSpaceRequestBody) GetAnnouncements 

func (r *AnnounceUsedSpaceRequestBody) GetAnnouncements() []*UsedSpaceAnnouncement

func (*AnnounceUsedSpaceRequestBody) SetAnnouncements 

func (r *AnnounceUsedSpaceRequestBody) SetAnnouncements(v []*UsedSpaceAnnouncement)

func (*AnnounceUsedSpaceRequestBody) StableMarshal 

func (r *AnnounceUsedSpaceRequestBody) StableMarshal(buf []byte) ([]byte, error)

func (*AnnounceUsedSpaceRequestBody) StableSize 

func (r *AnnounceUsedSpaceRequestBody) StableSize() (size int)

type AnnounceUsedSpaceResponse 

type AnnounceUsedSpaceResponse struct {
	// contains filtered or unexported fields
}

func AnnounceUsedSpaceResponseFromGRPCMessage 

func AnnounceUsedSpaceResponseFromGRPCMessage(m *container.AnnounceUsedSpaceResponse) *AnnounceUsedSpaceResponse

func (*AnnounceUsedSpaceResponse) GetBody 

func (r *AnnounceUsedSpaceResponse) GetBody() *AnnounceUsedSpaceResponseBody

func (*AnnounceUsedSpaceResponse) GetMetaHeader 

func (r *AnnounceUsedSpaceResponse) GetMetaHeader() *session.ResponseMetaHeader

func (*AnnounceUsedSpaceResponse) GetVerificationHeader 

func (r *AnnounceUsedSpaceResponse) GetVerificationHeader() *session.ResponseVerificationHeader

func (*AnnounceUsedSpaceResponse) SetBody 

func (r *AnnounceUsedSpaceResponse) SetBody(v *AnnounceUsedSpaceResponseBody)

func (*AnnounceUsedSpaceResponse) SetMetaHeader 

func (r *AnnounceUsedSpaceResponse) SetMetaHeader(v *session.ResponseMetaHeader)

func (*AnnounceUsedSpaceResponse) SetVerificationHeader 

func (r *AnnounceUsedSpaceResponse) SetVerificationHeader(v *session.ResponseVerificationHeader)

type AnnounceUsedSpaceResponseBody 

type AnnounceUsedSpaceResponseBody struct{}

func AnnounceUsedSpaceResponseBodyFromGRPCMessage 

func AnnounceUsedSpaceResponseBodyFromGRPCMessage(m *container.AnnounceUsedSpaceResponse_Body) *AnnounceUsedSpaceResponseBody

func (*AnnounceUsedSpaceResponseBody) StableMarshal 

func (r *AnnounceUsedSpaceResponseBody) StableMarshal(buf []byte) ([]byte, error)

func (*AnnounceUsedSpaceResponseBody) StableSize 

func (r *AnnounceUsedSpaceResponseBody) StableSize() (size int)

type Attribute 

type Attribute struct {
	// contains filtered or unexported fields
}

func AttributeFromGRPCMessage 

func AttributeFromGRPCMessage(m *container.Container_Attribute) *Attribute

func (*Attribute) GetKey 

func (a *Attribute) GetKey() string

func (*Attribute) GetValue 

func (a *Attribute) GetValue() string

func (*Attribute) MarshalJSON 

func (a *Attribute) MarshalJSON() ([]byte, error)

func (*Attribute) SetKey 

func (a *Attribute) SetKey(v string)

func (*Attribute) SetValue 

func (a *Attribute) SetValue(v string)

func (*Attribute) StableMarshal 

func (a *Attribute) StableMarshal(buf []byte) ([]byte, error)

func (*Attribute) StableSize 

func (a *Attribute) StableSize() (size int)

func (*Attribute) Unmarshal 

func (a *Attribute) Unmarshal(data []byte) error

func (*Attribute) UnmarshalJSON 

func (a *Attribute) UnmarshalJSON(data []byte) error

type Client 

type Client struct {
	// contains filtered or unexported fields
}

Client represents universal container transport client.

func NewClient 

func NewClient(opts ...Option) (*Client, error)

func (*Client) AnnounceUsedSpace 

func (c *Client) AnnounceUsedSpace(ctx context.Context, req *AnnounceUsedSpaceRequest) (*AnnounceUsedSpaceResponse, error)

AnnounceUsedSpace sends AnnounceUsedSpaceRequest over the network and returns AnnounceUsedSpaceResponse.

It returns any error encountered during the call.

func (*Client) Delete 

func (c *Client) Delete(ctx context.Context, req *DeleteRequest) (*DeleteResponse, error)

Delete sends GetRequest over the network and returns GetResponse.

It returns any error encountered during the call.

func (*Client) Get 

func (c *Client) Get(ctx context.Context, req *GetRequest) (*GetResponse, error)

Get sends GetRequest over the network and returns GetResponse.

It returns any error encountered during the call.

func (*Client) GetExtendedACL 

func (c *Client) GetExtendedACL(ctx context.Context, req *GetExtendedACLRequest) (*GetExtendedACLResponse, error)

GetExtendedACL sends GetExtendedACLRequest over the network and returns GetExtendedACLResponse.

It returns any error encountered during the call.

func (*Client) List 

func (c *Client) List(ctx context.Context, req *ListRequest) (*ListResponse, error)

List sends ListRequest over the network and returns ListResponse.

It returns any error encountered during the call.

func (*Client) Put 

func (c *Client) Put(ctx context.Context, req *PutRequest) (*PutResponse, error)

Put sends PutRequest over the network and returns PutResponse.

It returns any error encountered during the call.

func (*Client) SetExtendedACL 

func (c *Client) SetExtendedACL(ctx context.Context, req *SetExtendedACLRequest) (*SetExtendedACLResponse, error)

SetExtendedACL sends SetExtendedACLRequest over the network and returns SetExtendedACLResponse.

It returns any error encountered during the call.

type Container 

type Container struct {
	// contains filtered or unexported fields
}

func ContainerFromGRPCMessage 

func ContainerFromGRPCMessage(m *container.Container) *Container

func (*Container) GetAttributes 

func (c *Container) GetAttributes() []*Attribute

func (*Container) GetBasicACL 

func (c *Container) GetBasicACL() uint32

func (*Container) GetNonce 

func (c *Container) GetNonce() []byte

func (*Container) GetOwnerID 

func (c *Container) GetOwnerID() *refs.OwnerID

func (*Container) GetPlacementPolicy 

func (c *Container) GetPlacementPolicy() *netmap.PlacementPolicy

func (*Container) GetVersion 

func (c *Container) GetVersion() *refs.Version

func (*Container) MarshalJSON 

func (c *Container) MarshalJSON() ([]byte, error)

func (*Container) SetAttributes 

func (c *Container) SetAttributes(v []*Attribute)

func (*Container) SetBasicACL 

func (c *Container) SetBasicACL(v uint32)

func (*Container) SetNonce 

func (c *Container) SetNonce(v []byte)

func (*Container) SetOwnerID 

func (c *Container) SetOwnerID(v *refs.OwnerID)

func (*Container) SetPlacementPolicy 

func (c *Container) SetPlacementPolicy(v *netmap.PlacementPolicy)

func (*Container) SetVersion 

func (c *Container) SetVersion(v *refs.Version)

func (*Container) StableMarshal 

func (c *Container) StableMarshal(buf []byte) ([]byte, error)

func (*Container) StableSize 

func (c *Container) StableSize() (size int)

func (*Container) Unmarshal 

func (c *Container) Unmarshal(data []byte) error

func (*Container) UnmarshalJSON 

func (c *Container) UnmarshalJSON(data []byte) error

type DeleteRequest 

type DeleteRequest struct {
	// contains filtered or unexported fields
}

func DeleteRequestFromGRPCMessage 

func DeleteRequestFromGRPCMessage(m *container.DeleteRequest) *DeleteRequest

func (*DeleteRequest) GetBody 

func (r *DeleteRequest) GetBody() *DeleteRequestBody

func (*DeleteRequest) GetMetaHeader 

func (r *DeleteRequest) GetMetaHeader() *session.RequestMetaHeader

func (*DeleteRequest) GetVerificationHeader 

func (r *DeleteRequest) GetVerificationHeader() *session.RequestVerificationHeader

func (*DeleteRequest) SetBody 

func (r *DeleteRequest) SetBody(v *DeleteRequestBody)

func (*DeleteRequest) SetMetaHeader 

func (r *DeleteRequest) SetMetaHeader(v *session.RequestMetaHeader)

func (*DeleteRequest) SetVerificationHeader 

func (r *DeleteRequest) SetVerificationHeader(v *session.RequestVerificationHeader)

type DeleteRequestBody 

type DeleteRequestBody struct {
	// contains filtered or unexported fields
}

func DeleteRequestBodyFromGRPCMessage 

func DeleteRequestBodyFromGRPCMessage(m *container.DeleteRequest_Body) *DeleteRequestBody

func (*DeleteRequestBody) GetContainerID 

func (r *DeleteRequestBody) GetContainerID() *refs.ContainerID

func (*DeleteRequestBody) GetSignature 

func (r *DeleteRequestBody) GetSignature() *refs.Signature

func (*DeleteRequestBody) SetContainerID 

func (r *DeleteRequestBody) SetContainerID(v *refs.ContainerID)

func (*DeleteRequestBody) SetSignature 

func (r *DeleteRequestBody) SetSignature(v *refs.Signature)

func (*DeleteRequestBody) StableMarshal 

func (r *DeleteRequestBody) StableMarshal(buf []byte) ([]byte, error)

func (*DeleteRequestBody) StableSize 

func (r *DeleteRequestBody) StableSize() (size int)

type DeleteResponse 

type DeleteResponse struct {
	// contains filtered or unexported fields
}

func DeleteResponseFromGRPCMessage 

func DeleteResponseFromGRPCMessage(m *container.DeleteResponse) *DeleteResponse

func (*DeleteResponse) GetBody 

func (r *DeleteResponse) GetBody() *DeleteResponseBody

func (*DeleteResponse) GetMetaHeader 

func (r *DeleteResponse) GetMetaHeader() *session.ResponseMetaHeader

func (*DeleteResponse) GetVerificationHeader 

func (r *DeleteResponse) GetVerificationHeader() *session.ResponseVerificationHeader

func (*DeleteResponse) SetBody 

func (r *DeleteResponse) SetBody(v *DeleteResponseBody)

func (*DeleteResponse) SetMetaHeader 

func (r *DeleteResponse) SetMetaHeader(v *session.ResponseMetaHeader)

func (*DeleteResponse) SetVerificationHeader 

func (r *DeleteResponse) SetVerificationHeader(v *session.ResponseVerificationHeader)

type DeleteResponseBody 

type DeleteResponseBody struct{}

func DeleteResponseBodyFromGRPCMessage 

func DeleteResponseBodyFromGRPCMessage(m *container.DeleteResponse_Body) *DeleteResponseBody

func (*DeleteResponseBody) StableMarshal 

func (r *DeleteResponseBody) StableMarshal(buf []byte) ([]byte, error)

func (*DeleteResponseBody) StableSize 

func (r *DeleteResponseBody) StableSize() (size int)

type GetExtendedACLRequest 

type GetExtendedACLRequest struct {
	// contains filtered or unexported fields
}

func GetExtendedACLRequestFromGRPCMessage 

func GetExtendedACLRequestFromGRPCMessage(m *container.GetExtendedACLRequest) *GetExtendedACLRequest

func (*GetExtendedACLRequest) GetBody 

func (r *GetExtendedACLRequest) GetBody() *GetExtendedACLRequestBody

func (*GetExtendedACLRequest) GetMetaHeader 

func (r *GetExtendedACLRequest) GetMetaHeader() *session.RequestMetaHeader

func (*GetExtendedACLRequest) GetVerificationHeader 

func (r *GetExtendedACLRequest) GetVerificationHeader() *session.RequestVerificationHeader

func (*GetExtendedACLRequest) SetBody 

func (r *GetExtendedACLRequest) SetBody(v *GetExtendedACLRequestBody)

func (*GetExtendedACLRequest) SetMetaHeader 

func (r *GetExtendedACLRequest) SetMetaHeader(v *session.RequestMetaHeader)

func (*GetExtendedACLRequest) SetVerificationHeader 

func (r *GetExtendedACLRequest) SetVerificationHeader(v *session.RequestVerificationHeader)

type GetExtendedACLRequestBody 

type GetExtendedACLRequestBody struct {
	// contains filtered or unexported fields
}

func GetExtendedACLRequestBodyFromGRPCMessage 

func GetExtendedACLRequestBodyFromGRPCMessage(m *container.GetExtendedACLRequest_Body) *GetExtendedACLRequestBody

func (*GetExtendedACLRequestBody) GetContainerID 

func (r *GetExtendedACLRequestBody) GetContainerID() *refs.ContainerID

func (*GetExtendedACLRequestBody) SetContainerID 

func (r *GetExtendedACLRequestBody) SetContainerID(v *refs.ContainerID)

func (*GetExtendedACLRequestBody) StableMarshal 

func (r *GetExtendedACLRequestBody) StableMarshal(buf []byte) ([]byte, error)

func (*GetExtendedACLRequestBody) StableSize 

func (r *GetExtendedACLRequestBody) StableSize() (size int)

type GetExtendedACLResponse 

type GetExtendedACLResponse struct {
	// contains filtered or unexported fields
}

func GetExtendedACLResponseFromGRPCMessage 

func GetExtendedACLResponseFromGRPCMessage(m *container.GetExtendedACLResponse) *GetExtendedACLResponse

func (*GetExtendedACLResponse) GetBody 

func (r *GetExtendedACLResponse) GetBody() *GetExtendedACLResponseBody

func (*GetExtendedACLResponse) GetMetaHeader 

func (r *GetExtendedACLResponse) GetMetaHeader() *session.ResponseMetaHeader

func (*GetExtendedACLResponse) GetVerificationHeader 

func (r *GetExtendedACLResponse) GetVerificationHeader() *session.ResponseVerificationHeader

func (*GetExtendedACLResponse) SetBody 

func (r *GetExtendedACLResponse) SetBody(v *GetExtendedACLResponseBody)

func (*GetExtendedACLResponse) SetMetaHeader 

func (r *GetExtendedACLResponse) SetMetaHeader(v *session.ResponseMetaHeader)

func (*GetExtendedACLResponse) SetVerificationHeader 

func (r *GetExtendedACLResponse) SetVerificationHeader(v *session.ResponseVerificationHeader)

type GetExtendedACLResponseBody 

type GetExtendedACLResponseBody struct {
	// contains filtered or unexported fields
}

func GetExtendedACLResponseBodyFromGRPCMessage 

func GetExtendedACLResponseBodyFromGRPCMessage(m *container.GetExtendedACLResponse_Body) *GetExtendedACLResponseBody

func (*GetExtendedACLResponseBody) GetEACL 

func (r *GetExtendedACLResponseBody) GetEACL() *acl.Table

func (*GetExtendedACLResponseBody) GetSignature 

func (r *GetExtendedACLResponseBody) GetSignature() *refs.Signature

func (*GetExtendedACLResponseBody) SetEACL 

func (r *GetExtendedACLResponseBody) SetEACL(v *acl.Table)

func (*GetExtendedACLResponseBody) SetSignature 

func (r *GetExtendedACLResponseBody) SetSignature(v *refs.Signature)

func (*GetExtendedACLResponseBody) StableMarshal 

func (r *GetExtendedACLResponseBody) StableMarshal(buf []byte) ([]byte, error)

func (*GetExtendedACLResponseBody) StableSize 

func (r *GetExtendedACLResponseBody) StableSize() (size int)

type GetRequest 

type GetRequest struct {
	// contains filtered or unexported fields
}

func GetRequestFromGRPCMessage 

func GetRequestFromGRPCMessage(m *container.GetRequest) *GetRequest

func (*GetRequest) GetBody 

func (r *GetRequest) GetBody() *GetRequestBody

func (*GetRequest) GetMetaHeader 

func (r *GetRequest) GetMetaHeader() *session.RequestMetaHeader

func (*GetRequest) GetVerificationHeader 

func (r *GetRequest) GetVerificationHeader() *session.RequestVerificationHeader

func (*GetRequest) SetBody 

func (r *GetRequest) SetBody(v *GetRequestBody)

func (*GetRequest) SetMetaHeader 

func (r *GetRequest) SetMetaHeader(v *session.RequestMetaHeader)

func (*GetRequest) SetVerificationHeader 

func (r *GetRequest) SetVerificationHeader(v *session.RequestVerificationHeader)

type GetRequestBody 

type GetRequestBody struct {
	// contains filtered or unexported fields
}

func GetRequestBodyFromGRPCMessage 

func GetRequestBodyFromGRPCMessage(m *container.GetRequest_Body) *GetRequestBody

func (*GetRequestBody) GetContainerID 

func (r *GetRequestBody) GetContainerID() *refs.ContainerID

func (*GetRequestBody) SetContainerID 

func (r *GetRequestBody) SetContainerID(v *refs.ContainerID)

func (*GetRequestBody) StableMarshal 

func (r *GetRequestBody) StableMarshal(buf []byte) ([]byte, error)

func (*GetRequestBody) StableSize 

func (r *GetRequestBody) StableSize() (size int)

type GetResponse 

type GetResponse struct {
	// contains filtered or unexported fields
}

func GetResponseFromGRPCMessage 

func GetResponseFromGRPCMessage(m *container.GetResponse) *GetResponse

func (*GetResponse) GetBody 

func (r *GetResponse) GetBody() *GetResponseBody

func (*GetResponse) GetMetaHeader 

func (r *GetResponse) GetMetaHeader() *session.ResponseMetaHeader

func (*GetResponse) GetVerificationHeader 

func (r *GetResponse) GetVerificationHeader() *session.ResponseVerificationHeader

func (*GetResponse) SetBody 

func (r *GetResponse) SetBody(v *GetResponseBody)

func (*GetResponse) SetMetaHeader 

func (r *GetResponse) SetMetaHeader(v *session.ResponseMetaHeader)

func (*GetResponse) SetVerificationHeader 

func (r *GetResponse) SetVerificationHeader(v *session.ResponseVerificationHeader)

type GetResponseBody 

type GetResponseBody struct {
	// contains filtered or unexported fields
}

func GetResponseBodyFromGRPCMessage 

func GetResponseBodyFromGRPCMessage(m *container.GetResponse_Body) *GetResponseBody

func (*GetResponseBody) GetContainer 

func (r *GetResponseBody) GetContainer() *Container

func (*GetResponseBody) SetContainer 

func (r *GetResponseBody) SetContainer(v *Container)

func (*GetResponseBody) StableMarshal 

func (r *GetResponseBody) StableMarshal(buf []byte) ([]byte, error)

func (*GetResponseBody) StableSize 

func (r *GetResponseBody) StableSize() (size int)

type ListRequest 

type ListRequest struct {
	// contains filtered or unexported fields
}

func ListRequestFromGRPCMessage 

func ListRequestFromGRPCMessage(m *container.ListRequest) *ListRequest

func (*ListRequest) GetBody 

func (r *ListRequest) GetBody() *ListRequestBody

func (*ListRequest) GetMetaHeader 

func (r *ListRequest) GetMetaHeader() *session.RequestMetaHeader

func (*ListRequest) GetVerificationHeader 

func (r *ListRequest) GetVerificationHeader() *session.RequestVerificationHeader

func (*ListRequest) SetBody 

func (r *ListRequest) SetBody(v *ListRequestBody)

func (*ListRequest) SetMetaHeader 

func (r *ListRequest) SetMetaHeader(v *session.RequestMetaHeader)

func (*ListRequest) SetVerificationHeader 

func (r *ListRequest) SetVerificationHeader(v *session.RequestVerificationHeader)

type ListRequestBody 

type ListRequestBody struct {
	// contains filtered or unexported fields
}

func ListRequestBodyFromGRPCMessage 

func ListRequestBodyFromGRPCMessage(m *container.ListRequest_Body) *ListRequestBody

func (*ListRequestBody) GetOwnerID 

func (r *ListRequestBody) GetOwnerID() *refs.OwnerID

func (*ListRequestBody) SetOwnerID 

func (r *ListRequestBody) SetOwnerID(v *refs.OwnerID)

func (*ListRequestBody) StableMarshal 

func (r *ListRequestBody) StableMarshal(buf []byte) ([]byte, error)

func (*ListRequestBody) StableSize 

func (r *ListRequestBody) StableSize() (size int)

type ListResponse 

type ListResponse struct {
	// contains filtered or unexported fields
}

func ListResponseFromGRPCMessage 

func ListResponseFromGRPCMessage(m *container.ListResponse) *ListResponse

func (*ListResponse) GetBody 

func (r *ListResponse) GetBody() *ListResponseBody

func (*ListResponse) GetMetaHeader 

func (r *ListResponse) GetMetaHeader() *session.ResponseMetaHeader

func (*ListResponse) GetVerificationHeader 

func (r *ListResponse) GetVerificationHeader() *session.ResponseVerificationHeader

func (*ListResponse) SetBody 

func (r *ListResponse) SetBody(v *ListResponseBody)

func (*ListResponse) SetMetaHeader 

func (r *ListResponse) SetMetaHeader(v *session.ResponseMetaHeader)

func (*ListResponse) SetVerificationHeader 

func (r *ListResponse) SetVerificationHeader(v *session.ResponseVerificationHeader)

type ListResponseBody 

type ListResponseBody struct {
	// contains filtered or unexported fields
}

func ListResponseBodyFromGRPCMessage 

func ListResponseBodyFromGRPCMessage(m *container.ListResponse_Body) *ListResponseBody

func (*ListResponseBody) GetContainerIDs 

func (r *ListResponseBody) GetContainerIDs() []*refs.ContainerID

func (*ListResponseBody) SetContainerIDs 

func (r *ListResponseBody) SetContainerIDs(v []*refs.ContainerID)

func (*ListResponseBody) StableMarshal 

func (r *ListResponseBody) StableMarshal(buf []byte) ([]byte, error)

func (*ListResponseBody) StableSize 

func (r *ListResponseBody) StableSize() (size int)

type Option 

type Option func(*cfg)

Option represents Client option.

func WithGRPCCallOpts 

func WithGRPCCallOpts(v []grpc.CallOption) Option

func WithGRPCClient 

func WithGRPCClient(v *container.Client) Option

func WithGRPCClientOpts 

func WithGRPCClientOpts(v []container.Option) Option

func WithGRPCServiceClient 

func WithGRPCServiceClient(v container.ContainerServiceClient) Option

func WithGlobalOpts 

func WithGlobalOpts(v ...client.Option) Option

type PutRequest 

type PutRequest struct {
	// contains filtered or unexported fields
}

func PutRequestFromGRPCMessage 

func PutRequestFromGRPCMessage(m *container.PutRequest) *PutRequest

func (*PutRequest) GetBody 

func (r *PutRequest) GetBody() *PutRequestBody

func (*PutRequest) GetMetaHeader 

func (r *PutRequest) GetMetaHeader() *session.RequestMetaHeader

func (*PutRequest) GetVerificationHeader 

func (r *PutRequest) GetVerificationHeader() *session.RequestVerificationHeader

func (*PutRequest) SetBody 

func (r *PutRequest) SetBody(v *PutRequestBody)

func (*PutRequest) SetMetaHeader 

func (r *PutRequest) SetMetaHeader(v *session.RequestMetaHeader)

func (*PutRequest) SetVerificationHeader 

func (r *PutRequest) SetVerificationHeader(v *session.RequestVerificationHeader)

type PutRequestBody 

type PutRequestBody struct {
	// contains filtered or unexported fields
}

func PutRequestBodyFromGRPCMessage 

func PutRequestBodyFromGRPCMessage(m *container.PutRequest_Body) *PutRequestBody

func (*PutRequestBody) GetContainer 

func (r *PutRequestBody) GetContainer() *Container

func (*PutRequestBody) GetSignature 

func (r *PutRequestBody) GetSignature() *refs.Signature

func (*PutRequestBody) SetContainer 

func (r *PutRequestBody) SetContainer(v *Container)

func (*PutRequestBody) SetSignature 

func (r *PutRequestBody) SetSignature(v *refs.Signature)

func (*PutRequestBody) StableMarshal 

func (r *PutRequestBody) StableMarshal(buf []byte) ([]byte, error)

func (*PutRequestBody) StableSize 

func (r *PutRequestBody) StableSize() (size int)

type PutResponse 

type PutResponse struct {
	// contains filtered or unexported fields
}

func PutResponseFromGRPCMessage 

func PutResponseFromGRPCMessage(m *container.PutResponse) *PutResponse

func (*PutResponse) GetBody 

func (r *PutResponse) GetBody() *PutResponseBody

func (*PutResponse) GetMetaHeader 

func (r *PutResponse) GetMetaHeader() *session.ResponseMetaHeader

func (*PutResponse) GetVerificationHeader 

func (r *PutResponse) GetVerificationHeader() *session.ResponseVerificationHeader

func (*PutResponse) SetBody 

func (r *PutResponse) SetBody(v *PutResponseBody)

func (*PutResponse) SetMetaHeader 

func (r *PutResponse) SetMetaHeader(v *session.ResponseMetaHeader)

func (*PutResponse) SetVerificationHeader 

func (r *PutResponse) SetVerificationHeader(v *session.ResponseVerificationHeader)

type PutResponseBody 

type PutResponseBody struct {
	// contains filtered or unexported fields
}

func PutResponseBodyFromGRPCMessage 

func PutResponseBodyFromGRPCMessage(m *container.PutResponse_Body) *PutResponseBody

func (*PutResponseBody) GetContainerID 

func (r *PutResponseBody) GetContainerID() *refs.ContainerID

func (*PutResponseBody) SetContainerID 

func (r *PutResponseBody) SetContainerID(v *refs.ContainerID)

func (*PutResponseBody) StableMarshal 

func (r *PutResponseBody) StableMarshal(buf []byte) ([]byte, error)

func (*PutResponseBody) StableSize 

func (r *PutResponseBody) StableSize() (size int)

type Service 

type Service interface {
	Put(context.Context, *PutRequest) (*PutResponse, error)
	Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)
	Get(context.Context, *GetRequest) (*GetResponse, error)
	List(context.Context, *ListRequest) (*ListResponse, error)
	SetExtendedACL(context.Context, *SetExtendedACLRequest) (*SetExtendedACLResponse, error)
	GetExtendedACL(context.Context, *GetExtendedACLRequest) (*GetExtendedACLResponse, error)
	AnnounceUsedSpace(context.Context, *AnnounceUsedSpaceRequest) (*AnnounceUsedSpaceResponse, error)
}

type SetExtendedACLRequest 

type SetExtendedACLRequest struct {
	// contains filtered or unexported fields
}

func SetExtendedACLRequestFromGRPCMessage 

func SetExtendedACLRequestFromGRPCMessage(m *container.SetExtendedACLRequest) *SetExtendedACLRequest

func (*SetExtendedACLRequest) GetBody 

func (r *SetExtendedACLRequest) GetBody() *SetExtendedACLRequestBody

func (*SetExtendedACLRequest) GetMetaHeader 

func (r *SetExtendedACLRequest) GetMetaHeader() *session.RequestMetaHeader

func (*SetExtendedACLRequest) GetVerificationHeader 

func (r *SetExtendedACLRequest) GetVerificationHeader() *session.RequestVerificationHeader

func (*SetExtendedACLRequest) SetBody 

func (r *SetExtendedACLRequest) SetBody(v *SetExtendedACLRequestBody)

func (*SetExtendedACLRequest) SetMetaHeader 

func (r *SetExtendedACLRequest) SetMetaHeader(v *session.RequestMetaHeader)

func (*SetExtendedACLRequest) SetVerificationHeader 

func (r *SetExtendedACLRequest) SetVerificationHeader(v *session.RequestVerificationHeader)

type SetExtendedACLRequestBody 

type SetExtendedACLRequestBody struct {
	// contains filtered or unexported fields
}

func SetExtendedACLRequestBodyFromGRPCMessage 

func SetExtendedACLRequestBodyFromGRPCMessage(m *container.SetExtendedACLRequest_Body) *SetExtendedACLRequestBody

func (*SetExtendedACLRequestBody) GetEACL 

func (r *SetExtendedACLRequestBody) GetEACL() *acl.Table

func (*SetExtendedACLRequestBody) GetSignature 

func (r *SetExtendedACLRequestBody) GetSignature() *refs.Signature

func (*SetExtendedACLRequestBody) SetEACL 

func (r *SetExtendedACLRequestBody) SetEACL(v *acl.Table)

func (*SetExtendedACLRequestBody) SetSignature 

func (r *SetExtendedACLRequestBody) SetSignature(v *refs.Signature)

func (*SetExtendedACLRequestBody) StableMarshal 

func (r *SetExtendedACLRequestBody) StableMarshal(buf []byte) ([]byte, error)

func (*SetExtendedACLRequestBody) StableSize 

func (r *SetExtendedACLRequestBody) StableSize() (size int)

type SetExtendedACLResponse 

type SetExtendedACLResponse struct {
	// contains filtered or unexported fields
}

func SetExtendedACLResponseFromGRPCMessage 

func SetExtendedACLResponseFromGRPCMessage(m *container.SetExtendedACLResponse) *SetExtendedACLResponse

func (*SetExtendedACLResponse) GetBody 

func (r *SetExtendedACLResponse) GetBody() *SetExtendedACLResponseBody

func (*SetExtendedACLResponse) GetMetaHeader 

func (r *SetExtendedACLResponse) GetMetaHeader() *session.ResponseMetaHeader

func (*SetExtendedACLResponse) GetVerificationHeader 

func (r *SetExtendedACLResponse) GetVerificationHeader() *session.ResponseVerificationHeader

func (*SetExtendedACLResponse) SetBody 

func (r *SetExtendedACLResponse) SetBody(v *SetExtendedACLResponseBody)

func (*SetExtendedACLResponse) SetMetaHeader 

func (r *SetExtendedACLResponse) SetMetaHeader(v *session.ResponseMetaHeader)

func (*SetExtendedACLResponse) SetVerificationHeader 

func (r *SetExtendedACLResponse) SetVerificationHeader(v *session.ResponseVerificationHeader)

type SetExtendedACLResponseBody 

type SetExtendedACLResponseBody struct{}

func SetExtendedACLResponseBodyFromGRPCMessage 

func SetExtendedACLResponseBodyFromGRPCMessage(m *container.SetExtendedACLResponse_Body) *SetExtendedACLResponseBody

func (*SetExtendedACLResponseBody) StableMarshal 

func (r *SetExtendedACLResponseBody) StableMarshal(buf []byte) ([]byte, error)

func (*SetExtendedACLResponseBody) StableSize 

func (r *SetExtendedACLResponseBody) StableSize() (size int)

type UsedSpaceAnnouncement 

type UsedSpaceAnnouncement struct {
	// contains filtered or unexported fields
}

func UsedSpaceAnnouncementFromGRPCMessage 

func UsedSpaceAnnouncementFromGRPCMessage(m *container.AnnounceUsedSpaceRequest_Body_Announcement) *UsedSpaceAnnouncement

func (*UsedSpaceAnnouncement) GetContainerID 

func (a *UsedSpaceAnnouncement) GetContainerID() *refs.ContainerID

func (*UsedSpaceAnnouncement) GetEpoch 

func (a *UsedSpaceAnnouncement) GetEpoch() uint64

func (*UsedSpaceAnnouncement) GetUsedSpace 

func (a *UsedSpaceAnnouncement) GetUsedSpace() uint64

func (*UsedSpaceAnnouncement) SetContainerID 

func (a *UsedSpaceAnnouncement) SetContainerID(v *refs.ContainerID)

func (*UsedSpaceAnnouncement) SetEpoch 

func (a *UsedSpaceAnnouncement) SetEpoch(v uint64)

func (*UsedSpaceAnnouncement) SetUsedSpace 

func (a *UsedSpaceAnnouncement) SetUsedSpace(v uint64)

func (*UsedSpaceAnnouncement) StableMarshal 

func (a *UsedSpaceAnnouncement) StableMarshal(buf []byte) ([]byte, error)

func (*UsedSpaceAnnouncement) StableSize 

func (a *UsedSpaceAnnouncement) StableSize() (size int)

func (*UsedSpaceAnnouncement) Unmarshal 

func (a *UsedSpaceAnnouncement) Unmarshal(data []byte) error

Source Files

View all Source files

Directories

Path Synopsis

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.