container

package
v0.0.0-...-593dd77 Latest Latest
Warning

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

 Go to latest Published: Jan 30, 2025 License: Apache-2.0 Imports: 10 Imported by: 3

Documentation

Index

Constants

View Source 
const (
	ContainerService_Put_FullMethodName        = "/neo.fs.v2.container.ContainerService/Put"
	ContainerService_Delete_FullMethodName     = "/neo.fs.v2.container.ContainerService/Delete"
	ContainerService_Get_FullMethodName        = "/neo.fs.v2.container.ContainerService/Get"
	ContainerService_List_FullMethodName       = "/neo.fs.v2.container.ContainerService/List"
	ContainerService_ListStream_FullMethodName = "/neo.fs.v2.container.ContainerService/ListStream"
)

Variables

View Source 
var ContainerService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "neo.fs.v2.container.ContainerService",
	HandlerType: (*ContainerServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Put",
			Handler:    _ContainerService_Put_Handler,
		},
		{
			MethodName: "Delete",
			Handler:    _ContainerService_Delete_Handler,
		},
		{
			MethodName: "Get",
			Handler:    _ContainerService_Get_Handler,
		},
		{
			MethodName: "List",
			Handler:    _ContainerService_List_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "ListStream",
			Handler:       _ContainerService_ListStream_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "api/container/grpc/service.proto",
}

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

View Source 
var File_api_container_grpc_service_proto protoreflect.FileDescriptor
View Source 
var File_api_container_grpc_types_proto protoreflect.FileDescriptor

Functions

func RegisterContainerServiceServer 

func RegisterContainerServiceServer(s grpc.ServiceRegistrar, srv ContainerServiceServer)

Types

type Container 

type Container struct {

	// Container format version. Effectively, the version of API library used to
	// create the container.
	Version *grpc.Version `protobuf:"bytes,1,opt,name=version" json:"version,omitempty"`
	// Identifier of the container owner
	OwnerId *grpc.OwnerID `protobuf:"bytes,2,opt,name=owner_id,json=ownerID" json:"owner_id,omitempty"`
	// Nonce is a 16 byte UUIDv4, used to avoid collisions of `ContainerID`s
	Nonce []byte `protobuf:"bytes,3,opt,name=nonce" json:"nonce,omitempty"`
	// `BasicACL` contains access control rules for the owner, system and others
	// groups, as well as permission bits for `BearerToken` and `Extended ACL`
	BasicAcl *uint32 `protobuf:"varint,4,opt,name=basic_acl,json=basicACL" json:"basic_acl,omitempty"`
	// Attributes represent immutable container's meta data
	Attributes []*Container_Attribute `protobuf:"bytes,5,rep,name=attributes" json:"attributes,omitempty"`
	// Placement policy for the object inside the container
	PlacementPolicy *grpc1.PlacementPolicy `protobuf:"bytes,6,opt,name=placement_policy,json=placementPolicy" json:"placement_policy,omitempty"`
	// contains filtered or unexported fields
}

Container is a structure that defines object placement behaviour. Objects can be stored only within containers. They define placement rule, attributes and access control information. An ID of a container is a 32 byte long SHA256 hash of stable-marshalled container message.

func (*Container) ClearBasicAcl 

func (x *Container) ClearBasicAcl()

func (*Container) ClearNonce 

func (x *Container) ClearNonce()

func (*Container) ClearOwnerId 

func (x *Container) ClearOwnerId()

func (*Container) ClearPlacementPolicy 

func (x *Container) ClearPlacementPolicy()

func (*Container) ClearVersion 

func (x *Container) ClearVersion()

func (*Container) GetAttributes 

func (x *Container) GetAttributes() []*Container_Attribute

func (*Container) GetBasicAcl 

func (x *Container) GetBasicAcl() uint32

func (*Container) GetNonce 

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

func (*Container) GetOwnerId 

func (x *Container) GetOwnerId() *grpc.OwnerID

func (*Container) GetPlacementPolicy 

func (x *Container) GetPlacementPolicy() *grpc1.PlacementPolicy

func (*Container) GetVersion 

func (x *Container) GetVersion() *grpc.Version

func (*Container) HasBasicAcl 

func (x *Container) HasBasicAcl() bool

func (*Container) HasNonce 

func (x *Container) HasNonce() bool

func (*Container) HasOwnerId 

func (x *Container) HasOwnerId() bool

func (*Container) HasPlacementPolicy 

func (x *Container) HasPlacementPolicy() bool

func (*Container) HasVersion 

func (x *Container) HasVersion() bool

func (*Container) ProtoMessage 

func (*Container) ProtoMessage()

func (*Container) ProtoReflect 

func (x *Container) ProtoReflect() protoreflect.Message

func (*Container) Reset 

func (x *Container) Reset()

func (*Container) SetAttributes 

func (x *Container) SetAttributes(v []*Container_Attribute)

func (*Container) SetBasicAcl 

func (x *Container) SetBasicAcl(v uint32)

func (*Container) SetNonce 

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

func (*Container) SetOwnerId 

func (x *Container) SetOwnerId(v *grpc.OwnerID)

func (*Container) SetPlacementPolicy 

func (x *Container) SetPlacementPolicy(v *grpc1.PlacementPolicy)

func (*Container) SetVersion 

func (x *Container) SetVersion(v *grpc.Version)

func (*Container) String 

func (x *Container) String() string

type ContainerServiceClient 

type ContainerServiceClient interface {
	// `Put` invokes `Container` smart contract's `Put` method and returns
	// response immediately. After a new block is issued in sidechain, request is
	// verified by Inner Ring nodes. After one more block in sidechain, the
	// container is added into smart contract storage.
	//
	// Statuses:
	//   - **OK** (0, SECTION_SUCCESS): \
	//     request to save the container has been sent to the sidechain;
	//   - Common failures (SECTION_FAILURE_COMMON);
	//   - **CONTAINER_ACCESS_DENIED** (3074, SECTION_CONTAINER): \
	//     container create access denied.
	Put(ctx context.Context, in *PutRequest, opts ...grpc.CallOption) (*PutResponse, error)
	// `Delete` invokes `Container` smart contract's `Delete` method and returns
	// response immediately. After a new block is issued in sidechain, request is
	// verified by Inner Ring nodes. After one more block in sidechain, the
	// container is added into smart contract storage.
	//
	// Statuses:
	//   - **OK** (0, SECTION_SUCCESS): \
	//     request to remove the container has been sent to the sidechain;
	//   - Common failures (SECTION_FAILURE_COMMON);
	//   - **CONTAINER_ACCESS_DENIED** (3074, SECTION_CONTAINER): \
	//     container delete access denied.
	Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*DeleteResponse, error)
	// Returns container structure from `Container` smart contract storage.
	//
	// Statuses:
	//   - **OK** (0, SECTION_SUCCESS): \
	//     container has been successfully read;
	//   - Common failures (SECTION_FAILURE_COMMON);
	//   - **CONTAINER_NOT_FOUND** (3072, SECTION_CONTAINER): \
	//     requested container not found;
	//   - **CONTAINER_ACCESS_DENIED** (3074, SECTION_CONTAINER): \
	//     access to container is denied.
	Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error)
	// Returns all owner's containers from `Container` smart contract storage.
	//
	// Statuses:
	//   - **OK** (0, SECTION_SUCCESS): \
	//     container list has been successfully read;
	//   - Common failures (SECTION_FAILURE_COMMON);
	//   - **CONTAINER_ACCESS_DENIED** (3074, SECTION_CONTAINER): \
	//     container list access denied.
	List(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListResponse, error)
	// Returns all owner's containers from `Container` smart contract storage
	// via stream.
	//
	// Statuses:
	//   - **OK** (0, SECTION_SUCCESS): \
	//     container list has been successfully read;
	//   - Common failures (SECTION_FAILURE_COMMON);
	//   - **CONTAINER_ACCESS_DENIED** (3074, SECTION_CONTAINER): \
	//     container list access denied.
	ListStream(ctx context.Context, in *ListStreamRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[ListStreamResponse], error)
}

ContainerServiceClient is the client API for ContainerService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

`ContainerService` provides API to interact with `Container` smart contract in FrostFS sidechain via other FrostFS nodes. All of those actions can be done equivalently by directly issuing transactions and RPC calls to sidechain nodes.

func NewContainerServiceClient 

func NewContainerServiceClient(cc grpc.ClientConnInterface) ContainerServiceClient

type ContainerServiceServer 

type ContainerServiceServer interface {
	// `Put` invokes `Container` smart contract's `Put` method and returns
	// response immediately. After a new block is issued in sidechain, request is
	// verified by Inner Ring nodes. After one more block in sidechain, the
	// container is added into smart contract storage.
	//
	// Statuses:
	//   - **OK** (0, SECTION_SUCCESS): \
	//     request to save the container has been sent to the sidechain;
	//   - Common failures (SECTION_FAILURE_COMMON);
	//   - **CONTAINER_ACCESS_DENIED** (3074, SECTION_CONTAINER): \
	//     container create access denied.
	Put(context.Context, *PutRequest) (*PutResponse, error)
	// `Delete` invokes `Container` smart contract's `Delete` method and returns
	// response immediately. After a new block is issued in sidechain, request is
	// verified by Inner Ring nodes. After one more block in sidechain, the
	// container is added into smart contract storage.
	//
	// Statuses:
	//   - **OK** (0, SECTION_SUCCESS): \
	//     request to remove the container has been sent to the sidechain;
	//   - Common failures (SECTION_FAILURE_COMMON);
	//   - **CONTAINER_ACCESS_DENIED** (3074, SECTION_CONTAINER): \
	//     container delete access denied.
	Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)
	// Returns container structure from `Container` smart contract storage.
	//
	// Statuses:
	//   - **OK** (0, SECTION_SUCCESS): \
	//     container has been successfully read;
	//   - Common failures (SECTION_FAILURE_COMMON);
	//   - **CONTAINER_NOT_FOUND** (3072, SECTION_CONTAINER): \
	//     requested container not found;
	//   - **CONTAINER_ACCESS_DENIED** (3074, SECTION_CONTAINER): \
	//     access to container is denied.
	Get(context.Context, *GetRequest) (*GetResponse, error)
	// Returns all owner's containers from `Container` smart contract storage.
	//
	// Statuses:
	//   - **OK** (0, SECTION_SUCCESS): \
	//     container list has been successfully read;
	//   - Common failures (SECTION_FAILURE_COMMON);
	//   - **CONTAINER_ACCESS_DENIED** (3074, SECTION_CONTAINER): \
	//     container list access denied.
	List(context.Context, *ListRequest) (*ListResponse, error)
	// Returns all owner's containers from `Container` smart contract storage
	// via stream.
	//
	// Statuses:
	//   - **OK** (0, SECTION_SUCCESS): \
	//     container list has been successfully read;
	//   - Common failures (SECTION_FAILURE_COMMON);
	//   - **CONTAINER_ACCESS_DENIED** (3074, SECTION_CONTAINER): \
	//     container list access denied.
	ListStream(*ListStreamRequest, grpc.ServerStreamingServer[ListStreamResponse]) error
}

ContainerServiceServer is the server API for ContainerService service. All implementations should embed UnimplementedContainerServiceServer for forward compatibility.

`ContainerService` provides API to interact with `Container` smart contract in FrostFS sidechain via other FrostFS nodes. All of those actions can be done equivalently by directly issuing transactions and RPC calls to sidechain nodes.

type ContainerService_ListStreamClient 

type ContainerService_ListStreamClient = grpc.ServerStreamingClient[ListStreamResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type ContainerService_ListStreamServer 

type ContainerService_ListStreamServer = grpc.ServerStreamingServer[ListStreamResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type Container_Attribute 

type Container_Attribute struct {

	// Attribute name key
	Key *string `protobuf:"bytes,1,opt,name=key" json:"key,omitempty"`
	// Attribute value
	Value *string `protobuf:"bytes,2,opt,name=value" json:"value,omitempty"`
	// contains filtered or unexported fields
}

`Attribute` is a user-defined Key-Value metadata pair attached to the container. Container attributes are immutable. They are set at the moment of container creation and can never be added or updated.

Key name must be a container-unique valid UTF-8 string. Value can't be empty. Containers with duplicated attribute names or attributes with empty values will be considered invalid.

There are some "well-known" attributes affecting system behaviour:

  • [ __SYSTEM__NAME ] \ (`__NEOFS__NAME` is deprecated) \ String of a human-friendly container name registered as a domain in NNS contract.
  • [ __SYSTEM__ZONE ] \ (`__NEOFS__ZONE` is deprecated) \ String of a zone for `__SYSTEM__NAME` (`__NEOFS__NAME` is deprecated). Used as a TLD of a domain name in NNS contract. If no zone is specified, use default zone: `container`.
  • [ __SYSTEM__DISABLE_HOMOMORPHIC_HASHING ] \ (`__NEOFS__DISABLE_HOMOMORPHIC_HASHING` is deprecated) \ Disables homomorphic hashing for the container if the value equals "true" string. Any other values are interpreted as missing attribute. Container could be accepted in a FrostFS network only if the global network hashing configuration value corresponds with that attribute's value. After container inclusion, network setting is ignored.

And some well-known attributes used by applications only:

  • Name \ Human-friendly name
  • Timestamp \ User-defined local time of container creation in Unix Timestamp format

func (*Container_Attribute) ClearKey 

func (x *Container_Attribute) ClearKey()

func (*Container_Attribute) ClearValue 

func (x *Container_Attribute) ClearValue()

func (*Container_Attribute) GetKey 

func (x *Container_Attribute) GetKey() string

func (*Container_Attribute) GetValue 

func (x *Container_Attribute) GetValue() string

func (*Container_Attribute) HasKey 

func (x *Container_Attribute) HasKey() bool

func (*Container_Attribute) HasValue 

func (x *Container_Attribute) HasValue() bool

func (*Container_Attribute) ProtoMessage 

func (*Container_Attribute) ProtoMessage()

func (*Container_Attribute) ProtoReflect 

func (x *Container_Attribute) ProtoReflect() protoreflect.Message

func (*Container_Attribute) Reset 

func (x *Container_Attribute) Reset()

func (*Container_Attribute) SetKey 

func (x *Container_Attribute) SetKey(v string)

func (*Container_Attribute) SetValue 

func (x *Container_Attribute) SetValue(v string)

func (*Container_Attribute) String 

func (x *Container_Attribute) String() string

type Container_Attribute_builder 

type Container_Attribute_builder struct {

	// Attribute name key
	Key *string
	// Attribute value
	Value *string
	// contains filtered or unexported fields
}

func (Container_Attribute_builder) Build 

func (b0 Container_Attribute_builder) Build() *Container_Attribute

type Container_builder 

type Container_builder struct {

	// Container format version. Effectively, the version of API library used to
	// create the container.
	Version *grpc.Version
	// Identifier of the container owner
	OwnerId *grpc.OwnerID
	// Nonce is a 16 byte UUIDv4, used to avoid collisions of `ContainerID`s
	Nonce []byte
	// `BasicACL` contains access control rules for the owner, system and others
	// groups, as well as permission bits for `BearerToken` and `Extended ACL`
	BasicAcl *uint32
	// Attributes represent immutable container's meta data
	Attributes []*Container_Attribute
	// Placement policy for the object inside the container
	PlacementPolicy *grpc1.PlacementPolicy
	// contains filtered or unexported fields
}

func (Container_builder) Build 

func (b0 Container_builder) Build() *Container

type DeleteRequest 

type DeleteRequest struct {

	// Body of container delete request message.
	Body *DeleteRequest_Body `protobuf:"bytes,1,opt,name=body" json:"body,omitempty"`
	// Carries request meta information. Header data is used only to regulate
	// message transport and does not affect request execution.
	MetaHeader *grpc.RequestMetaHeader `protobuf:"bytes,2,opt,name=meta_header,json=metaHeader" json:"meta_header,omitempty"`
	// Carries request verification information. This header is used to
	// authenticate the nodes of the message route and check the correctness of
	// transmission.
	VerifyHeader *grpc.RequestVerificationHeader `protobuf:"bytes,3,opt,name=verify_header,json=verifyHeader" json:"verify_header,omitempty"`
	// contains filtered or unexported fields
}

Container removal request

func (*DeleteRequest) ClearBody 

func (x *DeleteRequest) ClearBody()

func (*DeleteRequest) ClearMetaHeader 

func (x *DeleteRequest) ClearMetaHeader()

func (*DeleteRequest) ClearVerifyHeader 

func (x *DeleteRequest) ClearVerifyHeader()

func (*DeleteRequest) GetBody 

func (x *DeleteRequest) GetBody() *DeleteRequest_Body

func (*DeleteRequest) GetMetaHeader 

func (x *DeleteRequest) GetMetaHeader() *grpc.RequestMetaHeader

func (*DeleteRequest) GetVerifyHeader 

func (x *DeleteRequest) GetVerifyHeader() *grpc.RequestVerificationHeader

func (*DeleteRequest) HasBody 

func (x *DeleteRequest) HasBody() bool

func (*DeleteRequest) HasMetaHeader 

func (x *DeleteRequest) HasMetaHeader() bool

func (*DeleteRequest) HasVerifyHeader 

func (x *DeleteRequest) HasVerifyHeader() bool

func (*DeleteRequest) ProtoMessage 

func (*DeleteRequest) ProtoMessage()

func (*DeleteRequest) ProtoReflect 

func (x *DeleteRequest) ProtoReflect() protoreflect.Message

func (*DeleteRequest) Reset 

func (x *DeleteRequest) Reset()

func (*DeleteRequest) SetBody 

func (x *DeleteRequest) SetBody(v *DeleteRequest_Body)

func (*DeleteRequest) SetMetaHeader 

func (x *DeleteRequest) SetMetaHeader(v *grpc.RequestMetaHeader)

func (*DeleteRequest) SetVerifyHeader 

func (x *DeleteRequest) SetVerifyHeader(v *grpc.RequestVerificationHeader)

func (*DeleteRequest) String 

func (x *DeleteRequest) String() string

type DeleteRequest_Body 

type DeleteRequest_Body struct {

	// Identifier of the container to delete from FrostFS
	ContainerId *grpc1.ContainerID `protobuf:"bytes,1,opt,name=container_id,json=containerId" json:"container_id,omitempty"`
	// `ContainerID` signed with the container owner's key according to
	// RFC-6979.
	Signature *grpc1.SignatureRFC6979 `protobuf:"bytes,2,opt,name=signature" json:"signature,omitempty"`
	// contains filtered or unexported fields
}

Container removal request body has signed `ContainerID` as a proof of the container owner's intent. The signature will be verified by `Container` smart contract, so signing algorithm must be supported by NeoVM.

func (*DeleteRequest_Body) ClearContainerId 

func (x *DeleteRequest_Body) ClearContainerId()

func (*DeleteRequest_Body) ClearSignature 

func (x *DeleteRequest_Body) ClearSignature()

func (*DeleteRequest_Body) GetContainerId 

func (x *DeleteRequest_Body) GetContainerId() *grpc1.ContainerID

func (*DeleteRequest_Body) GetSignature 

func (x *DeleteRequest_Body) GetSignature() *grpc1.SignatureRFC6979

func (*DeleteRequest_Body) HasContainerId 

func (x *DeleteRequest_Body) HasContainerId() bool

func (*DeleteRequest_Body) HasSignature 

func (x *DeleteRequest_Body) HasSignature() bool

func (*DeleteRequest_Body) ProtoMessage 

func (*DeleteRequest_Body) ProtoMessage()

func (*DeleteRequest_Body) ProtoReflect 

func (x *DeleteRequest_Body) ProtoReflect() protoreflect.Message

func (*DeleteRequest_Body) Reset 

func (x *DeleteRequest_Body) Reset()

func (*DeleteRequest_Body) SetContainerId 

func (x *DeleteRequest_Body) SetContainerId(v *grpc1.ContainerID)

func (*DeleteRequest_Body) SetSignature 

func (x *DeleteRequest_Body) SetSignature(v *grpc1.SignatureRFC6979)

func (*DeleteRequest_Body) String 

func (x *DeleteRequest_Body) String() string

type DeleteRequest_Body_builder 

type DeleteRequest_Body_builder struct {

	// Identifier of the container to delete from FrostFS
	ContainerId *grpc1.ContainerID
	// `ContainerID` signed with the container owner's key according to
	// RFC-6979.
	Signature *grpc1.SignatureRFC6979
	// contains filtered or unexported fields
}

func (DeleteRequest_Body_builder) Build 

func (b0 DeleteRequest_Body_builder) Build() *DeleteRequest_Body

type DeleteRequest_builder 

type DeleteRequest_builder struct {

	// Body of container delete request message.
	Body *DeleteRequest_Body
	// Carries request meta information. Header data is used only to regulate
	// message transport and does not affect request execution.
	MetaHeader *grpc.RequestMetaHeader
	// Carries request verification information. This header is used to
	// authenticate the nodes of the message route and check the correctness of
	// transmission.
	VerifyHeader *grpc.RequestVerificationHeader
	// contains filtered or unexported fields
}

func (DeleteRequest_builder) Build 

func (b0 DeleteRequest_builder) Build() *DeleteRequest

type DeleteResponse 

type DeleteResponse struct {

	// Body of container delete response message.
	Body *DeleteResponse_Body `protobuf:"bytes,1,opt,name=body" json:"body,omitempty"`
	// Carries response meta information. Header data is used only to regulate
	// message transport and does not affect request execution.
	MetaHeader *grpc.ResponseMetaHeader `protobuf:"bytes,2,opt,name=meta_header,json=metaHeader" json:"meta_header,omitempty"`
	// Carries response verification information. This header is used to
	// authenticate the nodes of the message route and check the correctness of
	// transmission.
	VerifyHeader *grpc.ResponseVerificationHeader `protobuf:"bytes,3,opt,name=verify_header,json=verifyHeader" json:"verify_header,omitempty"`
	// contains filtered or unexported fields
}

`DeleteResponse` has an empty body because delete operation is asynchronous and done via consensus in Inner Ring nodes.

func (*DeleteResponse) ClearBody 

func (x *DeleteResponse) ClearBody()

func (*DeleteResponse) ClearMetaHeader 

func (x *DeleteResponse) ClearMetaHeader()

func (*DeleteResponse) ClearVerifyHeader 

func (x *DeleteResponse) ClearVerifyHeader()

func (*DeleteResponse) GetBody 

func (x *DeleteResponse) GetBody() *DeleteResponse_Body

func (*DeleteResponse) GetMetaHeader 

func (x *DeleteResponse) GetMetaHeader() *grpc.ResponseMetaHeader

func (*DeleteResponse) GetVerifyHeader 

func (x *DeleteResponse) GetVerifyHeader() *grpc.ResponseVerificationHeader

func (*DeleteResponse) HasBody 

func (x *DeleteResponse) HasBody() bool

func (*DeleteResponse) HasMetaHeader 

func (x *DeleteResponse) HasMetaHeader() bool

func (*DeleteResponse) HasVerifyHeader 

func (x *DeleteResponse) HasVerifyHeader() bool

func (*DeleteResponse) ProtoMessage 

func (*DeleteResponse) ProtoMessage()

func (*DeleteResponse) ProtoReflect 

func (x *DeleteResponse) ProtoReflect() protoreflect.Message

func (*DeleteResponse) Reset 

func (x *DeleteResponse) Reset()

func (*DeleteResponse) SetBody 

func (x *DeleteResponse) SetBody(v *DeleteResponse_Body)

func (*DeleteResponse) SetMetaHeader 

func (x *DeleteResponse) SetMetaHeader(v *grpc.ResponseMetaHeader)

func (*DeleteResponse) SetVerifyHeader 

func (x *DeleteResponse) SetVerifyHeader(v *grpc.ResponseVerificationHeader)

func (*DeleteResponse) String 

func (x *DeleteResponse) String() string

type DeleteResponse_Body 

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

`DeleteResponse` has an empty body because delete operation is asynchronous and done via consensus in Inner Ring nodes.

func (*DeleteResponse_Body) ProtoMessage 

func (*DeleteResponse_Body) ProtoMessage()

func (*DeleteResponse_Body) ProtoReflect 

func (x *DeleteResponse_Body) ProtoReflect() protoreflect.Message

func (*DeleteResponse_Body) Reset 

func (x *DeleteResponse_Body) Reset()

func (*DeleteResponse_Body) String 

func (x *DeleteResponse_Body) String() string

type DeleteResponse_Body_builder 

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

func (DeleteResponse_Body_builder) Build 

func (b0 DeleteResponse_Body_builder) Build() *DeleteResponse_Body

type DeleteResponse_builder 

type DeleteResponse_builder struct {

	// Body of container delete response message.
	Body *DeleteResponse_Body
	// Carries response meta information. Header data is used only to regulate
	// message transport and does not affect request execution.
	MetaHeader *grpc.ResponseMetaHeader
	// Carries response verification information. This header is used to
	// authenticate the nodes of the message route and check the correctness of
	// transmission.
	VerifyHeader *grpc.ResponseVerificationHeader
	// contains filtered or unexported fields
}

func (DeleteResponse_builder) Build 

func (b0 DeleteResponse_builder) Build() *DeleteResponse

type GetRequest 

type GetRequest struct {

	// Body of container get request message.
	Body *GetRequest_Body `protobuf:"bytes,1,opt,name=body" json:"body,omitempty"`
	// Carries request meta information. Header data is used only to regulate
	// message transport and does not affect request execution.
	MetaHeader *grpc.RequestMetaHeader `protobuf:"bytes,2,opt,name=meta_header,json=metaHeader" json:"meta_header,omitempty"`
	// Carries request verification information. This header is used to
	// authenticate the nodes of the message route and check the correctness of
	// transmission.
	VerifyHeader *grpc.RequestVerificationHeader `protobuf:"bytes,3,opt,name=verify_header,json=verifyHeader" json:"verify_header,omitempty"`
	// contains filtered or unexported fields
}

Get container structure

func (*GetRequest) ClearBody 

func (x *GetRequest) ClearBody()

func (*GetRequest) ClearMetaHeader 

func (x *GetRequest) ClearMetaHeader()

func (*GetRequest) ClearVerifyHeader 

func (x *GetRequest) ClearVerifyHeader()

func (*GetRequest) GetBody 

func (x *GetRequest) GetBody() *GetRequest_Body

func (*GetRequest) GetMetaHeader 

func (x *GetRequest) GetMetaHeader() *grpc.RequestMetaHeader

func (*GetRequest) GetVerifyHeader 

func (x *GetRequest) GetVerifyHeader() *grpc.RequestVerificationHeader

func (*GetRequest) HasBody 

func (x *GetRequest) HasBody() bool

func (*GetRequest) HasMetaHeader 

func (x *GetRequest) HasMetaHeader() bool

func (*GetRequest) HasVerifyHeader 

func (x *GetRequest) HasVerifyHeader() bool

func (*GetRequest) ProtoMessage 

func (*GetRequest) ProtoMessage()

func (*GetRequest) ProtoReflect 

func (x *GetRequest) ProtoReflect() protoreflect.Message

func (*GetRequest) Reset 

func (x *GetRequest) Reset()

func (*GetRequest) SetBody 

func (x *GetRequest) SetBody(v *GetRequest_Body)

func (*GetRequest) SetMetaHeader 

func (x *GetRequest) SetMetaHeader(v *grpc.RequestMetaHeader)

func (*GetRequest) SetVerifyHeader 

func (x *GetRequest) SetVerifyHeader(v *grpc.RequestVerificationHeader)

func (*GetRequest) String 

func (x *GetRequest) String() string

type GetRequest_Body 

type GetRequest_Body struct {

	// Identifier of the container to get
	ContainerId *grpc1.ContainerID `protobuf:"bytes,1,opt,name=container_id,json=containerId" json:"container_id,omitempty"`
	// contains filtered or unexported fields
}

Get container structure request body.

func (*GetRequest_Body) ClearContainerId 

func (x *GetRequest_Body) ClearContainerId()

func (*GetRequest_Body) GetContainerId 

func (x *GetRequest_Body) GetContainerId() *grpc1.ContainerID

func (*GetRequest_Body) HasContainerId 

func (x *GetRequest_Body) HasContainerId() bool

func (*GetRequest_Body) ProtoMessage 

func (*GetRequest_Body) ProtoMessage()

func (*GetRequest_Body) ProtoReflect 

func (x *GetRequest_Body) ProtoReflect() protoreflect.Message

func (*GetRequest_Body) Reset 

func (x *GetRequest_Body) Reset()

func (*GetRequest_Body) SetContainerId 

func (x *GetRequest_Body) SetContainerId(v *grpc1.ContainerID)

func (*GetRequest_Body) String 

func (x *GetRequest_Body) String() string

type GetRequest_Body_builder 

type GetRequest_Body_builder struct {

	// Identifier of the container to get
	ContainerId *grpc1.ContainerID
	// contains filtered or unexported fields
}

func (GetRequest_Body_builder) Build 

func (b0 GetRequest_Body_builder) Build() *GetRequest_Body

type GetRequest_builder 

type GetRequest_builder struct {

	// Body of container get request message.
	Body *GetRequest_Body
	// Carries request meta information. Header data is used only to regulate
	// message transport and does not affect request execution.
	MetaHeader *grpc.RequestMetaHeader
	// Carries request verification information. This header is used to
	// authenticate the nodes of the message route and check the correctness of
	// transmission.
	VerifyHeader *grpc.RequestVerificationHeader
	// contains filtered or unexported fields
}

func (GetRequest_builder) Build 

func (b0 GetRequest_builder) Build() *GetRequest

type GetResponse 

type GetResponse struct {

	// Body of container get response message.
	Body *GetResponse_Body `protobuf:"bytes,1,opt,name=body" json:"body,omitempty"`
	// Carries response meta information. Header data is used only to regulate
	// message transport and does not affect request execution.
	MetaHeader *grpc.ResponseMetaHeader `protobuf:"bytes,2,opt,name=meta_header,json=metaHeader" json:"meta_header,omitempty"`
	// Carries response verification information. This header is used to
	// authenticate the nodes of the message route and check the correctness of
	// transmission.
	VerifyHeader *grpc.ResponseVerificationHeader `protobuf:"bytes,3,opt,name=verify_header,json=verifyHeader" json:"verify_header,omitempty"`
	// contains filtered or unexported fields
}

Get container structure

func (*GetResponse) ClearBody 

func (x *GetResponse) ClearBody()

func (*GetResponse) ClearMetaHeader 

func (x *GetResponse) ClearMetaHeader()

func (*GetResponse) ClearVerifyHeader 

func (x *GetResponse) ClearVerifyHeader()

func (*GetResponse) GetBody 

func (x *GetResponse) GetBody() *GetResponse_Body

func (*GetResponse) GetMetaHeader 

func (x *GetResponse) GetMetaHeader() *grpc.ResponseMetaHeader

func (*GetResponse) GetVerifyHeader 

func (x *GetResponse) GetVerifyHeader() *grpc.ResponseVerificationHeader

func (*GetResponse) HasBody 

func (x *GetResponse) HasBody() bool

func (*GetResponse) HasMetaHeader 

func (x *GetResponse) HasMetaHeader() bool

func (*GetResponse) HasVerifyHeader 

func (x *GetResponse) HasVerifyHeader() bool

func (*GetResponse) ProtoMessage 

func (*GetResponse) ProtoMessage()

func (*GetResponse) ProtoReflect 

func (x *GetResponse) ProtoReflect() protoreflect.Message

func (*GetResponse) Reset 

func (x *GetResponse) Reset()

func (*GetResponse) SetBody 

func (x *GetResponse) SetBody(v *GetResponse_Body)

func (*GetResponse) SetMetaHeader 

func (x *GetResponse) SetMetaHeader(v *grpc.ResponseMetaHeader)

func (*GetResponse) SetVerifyHeader 

func (x *GetResponse) SetVerifyHeader(v *grpc.ResponseVerificationHeader)

func (*GetResponse) String 

func (x *GetResponse) String() string

type GetResponse_Body 

type GetResponse_Body struct {

	// Requested container structure
	Container *Container `protobuf:"bytes,1,opt,name=container" json:"container,omitempty"`
	// Signature of a stable-marshalled container according to RFC-6979.
	Signature *grpc1.SignatureRFC6979 `protobuf:"bytes,2,opt,name=signature" json:"signature,omitempty"`
	// Session token if the container has been created within the session
	SessionToken *grpc.SessionToken `protobuf:"bytes,3,opt,name=session_token,json=sessionToken" json:"session_token,omitempty"`
	// contains filtered or unexported fields
}

Get container response body does not have container structure signature. It has been already verified upon container creation.

func (*GetResponse_Body) ClearContainer 

func (x *GetResponse_Body) ClearContainer()

func (*GetResponse_Body) ClearSessionToken 

func (x *GetResponse_Body) ClearSessionToken()

func (*GetResponse_Body) ClearSignature 

func (x *GetResponse_Body) ClearSignature()

func (*GetResponse_Body) GetContainer 

func (x *GetResponse_Body) GetContainer() *Container

func (*GetResponse_Body) GetSessionToken 

func (x *GetResponse_Body) GetSessionToken() *grpc.SessionToken

func (*GetResponse_Body) GetSignature 

func (x *GetResponse_Body) GetSignature() *grpc1.SignatureRFC6979

func (*GetResponse_Body) HasContainer 

func (x *GetResponse_Body) HasContainer() bool

func (*GetResponse_Body) HasSessionToken 

func (x *GetResponse_Body) HasSessionToken() bool

func (*GetResponse_Body) HasSignature 

func (x *GetResponse_Body) HasSignature() bool

func (*GetResponse_Body) ProtoMessage 

func (*GetResponse_Body) ProtoMessage()

func (*GetResponse_Body) ProtoReflect 

func (x *GetResponse_Body) ProtoReflect() protoreflect.Message

func (*GetResponse_Body) Reset 

func (x *GetResponse_Body) Reset()

func (*GetResponse_Body) SetContainer 

func (x *GetResponse_Body) SetContainer(v *Container)

func (*GetResponse_Body) SetSessionToken 

func (x *GetResponse_Body) SetSessionToken(v *grpc.SessionToken)

func (*GetResponse_Body) SetSignature 

func (x *GetResponse_Body) SetSignature(v *grpc1.SignatureRFC6979)

func (*GetResponse_Body) String 

func (x *GetResponse_Body) String() string

type GetResponse_Body_builder 

type GetResponse_Body_builder struct {

	// Requested container structure
	Container *Container
	// Signature of a stable-marshalled container according to RFC-6979.
	Signature *grpc1.SignatureRFC6979
	// Session token if the container has been created within the session
	SessionToken *grpc.SessionToken
	// contains filtered or unexported fields
}

func (GetResponse_Body_builder) Build 

func (b0 GetResponse_Body_builder) Build() *GetResponse_Body

type GetResponse_builder 

type GetResponse_builder struct {

	// Body of container get response message.
	Body *GetResponse_Body
	// Carries response meta information. Header data is used only to regulate
	// message transport and does not affect request execution.
	MetaHeader *grpc.ResponseMetaHeader
	// Carries response verification information. This header is used to
	// authenticate the nodes of the message route and check the correctness of
	// transmission.
	VerifyHeader *grpc.ResponseVerificationHeader
	// contains filtered or unexported fields
}

func (GetResponse_builder) Build 

func (b0 GetResponse_builder) Build() *GetResponse

type ListRequest 

type ListRequest struct {

	// Body of list containers request message
	Body *ListRequest_Body `protobuf:"bytes,1,opt,name=body" json:"body,omitempty"`
	// Carries request meta information. Header data is used only to regulate
	// message transport and does not affect request execution.
	MetaHeader *grpc.RequestMetaHeader `protobuf:"bytes,2,opt,name=meta_header,json=metaHeader" json:"meta_header,omitempty"`
	// Carries request verification information. This header is used to
	// authenticate the nodes of the message route and check the correctness of
	// transmission.
	VerifyHeader *grpc.RequestVerificationHeader `protobuf:"bytes,3,opt,name=verify_header,json=verifyHeader" json:"verify_header,omitempty"`
	// contains filtered or unexported fields
}

List containers

func (*ListRequest) ClearBody 

func (x *ListRequest) ClearBody()

func (*ListRequest) ClearMetaHeader 

func (x *ListRequest) ClearMetaHeader()

func (*ListRequest) ClearVerifyHeader 

func (x *ListRequest) ClearVerifyHeader()

func (*ListRequest) GetBody 

func (x *ListRequest) GetBody() *ListRequest_Body

func (*ListRequest) GetMetaHeader 

func (x *ListRequest) GetMetaHeader() *grpc.RequestMetaHeader

func (*ListRequest) GetVerifyHeader 

func (x *ListRequest) GetVerifyHeader() *grpc.RequestVerificationHeader

func (*ListRequest) HasBody 

func (x *ListRequest) HasBody() bool

func (*ListRequest) HasMetaHeader 

func (x *ListRequest) HasMetaHeader() bool

func (*ListRequest) HasVerifyHeader 

func (x *ListRequest) HasVerifyHeader() bool

func (*ListRequest) ProtoMessage 

func (*ListRequest) ProtoMessage()

func (*ListRequest) ProtoReflect 

func (x *ListRequest) ProtoReflect() protoreflect.Message

func (*ListRequest) Reset 

func (x *ListRequest) Reset()

func (*ListRequest) SetBody 

func (x *ListRequest) SetBody(v *ListRequest_Body)

func (*ListRequest) SetMetaHeader 

func (x *ListRequest) SetMetaHeader(v *grpc.RequestMetaHeader)

func (*ListRequest) SetVerifyHeader 

func (x *ListRequest) SetVerifyHeader(v *grpc.RequestVerificationHeader)

func (*ListRequest) String 

func (x *ListRequest) String() string

type ListRequest_Body 

type ListRequest_Body struct {

	// Identifier of the container owner
	OwnerId *grpc1.OwnerID `protobuf:"bytes,1,opt,name=owner_id,json=ownerId" json:"owner_id,omitempty"`
	// contains filtered or unexported fields
}

List containers request body.

func (*ListRequest_Body) ClearOwnerId 

func (x *ListRequest_Body) ClearOwnerId()

func (*ListRequest_Body) GetOwnerId 

func (x *ListRequest_Body) GetOwnerId() *grpc1.OwnerID

func (*ListRequest_Body) HasOwnerId 

func (x *ListRequest_Body) HasOwnerId() bool

func (*ListRequest_Body) ProtoMessage 

func (*ListRequest_Body) ProtoMessage()

func (*ListRequest_Body) ProtoReflect 

func (x *ListRequest_Body) ProtoReflect() protoreflect.Message

func (*ListRequest_Body) Reset 

func (x *ListRequest_Body) Reset()

func (*ListRequest_Body) SetOwnerId 

func (x *ListRequest_Body) SetOwnerId(v *grpc1.OwnerID)

func (*ListRequest_Body) String 

func (x *ListRequest_Body) String() string

type ListRequest_Body_builder 

type ListRequest_Body_builder struct {

	// Identifier of the container owner
	OwnerId *grpc1.OwnerID
	// contains filtered or unexported fields
}

func (ListRequest_Body_builder) Build 

func (b0 ListRequest_Body_builder) Build() *ListRequest_Body

type ListRequest_builder 

type ListRequest_builder struct {

	// Body of list containers request message
	Body *ListRequest_Body
	// Carries request meta information. Header data is used only to regulate
	// message transport and does not affect request execution.
	MetaHeader *grpc.RequestMetaHeader
	// Carries request verification information. This header is used to
	// authenticate the nodes of the message route and check the correctness of
	// transmission.
	VerifyHeader *grpc.RequestVerificationHeader
	// contains filtered or unexported fields
}

func (ListRequest_builder) Build 

func (b0 ListRequest_builder) Build() *ListRequest

type ListResponse 

type ListResponse struct {

	// Body of list containers response message.
	Body *ListResponse_Body `protobuf:"bytes,1,opt,name=body" json:"body,omitempty"`
	// Carries response meta information. Header data is used only to regulate
	// message transport and does not affect request execution.
	MetaHeader *grpc.ResponseMetaHeader `protobuf:"bytes,2,opt,name=meta_header,json=metaHeader" json:"meta_header,omitempty"`
	// Carries response verification information. This header is used to
	// authenticate the nodes of the message route and check the correctness of
	// transmission.
	VerifyHeader *grpc.ResponseVerificationHeader `protobuf:"bytes,3,opt,name=verify_header,json=verifyHeader" json:"verify_header,omitempty"`
	// contains filtered or unexported fields
}

List containers

func (*ListResponse) ClearBody 

func (x *ListResponse) ClearBody()

func (*ListResponse) ClearMetaHeader 

func (x *ListResponse) ClearMetaHeader()

func (*ListResponse) ClearVerifyHeader 

func (x *ListResponse) ClearVerifyHeader()

func (*ListResponse) GetBody 

func (x *ListResponse) GetBody() *ListResponse_Body

func (*ListResponse) GetMetaHeader 

func (x *ListResponse) GetMetaHeader() *grpc.ResponseMetaHeader

func (*ListResponse) GetVerifyHeader 

func (x *ListResponse) GetVerifyHeader() *grpc.ResponseVerificationHeader

func (*ListResponse) HasBody 

func (x *ListResponse) HasBody() bool

func (*ListResponse) HasMetaHeader 

func (x *ListResponse) HasMetaHeader() bool

func (*ListResponse) HasVerifyHeader 

func (x *ListResponse) HasVerifyHeader() bool

func (*ListResponse) ProtoMessage 

func (*ListResponse) ProtoMessage()

func (*ListResponse) ProtoReflect 

func (x *ListResponse) ProtoReflect() protoreflect.Message

func (*ListResponse) Reset 

func (x *ListResponse) Reset()

func (*ListResponse) SetBody 

func (x *ListResponse) SetBody(v *ListResponse_Body)

func (*ListResponse) SetMetaHeader 

func (x *ListResponse) SetMetaHeader(v *grpc.ResponseMetaHeader)

func (*ListResponse) SetVerifyHeader 

func (x *ListResponse) SetVerifyHeader(v *grpc.ResponseVerificationHeader)

func (*ListResponse) String 

func (x *ListResponse) String() string

type ListResponse_Body 

type ListResponse_Body struct {

	// List of `ContainerID`s belonging to the requested `OwnerID`
	ContainerIds []*grpc1.ContainerID `protobuf:"bytes,1,rep,name=container_ids,json=containerIds" json:"container_ids,omitempty"`
	// contains filtered or unexported fields
}

List containers response body.

func (*ListResponse_Body) GetContainerIds 

func (x *ListResponse_Body) GetContainerIds() []*grpc1.ContainerID

func (*ListResponse_Body) ProtoMessage 

func (*ListResponse_Body) ProtoMessage()

func (*ListResponse_Body) ProtoReflect 

func (x *ListResponse_Body) ProtoReflect() protoreflect.Message

func (*ListResponse_Body) Reset 

func (x *ListResponse_Body) Reset()

func (*ListResponse_Body) SetContainerIds 

func (x *ListResponse_Body) SetContainerIds(v []*grpc1.ContainerID)

func (*ListResponse_Body) String 

func (x *ListResponse_Body) String() string

type ListResponse_Body_builder 

type ListResponse_Body_builder struct {

	// List of `ContainerID`s belonging to the requested `OwnerID`
	ContainerIds []*grpc1.ContainerID
	// contains filtered or unexported fields
}

func (ListResponse_Body_builder) Build 

func (b0 ListResponse_Body_builder) Build() *ListResponse_Body

type ListResponse_builder 

type ListResponse_builder struct {

	// Body of list containers response message.
	Body *ListResponse_Body
	// Carries response meta information. Header data is used only to regulate
	// message transport and does not affect request execution.
	MetaHeader *grpc.ResponseMetaHeader
	// Carries response verification information. This header is used to
	// authenticate the nodes of the message route and check the correctness of
	// transmission.
	VerifyHeader *grpc.ResponseVerificationHeader
	// contains filtered or unexported fields
}

func (ListResponse_builder) Build 

func (b0 ListResponse_builder) Build() *ListResponse

type ListStreamRequest 

type ListStreamRequest struct {

	// Body of list containers stream request message.
	Body *ListStreamRequest_Body `protobuf:"bytes,1,opt,name=body" json:"body,omitempty"`
	// Carries request meta information. Header data is used only to regulate
	// message transport and does not affect request execution.
	MetaHeader *grpc.RequestMetaHeader `protobuf:"bytes,2,opt,name=meta_header,json=metaHeader" json:"meta_header,omitempty"`
	// Carries request verification information. This header is used to
	// authenticate the nodes of the message route and check the correctness of
	// transmission.
	VerifyHeader *grpc.RequestVerificationHeader `protobuf:"bytes,3,opt,name=verify_header,json=verifyHeader" json:"verify_header,omitempty"`
	// contains filtered or unexported fields
}

List containers stream

func (*ListStreamRequest) ClearBody 

func (x *ListStreamRequest) ClearBody()

func (*ListStreamRequest) ClearMetaHeader 

func (x *ListStreamRequest) ClearMetaHeader()

func (*ListStreamRequest) ClearVerifyHeader 

func (x *ListStreamRequest) ClearVerifyHeader()

func (*ListStreamRequest) GetBody 

func (x *ListStreamRequest) GetBody() *ListStreamRequest_Body

func (*ListStreamRequest) GetMetaHeader 

func (x *ListStreamRequest) GetMetaHeader() *grpc.RequestMetaHeader

func (*ListStreamRequest) GetVerifyHeader 

func (x *ListStreamRequest) GetVerifyHeader() *grpc.RequestVerificationHeader

func (*ListStreamRequest) HasBody 

func (x *ListStreamRequest) HasBody() bool

func (*ListStreamRequest) HasMetaHeader 

func (x *ListStreamRequest) HasMetaHeader() bool

func (*ListStreamRequest) HasVerifyHeader 

func (x *ListStreamRequest) HasVerifyHeader() bool

func (*ListStreamRequest) ProtoMessage 

func (*ListStreamRequest) ProtoMessage()

func (*ListStreamRequest) ProtoReflect 

func (x *ListStreamRequest) ProtoReflect() protoreflect.Message

func (*ListStreamRequest) Reset 

func (x *ListStreamRequest) Reset()

func (*ListStreamRequest) SetBody 

func (x *ListStreamRequest) SetBody(v *ListStreamRequest_Body)

func (*ListStreamRequest) SetMetaHeader 

func (x *ListStreamRequest) SetMetaHeader(v *grpc.RequestMetaHeader)

func (*ListStreamRequest) SetVerifyHeader 

func (x *ListStreamRequest) SetVerifyHeader(v *grpc.RequestVerificationHeader)

func (*ListStreamRequest) String 

func (x *ListStreamRequest) String() string

type ListStreamRequest_Body 

type ListStreamRequest_Body struct {

	// Identifier of the container owner.
	OwnerId *grpc1.OwnerID `protobuf:"bytes,1,opt,name=owner_id,json=ownerId" json:"owner_id,omitempty"`
	// contains filtered or unexported fields
}

List containers stream request body.

func (*ListStreamRequest_Body) ClearOwnerId 

func (x *ListStreamRequest_Body) ClearOwnerId()

func (*ListStreamRequest_Body) GetOwnerId 

func (x *ListStreamRequest_Body) GetOwnerId() *grpc1.OwnerID

func (*ListStreamRequest_Body) HasOwnerId 

func (x *ListStreamRequest_Body) HasOwnerId() bool

func (*ListStreamRequest_Body) ProtoMessage 

func (*ListStreamRequest_Body) ProtoMessage()

func (*ListStreamRequest_Body) ProtoReflect 

func (x *ListStreamRequest_Body) ProtoReflect() protoreflect.Message

func (*ListStreamRequest_Body) Reset 

func (x *ListStreamRequest_Body) Reset()

func (*ListStreamRequest_Body) SetOwnerId 

func (x *ListStreamRequest_Body) SetOwnerId(v *grpc1.OwnerID)

func (*ListStreamRequest_Body) String 

func (x *ListStreamRequest_Body) String() string

type ListStreamRequest_Body_builder 

type ListStreamRequest_Body_builder struct {

	// Identifier of the container owner.
	OwnerId *grpc1.OwnerID
	// contains filtered or unexported fields
}

func (ListStreamRequest_Body_builder) Build 

func (b0 ListStreamRequest_Body_builder) Build() *ListStreamRequest_Body

type ListStreamRequest_builder 

type ListStreamRequest_builder struct {

	// Body of list containers stream request message.
	Body *ListStreamRequest_Body
	// Carries request meta information. Header data is used only to regulate
	// message transport and does not affect request execution.
	MetaHeader *grpc.RequestMetaHeader
	// Carries request verification information. This header is used to
	// authenticate the nodes of the message route and check the correctness of
	// transmission.
	VerifyHeader *grpc.RequestVerificationHeader
	// contains filtered or unexported fields
}

func (ListStreamRequest_builder) Build 

func (b0 ListStreamRequest_builder) Build() *ListStreamRequest

type ListStreamResponse 

type ListStreamResponse struct {

	// Body of list containers stream response message.
	Body *ListStreamResponse_Body `protobuf:"bytes,1,opt,name=body" json:"body,omitempty"`
	// Carries response meta information. Header data is used only to regulate
	// message transport and does not affect request execution.
	MetaHeader *grpc.ResponseMetaHeader `protobuf:"bytes,2,opt,name=meta_header,json=metaHeader" json:"meta_header,omitempty"`
	// Carries response verification information. This header is used to
	// authenticate the nodes of the message route and check the correctness of
	// transmission.
	VerifyHeader *grpc.ResponseVerificationHeader `protobuf:"bytes,3,opt,name=verify_header,json=verifyHeader" json:"verify_header,omitempty"`
	// contains filtered or unexported fields
}

List containers stream

func (*ListStreamResponse) ClearBody 

func (x *ListStreamResponse) ClearBody()

func (*ListStreamResponse) ClearMetaHeader 

func (x *ListStreamResponse) ClearMetaHeader()

func (*ListStreamResponse) ClearVerifyHeader 

func (x *ListStreamResponse) ClearVerifyHeader()

func (*ListStreamResponse) GetBody 

func (x *ListStreamResponse) GetBody() *ListStreamResponse_Body

func (*ListStreamResponse) GetMetaHeader 

func (x *ListStreamResponse) GetMetaHeader() *grpc.ResponseMetaHeader

func (*ListStreamResponse) GetVerifyHeader 

func (x *ListStreamResponse) GetVerifyHeader() *grpc.ResponseVerificationHeader

func (*ListStreamResponse) HasBody 

func (x *ListStreamResponse) HasBody() bool

func (*ListStreamResponse) HasMetaHeader 

func (x *ListStreamResponse) HasMetaHeader() bool

func (*ListStreamResponse) HasVerifyHeader 

func (x *ListStreamResponse) HasVerifyHeader() bool

func (*ListStreamResponse) ProtoMessage 

func (*ListStreamResponse) ProtoMessage()

func (*ListStreamResponse) ProtoReflect 

func (x *ListStreamResponse) ProtoReflect() protoreflect.Message

func (*ListStreamResponse) Reset 

func (x *ListStreamResponse) Reset()

func (*ListStreamResponse) SetBody 

func (x *ListStreamResponse) SetBody(v *ListStreamResponse_Body)

func (*ListStreamResponse) SetMetaHeader 

func (x *ListStreamResponse) SetMetaHeader(v *grpc.ResponseMetaHeader)

func (*ListStreamResponse) SetVerifyHeader 

func (x *ListStreamResponse) SetVerifyHeader(v *grpc.ResponseVerificationHeader)

func (*ListStreamResponse) String 

func (x *ListStreamResponse) String() string

type ListStreamResponse_Body 

type ListStreamResponse_Body struct {

	// List of `ContainerID`s belonging to the requested `OwnerID`
	ContainerIds []*grpc1.ContainerID `protobuf:"bytes,1,rep,name=container_ids,json=containerIds" json:"container_ids,omitempty"`
	// contains filtered or unexported fields
}

List containers stream response body.

func (*ListStreamResponse_Body) GetContainerIds 

func (x *ListStreamResponse_Body) GetContainerIds() []*grpc1.ContainerID

func (*ListStreamResponse_Body) ProtoMessage 

func (*ListStreamResponse_Body) ProtoMessage()

func (*ListStreamResponse_Body) ProtoReflect 

func (x *ListStreamResponse_Body) ProtoReflect() protoreflect.Message

func (*ListStreamResponse_Body) Reset 

func (x *ListStreamResponse_Body) Reset()

func (*ListStreamResponse_Body) SetContainerIds 

func (x *ListStreamResponse_Body) SetContainerIds(v []*grpc1.ContainerID)

func (*ListStreamResponse_Body) String 

func (x *ListStreamResponse_Body) String() string

type ListStreamResponse_Body_builder 

type ListStreamResponse_Body_builder struct {

	// List of `ContainerID`s belonging to the requested `OwnerID`
	ContainerIds []*grpc1.ContainerID
	// contains filtered or unexported fields
}

func (ListStreamResponse_Body_builder) Build 

func (b0 ListStreamResponse_Body_builder) Build() *ListStreamResponse_Body

type ListStreamResponse_builder 

type ListStreamResponse_builder struct {

	// Body of list containers stream response message.
	Body *ListStreamResponse_Body
	// Carries response meta information. Header data is used only to regulate
	// message transport and does not affect request execution.
	MetaHeader *grpc.ResponseMetaHeader
	// Carries response verification information. This header is used to
	// authenticate the nodes of the message route and check the correctness of
	// transmission.
	VerifyHeader *grpc.ResponseVerificationHeader
	// contains filtered or unexported fields
}

func (ListStreamResponse_builder) Build 

func (b0 ListStreamResponse_builder) Build() *ListStreamResponse

type PutRequest 

type PutRequest struct {

	// Body of container put request message.
	Body *PutRequest_Body `protobuf:"bytes,1,opt,name=body" json:"body,omitempty"`
	// Carries request meta information. Header data is used only to regulate
	// message transport and does not affect request execution.
	MetaHeader *grpc.RequestMetaHeader `protobuf:"bytes,2,opt,name=meta_header,json=metaHeader" json:"meta_header,omitempty"`
	// Carries request verification information. This header is used to
	// authenticate the nodes of the message route and check the correctness of
	// transmission.
	VerifyHeader *grpc.RequestVerificationHeader `protobuf:"bytes,3,opt,name=verify_header,json=verifyHeader" json:"verify_header,omitempty"`
	// contains filtered or unexported fields
}

New FrostFS Container creation request

func (*PutRequest) ClearBody 

func (x *PutRequest) ClearBody()

func (*PutRequest) ClearMetaHeader 

func (x *PutRequest) ClearMetaHeader()

func (*PutRequest) ClearVerifyHeader 

func (x *PutRequest) ClearVerifyHeader()

func (*PutRequest) GetBody 

func (x *PutRequest) GetBody() *PutRequest_Body

func (*PutRequest) GetMetaHeader 

func (x *PutRequest) GetMetaHeader() *grpc.RequestMetaHeader

func (*PutRequest) GetVerifyHeader 

func (x *PutRequest) GetVerifyHeader() *grpc.RequestVerificationHeader

func (*PutRequest) HasBody 

func (x *PutRequest) HasBody() bool

func (*PutRequest) HasMetaHeader 

func (x *PutRequest) HasMetaHeader() bool

func (*PutRequest) HasVerifyHeader 

func (x *PutRequest) HasVerifyHeader() bool

func (*PutRequest) ProtoMessage 

func (*PutRequest) ProtoMessage()

func (*PutRequest) ProtoReflect 

func (x *PutRequest) ProtoReflect() protoreflect.Message

func (*PutRequest) Reset 

func (x *PutRequest) Reset()

func (*PutRequest) SetBody 

func (x *PutRequest) SetBody(v *PutRequest_Body)

func (*PutRequest) SetMetaHeader 

func (x *PutRequest) SetMetaHeader(v *grpc.RequestMetaHeader)

func (*PutRequest) SetVerifyHeader 

func (x *PutRequest) SetVerifyHeader(v *grpc.RequestVerificationHeader)

func (*PutRequest) String 

func (x *PutRequest) String() string

type PutRequest_Body 

type PutRequest_Body struct {

	// Container structure to register in FrostFS
	Container *Container `protobuf:"bytes,1,opt,name=container" json:"container,omitempty"`
	// Signature of a stable-marshalled container according to RFC-6979.
	Signature *grpc1.SignatureRFC6979 `protobuf:"bytes,2,opt,name=signature" json:"signature,omitempty"`
	// contains filtered or unexported fields
}

Container creation request has container structure's signature as a separate field. It's not stored in sidechain, just verified on container creation by `Container` smart contract. `ContainerID` is a SHA256 hash of the stable-marshalled container strucutre, hence there is no need for additional signature checks.

func (*PutRequest_Body) ClearContainer 

func (x *PutRequest_Body) ClearContainer()

func (*PutRequest_Body) ClearSignature 

func (x *PutRequest_Body) ClearSignature()

func (*PutRequest_Body) GetContainer 

func (x *PutRequest_Body) GetContainer() *Container

func (*PutRequest_Body) GetSignature 

func (x *PutRequest_Body) GetSignature() *grpc1.SignatureRFC6979

func (*PutRequest_Body) HasContainer 

func (x *PutRequest_Body) HasContainer() bool

func (*PutRequest_Body) HasSignature 

func (x *PutRequest_Body) HasSignature() bool

func (*PutRequest_Body) ProtoMessage 

func (*PutRequest_Body) ProtoMessage()

func (*PutRequest_Body) ProtoReflect 

func (x *PutRequest_Body) ProtoReflect() protoreflect.Message

func (*PutRequest_Body) Reset 

func (x *PutRequest_Body) Reset()

func (*PutRequest_Body) SetContainer 

func (x *PutRequest_Body) SetContainer(v *Container)

func (*PutRequest_Body) SetSignature 

func (x *PutRequest_Body) SetSignature(v *grpc1.SignatureRFC6979)

func (*PutRequest_Body) String 

func (x *PutRequest_Body) String() string

type PutRequest_Body_builder 

type PutRequest_Body_builder struct {

	// Container structure to register in FrostFS
	Container *Container
	// Signature of a stable-marshalled container according to RFC-6979.
	Signature *grpc1.SignatureRFC6979
	// contains filtered or unexported fields
}

func (PutRequest_Body_builder) Build 

func (b0 PutRequest_Body_builder) Build() *PutRequest_Body

type PutRequest_builder 

type PutRequest_builder struct {

	// Body of container put request message.
	Body *PutRequest_Body
	// Carries request meta information. Header data is used only to regulate
	// message transport and does not affect request execution.
	MetaHeader *grpc.RequestMetaHeader
	// Carries request verification information. This header is used to
	// authenticate the nodes of the message route and check the correctness of
	// transmission.
	VerifyHeader *grpc.RequestVerificationHeader
	// contains filtered or unexported fields
}

func (PutRequest_builder) Build 

func (b0 PutRequest_builder) Build() *PutRequest

type PutResponse 

type PutResponse struct {

	// Body of container put response message.
	Body *PutResponse_Body `protobuf:"bytes,1,opt,name=body" json:"body,omitempty"`
	// Carries response meta information. Header data is used only to regulate
	// message transport and does not affect request execution.
	MetaHeader *grpc.ResponseMetaHeader `protobuf:"bytes,2,opt,name=meta_header,json=metaHeader" json:"meta_header,omitempty"`
	// Carries response verification information. This header is used to
	// authenticate the nodes of the message route and check the correctness of
	// transmission.
	VerifyHeader *grpc.ResponseVerificationHeader `protobuf:"bytes,3,opt,name=verify_header,json=verifyHeader" json:"verify_header,omitempty"`
	// contains filtered or unexported fields
}

New FrostFS Container creation response

func (*PutResponse) ClearBody 

func (x *PutResponse) ClearBody()

func (*PutResponse) ClearMetaHeader 

func (x *PutResponse) ClearMetaHeader()

func (*PutResponse) ClearVerifyHeader 

func (x *PutResponse) ClearVerifyHeader()

func (*PutResponse) GetBody 

func (x *PutResponse) GetBody() *PutResponse_Body

func (*PutResponse) GetMetaHeader 

func (x *PutResponse) GetMetaHeader() *grpc.ResponseMetaHeader

func (*PutResponse) GetVerifyHeader 

func (x *PutResponse) GetVerifyHeader() *grpc.ResponseVerificationHeader

func (*PutResponse) HasBody 

func (x *PutResponse) HasBody() bool

func (*PutResponse) HasMetaHeader 

func (x *PutResponse) HasMetaHeader() bool

func (*PutResponse) HasVerifyHeader 

func (x *PutResponse) HasVerifyHeader() bool

func (*PutResponse) ProtoMessage 

func (*PutResponse) ProtoMessage()

func (*PutResponse) ProtoReflect 

func (x *PutResponse) ProtoReflect() protoreflect.Message

func (*PutResponse) Reset 

func (x *PutResponse) Reset()

func (*PutResponse) SetBody 

func (x *PutResponse) SetBody(v *PutResponse_Body)

func (*PutResponse) SetMetaHeader 

func (x *PutResponse) SetMetaHeader(v *grpc.ResponseMetaHeader)

func (*PutResponse) SetVerifyHeader 

func (x *PutResponse) SetVerifyHeader(v *grpc.ResponseVerificationHeader)

func (*PutResponse) String 

func (x *PutResponse) String() string

type PutResponse_Body 

type PutResponse_Body struct {

	// Unique identifier of the newly created container
	ContainerId *grpc1.ContainerID `protobuf:"bytes,1,opt,name=container_id,json=containerId" json:"container_id,omitempty"`
	// contains filtered or unexported fields
}

Container put response body contains information about the newly registered container as seen by `Container` smart contract. `ContainerID` can be calculated beforehand from the container structure and compared to the one returned here to make sure everything has been done as expected.

func (*PutResponse_Body) ClearContainerId 

func (x *PutResponse_Body) ClearContainerId()

func (*PutResponse_Body) GetContainerId 

func (x *PutResponse_Body) GetContainerId() *grpc1.ContainerID

func (*PutResponse_Body) HasContainerId 

func (x *PutResponse_Body) HasContainerId() bool

func (*PutResponse_Body) ProtoMessage 

func (*PutResponse_Body) ProtoMessage()

func (*PutResponse_Body) ProtoReflect 

func (x *PutResponse_Body) ProtoReflect() protoreflect.Message

func (*PutResponse_Body) Reset 

func (x *PutResponse_Body) Reset()

func (*PutResponse_Body) SetContainerId 

func (x *PutResponse_Body) SetContainerId(v *grpc1.ContainerID)

func (*PutResponse_Body) String 

func (x *PutResponse_Body) String() string

type PutResponse_Body_builder 

type PutResponse_Body_builder struct {

	// Unique identifier of the newly created container
	ContainerId *grpc1.ContainerID
	// contains filtered or unexported fields
}

func (PutResponse_Body_builder) Build 

func (b0 PutResponse_Body_builder) Build() *PutResponse_Body

type PutResponse_builder 

type PutResponse_builder struct {

	// Body of container put response message.
	Body *PutResponse_Body
	// Carries response meta information. Header data is used only to regulate
	// message transport and does not affect request execution.
	MetaHeader *grpc.ResponseMetaHeader
	// Carries response verification information. This header is used to
	// authenticate the nodes of the message route and check the correctness of
	// transmission.
	VerifyHeader *grpc.ResponseVerificationHeader
	// contains filtered or unexported fields
}

func (PutResponse_builder) Build 

func (b0 PutResponse_builder) Build() *PutResponse

type UnimplementedContainerServiceServer 

type UnimplementedContainerServiceServer struct{}

UnimplementedContainerServiceServer should be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedContainerServiceServer) Delete 

func (UnimplementedContainerServiceServer) Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)

func (UnimplementedContainerServiceServer) Get 

func (UnimplementedContainerServiceServer) Get(context.Context, *GetRequest) (*GetResponse, error)

func (UnimplementedContainerServiceServer) List 

func (UnimplementedContainerServiceServer) List(context.Context, *ListRequest) (*ListResponse, error)

func (UnimplementedContainerServiceServer) ListStream 

func (UnimplementedContainerServiceServer) ListStream(*ListStreamRequest, grpc.ServerStreamingServer[ListStreamResponse]) error

func (UnimplementedContainerServiceServer) Put 

func (UnimplementedContainerServiceServer) Put(context.Context, *PutRequest) (*PutResponse, error)

type UnsafeContainerServiceServer 

type UnsafeContainerServiceServer interface {
	// contains filtered or unexported methods
}

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

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.