session

package
v0.0.0-...-2b8329e Latest Latest
Warning

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

 Go to latest Published: Feb 28, 2025 License: Apache-2.0 Imports: 10 Imported by: 2

Documentation

Index

Constants

View Source 
const (
	SessionService_Create_FullMethodName = "/neo.fs.v2.session.SessionService/Create"
)
View Source 
const SessionToken_Body_Container_case case_SessionToken_Body_Context = 6
View Source 
const SessionToken_Body_Context_not_set_case case_SessionToken_Body_Context = 0
View Source 
const SessionToken_Body_Object_case case_SessionToken_Body_Context = 5

Variables

View Source 
var (
	ObjectSessionContext_Verb_name = map[int32]string{
		0: "VERB_UNSPECIFIED",
		1: "PUT",
		2: "GET",
		3: "HEAD",
		4: "SEARCH",
		5: "DELETE",
		6: "RANGE",
		7: "RANGEHASH",
		8: "PATCH",
	}
	ObjectSessionContext_Verb_value = map[string]int32{
		"VERB_UNSPECIFIED": 0,
		"PUT":              1,
		"GET":              2,
		"HEAD":             3,
		"SEARCH":           4,
		"DELETE":           5,
		"RANGE":            6,
		"RANGEHASH":        7,
		"PATCH":            8,
	}
)

Enum value maps for ObjectSessionContext_Verb.

View Source 
var (
	ContainerSessionContext_Verb_name = map[int32]string{
		0: "VERB_UNSPECIFIED",
		1: "PUT",
		2: "DELETE",
		3: "SETEACL",
	}
	ContainerSessionContext_Verb_value = map[string]int32{
		"VERB_UNSPECIFIED": 0,
		"PUT":              1,
		"DELETE":           2,
		"SETEACL":          3,
	}
)

Enum value maps for ContainerSessionContext_Verb.

View Source 
var File_api_session_grpc_service_proto protoreflect.FileDescriptor
View Source 
var File_api_session_grpc_types_proto protoreflect.FileDescriptor
View Source 
var SessionService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "neo.fs.v2.session.SessionService",
	HandlerType: (*SessionServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Create",
			Handler:    _SessionService_Create_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "api/session/grpc/service.proto",
}

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

Functions

func RegisterSessionServiceServer 

func RegisterSessionServiceServer(s grpc.ServiceRegistrar, srv SessionServiceServer)

Types

type ContainerSessionContext 

type ContainerSessionContext struct {

	// Type of request for which the token is issued
	Verb *ContainerSessionContext_Verb `protobuf:"varint,1,opt,name=verb,enum=neo.fs.v2.session.ContainerSessionContext_Verb" json:"verb,omitempty"`
	// Spreads the action to all owner containers.
	// If set, container_id field is ignored.
	Wildcard *bool `protobuf:"varint,2,opt,name=wildcard" json:"wildcard,omitempty"`
	// Particular container to which the action applies.
	// Ignored if wildcard flag is set.
	ContainerId *grpc.ContainerID `protobuf:"bytes,3,opt,name=container_id,json=containerID" json:"container_id,omitempty"`
	// contains filtered or unexported fields
}

Context information for Session Tokens related to ContainerService requests.

func (*ContainerSessionContext) ClearContainerId 

func (x *ContainerSessionContext) ClearContainerId()

func (*ContainerSessionContext) ClearVerb 

func (x *ContainerSessionContext) ClearVerb()

func (*ContainerSessionContext) ClearWildcard 

func (x *ContainerSessionContext) ClearWildcard()

func (*ContainerSessionContext) GetContainerId 

func (x *ContainerSessionContext) GetContainerId() *grpc.ContainerID

func (*ContainerSessionContext) GetVerb 

func (x *ContainerSessionContext) GetVerb() ContainerSessionContext_Verb

func (*ContainerSessionContext) GetWildcard 

func (x *ContainerSessionContext) GetWildcard() bool

func (*ContainerSessionContext) HasContainerId 

func (x *ContainerSessionContext) HasContainerId() bool

func (*ContainerSessionContext) HasVerb 

func (x *ContainerSessionContext) HasVerb() bool

func (*ContainerSessionContext) HasWildcard 

func (x *ContainerSessionContext) HasWildcard() bool

func (*ContainerSessionContext) ProtoMessage 

func (*ContainerSessionContext) ProtoMessage()

func (*ContainerSessionContext) ProtoReflect 

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

func (*ContainerSessionContext) Reset 

func (x *ContainerSessionContext) Reset()

func (*ContainerSessionContext) SetContainerId 

func (x *ContainerSessionContext) SetContainerId(v *grpc.ContainerID)

func (*ContainerSessionContext) SetVerb 

func (x *ContainerSessionContext) SetVerb(v ContainerSessionContext_Verb)

func (*ContainerSessionContext) SetWildcard 

func (x *ContainerSessionContext) SetWildcard(v bool)

func (*ContainerSessionContext) String 

func (x *ContainerSessionContext) String() string

type ContainerSessionContext_Verb 

type ContainerSessionContext_Verb int32

Container request verbs 

const (
	// Unknown verb
	ContainerSessionContext_VERB_UNSPECIFIED ContainerSessionContext_Verb = 0
	// Refers to container.Put RPC call
	ContainerSessionContext_PUT ContainerSessionContext_Verb = 1
	// Refers to container.Delete RPC call
	ContainerSessionContext_DELETE ContainerSessionContext_Verb = 2
	// Refers to container.SetExtendedACL RPC call
	ContainerSessionContext_SETEACL ContainerSessionContext_Verb = 3
)

func (ContainerSessionContext_Verb) Descriptor 

func (ContainerSessionContext_Verb) Descriptor() protoreflect.EnumDescriptor

func (ContainerSessionContext_Verb) Enum 

func (x ContainerSessionContext_Verb) Enum() *ContainerSessionContext_Verb

func (ContainerSessionContext_Verb) Number 

func (x ContainerSessionContext_Verb) Number() protoreflect.EnumNumber

func (ContainerSessionContext_Verb) String 

func (x ContainerSessionContext_Verb) String() string

func (ContainerSessionContext_Verb) Type 

func (ContainerSessionContext_Verb) Type() protoreflect.EnumType

type ContainerSessionContext_builder 

type ContainerSessionContext_builder struct {

	// Type of request for which the token is issued
	Verb *ContainerSessionContext_Verb
	// Spreads the action to all owner containers.
	// If set, container_id field is ignored.
	Wildcard *bool
	// Particular container to which the action applies.
	// Ignored if wildcard flag is set.
	ContainerId *grpc.ContainerID
	// contains filtered or unexported fields
}

func (ContainerSessionContext_builder) Build 

func (b0 ContainerSessionContext_builder) Build() *ContainerSessionContext

type CreateRequest 

type CreateRequest struct {

	// Body of a create session token request message.
	Body *CreateRequest_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 *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 *RequestVerificationHeader `protobuf:"bytes,3,opt,name=verify_header,json=verifyHeader" json:"verify_header,omitempty"`
	// contains filtered or unexported fields
}

Information necessary for opening a session.

func (*CreateRequest) ClearBody 

func (x *CreateRequest) ClearBody()

func (*CreateRequest) ClearMetaHeader 

func (x *CreateRequest) ClearMetaHeader()

func (*CreateRequest) ClearVerifyHeader 

func (x *CreateRequest) ClearVerifyHeader()

func (*CreateRequest) GetBody 

func (x *CreateRequest) GetBody() *CreateRequest_Body

func (*CreateRequest) GetMetaHeader 

func (x *CreateRequest) GetMetaHeader() *RequestMetaHeader

func (*CreateRequest) GetVerifyHeader 

func (x *CreateRequest) GetVerifyHeader() *RequestVerificationHeader

func (*CreateRequest) HasBody 

func (x *CreateRequest) HasBody() bool

func (*CreateRequest) HasMetaHeader 

func (x *CreateRequest) HasMetaHeader() bool

func (*CreateRequest) HasVerifyHeader 

func (x *CreateRequest) HasVerifyHeader() bool

func (*CreateRequest) ProtoMessage 

func (*CreateRequest) ProtoMessage()

func (*CreateRequest) ProtoReflect 

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

func (*CreateRequest) Reset 

func (x *CreateRequest) Reset()

func (*CreateRequest) SetBody 

func (x *CreateRequest) SetBody(v *CreateRequest_Body)

func (*CreateRequest) SetMetaHeader 

func (x *CreateRequest) SetMetaHeader(v *RequestMetaHeader)

func (*CreateRequest) SetVerifyHeader 

func (x *CreateRequest) SetVerifyHeader(v *RequestVerificationHeader)

func (*CreateRequest) String 

func (x *CreateRequest) String() string

type CreateRequest_Body 

type CreateRequest_Body struct {

	// Session initiating user's or node's key derived `OwnerID`
	OwnerId *grpc.OwnerID `protobuf:"bytes,1,opt,name=owner_id,json=ownerId" json:"owner_id,omitempty"`
	// Session expiration `Epoch`
	Expiration *uint64 `protobuf:"varint,2,opt,name=expiration" json:"expiration,omitempty"`
	// contains filtered or unexported fields
}

Session creation request body

func (*CreateRequest_Body) ClearExpiration 

func (x *CreateRequest_Body) ClearExpiration()

func (*CreateRequest_Body) ClearOwnerId 

func (x *CreateRequest_Body) ClearOwnerId()

func (*CreateRequest_Body) GetExpiration 

func (x *CreateRequest_Body) GetExpiration() uint64

func (*CreateRequest_Body) GetOwnerId 

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

func (*CreateRequest_Body) HasExpiration 

func (x *CreateRequest_Body) HasExpiration() bool

func (*CreateRequest_Body) HasOwnerId 

func (x *CreateRequest_Body) HasOwnerId() bool

func (*CreateRequest_Body) ProtoMessage 

func (*CreateRequest_Body) ProtoMessage()

func (*CreateRequest_Body) ProtoReflect 

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

func (*CreateRequest_Body) Reset 

func (x *CreateRequest_Body) Reset()

func (*CreateRequest_Body) SetExpiration 

func (x *CreateRequest_Body) SetExpiration(v uint64)

func (*CreateRequest_Body) SetOwnerId 

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

func (*CreateRequest_Body) String 

func (x *CreateRequest_Body) String() string

type CreateRequest_Body_builder 

type CreateRequest_Body_builder struct {

	// Session initiating user's or node's key derived `OwnerID`
	OwnerId *grpc.OwnerID
	// Session expiration `Epoch`
	Expiration *uint64
	// contains filtered or unexported fields
}

func (CreateRequest_Body_builder) Build 

func (b0 CreateRequest_Body_builder) Build() *CreateRequest_Body

type CreateRequest_builder 

type CreateRequest_builder struct {

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

func (CreateRequest_builder) Build 

func (b0 CreateRequest_builder) Build() *CreateRequest

type CreateResponse 

type CreateResponse struct {

	// Body of create session token response message.
	Body *CreateResponse_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 *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 *ResponseVerificationHeader `protobuf:"bytes,3,opt,name=verify_header,json=verifyHeader" json:"verify_header,omitempty"`
	// contains filtered or unexported fields
}

Information about the opened session.

func (*CreateResponse) ClearBody 

func (x *CreateResponse) ClearBody()

func (*CreateResponse) ClearMetaHeader 

func (x *CreateResponse) ClearMetaHeader()

func (*CreateResponse) ClearVerifyHeader 

func (x *CreateResponse) ClearVerifyHeader()

func (*CreateResponse) GetBody 

func (x *CreateResponse) GetBody() *CreateResponse_Body

func (*CreateResponse) GetMetaHeader 

func (x *CreateResponse) GetMetaHeader() *ResponseMetaHeader

func (*CreateResponse) GetVerifyHeader 

func (x *CreateResponse) GetVerifyHeader() *ResponseVerificationHeader

func (*CreateResponse) HasBody 

func (x *CreateResponse) HasBody() bool

func (*CreateResponse) HasMetaHeader 

func (x *CreateResponse) HasMetaHeader() bool

func (*CreateResponse) HasVerifyHeader 

func (x *CreateResponse) HasVerifyHeader() bool

func (*CreateResponse) ProtoMessage 

func (*CreateResponse) ProtoMessage()

func (*CreateResponse) ProtoReflect 

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

func (*CreateResponse) Reset 

func (x *CreateResponse) Reset()

func (*CreateResponse) SetBody 

func (x *CreateResponse) SetBody(v *CreateResponse_Body)

func (*CreateResponse) SetMetaHeader 

func (x *CreateResponse) SetMetaHeader(v *ResponseMetaHeader)

func (*CreateResponse) SetVerifyHeader 

func (x *CreateResponse) SetVerifyHeader(v *ResponseVerificationHeader)

func (*CreateResponse) String 

func (x *CreateResponse) String() string

type CreateResponse_Body 

type CreateResponse_Body struct {

	// Identifier of a newly created session
	Id []byte `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
	// Public key used for session
	SessionKey []byte `protobuf:"bytes,2,opt,name=session_key,json=sessionKey" json:"session_key,omitempty"`
	// contains filtered or unexported fields
}

Session creation response body

func (*CreateResponse_Body) ClearId 

func (x *CreateResponse_Body) ClearId()

func (*CreateResponse_Body) ClearSessionKey 

func (x *CreateResponse_Body) ClearSessionKey()

func (*CreateResponse_Body) GetId 

func (x *CreateResponse_Body) GetId() []byte

func (*CreateResponse_Body) GetSessionKey 

func (x *CreateResponse_Body) GetSessionKey() []byte

func (*CreateResponse_Body) HasId 

func (x *CreateResponse_Body) HasId() bool

func (*CreateResponse_Body) HasSessionKey 

func (x *CreateResponse_Body) HasSessionKey() bool

func (*CreateResponse_Body) ProtoMessage 

func (*CreateResponse_Body) ProtoMessage()

func (*CreateResponse_Body) ProtoReflect 

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

func (*CreateResponse_Body) Reset 

func (x *CreateResponse_Body) Reset()

func (*CreateResponse_Body) SetId 

func (x *CreateResponse_Body) SetId(v []byte)

func (*CreateResponse_Body) SetSessionKey 

func (x *CreateResponse_Body) SetSessionKey(v []byte)

func (*CreateResponse_Body) String 

func (x *CreateResponse_Body) String() string

type CreateResponse_Body_builder 

type CreateResponse_Body_builder struct {

	// Identifier of a newly created session
	Id []byte
	// Public key used for session
	SessionKey []byte
	// contains filtered or unexported fields
}

func (CreateResponse_Body_builder) Build 

func (b0 CreateResponse_Body_builder) Build() *CreateResponse_Body

type CreateResponse_builder 

type CreateResponse_builder struct {

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

func (CreateResponse_builder) Build 

func (b0 CreateResponse_builder) Build() *CreateResponse

type ObjectSessionContext 

type ObjectSessionContext struct {

	// Type of request for which the token is issued
	Verb *ObjectSessionContext_Verb `protobuf:"varint,1,opt,name=verb,enum=neo.fs.v2.session.ObjectSessionContext_Verb" json:"verb,omitempty"`
	// Object session target. MUST be correctly formed and set. If `objects`
	// field is not empty, then the session applies only to these elements,
	// otherwise, to all objects from the specified container.
	Target *ObjectSessionContext_Target `protobuf:"bytes,2,opt,name=target" json:"target,omitempty"`
	// contains filtered or unexported fields
}

Context information for Session Tokens related to ObjectService requests

func (*ObjectSessionContext) ClearTarget 

func (x *ObjectSessionContext) ClearTarget()

func (*ObjectSessionContext) ClearVerb 

func (x *ObjectSessionContext) ClearVerb()

func (*ObjectSessionContext) GetTarget 

func (x *ObjectSessionContext) GetTarget() *ObjectSessionContext_Target

func (*ObjectSessionContext) GetVerb 

func (x *ObjectSessionContext) GetVerb() ObjectSessionContext_Verb

func (*ObjectSessionContext) HasTarget 

func (x *ObjectSessionContext) HasTarget() bool

func (*ObjectSessionContext) HasVerb 

func (x *ObjectSessionContext) HasVerb() bool

func (*ObjectSessionContext) ProtoMessage 

func (*ObjectSessionContext) ProtoMessage()

func (*ObjectSessionContext) ProtoReflect 

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

func (*ObjectSessionContext) Reset 

func (x *ObjectSessionContext) Reset()

func (*ObjectSessionContext) SetTarget 

func (x *ObjectSessionContext) SetTarget(v *ObjectSessionContext_Target)

func (*ObjectSessionContext) SetVerb 

func (x *ObjectSessionContext) SetVerb(v ObjectSessionContext_Verb)

func (*ObjectSessionContext) String 

func (x *ObjectSessionContext) String() string

type ObjectSessionContext_Target 

type ObjectSessionContext_Target struct {

	// Indicates which container the session is spread to. Field MUST be set
	// and correct.
	Container *grpc.ContainerID `protobuf:"bytes,1,opt,name=container" json:"container,omitempty"`
	// Indicates which objects the session is spread to. Objects are expected
	// to be stored in the FrostFS container referenced by `container` field.
	// Each element MUST have correct format.
	Objects []*grpc.ObjectID `protobuf:"bytes,2,rep,name=objects" json:"objects,omitempty"`
	// contains filtered or unexported fields
}

Carries objects involved in the object session.

func (*ObjectSessionContext_Target) ClearContainer 

func (x *ObjectSessionContext_Target) ClearContainer()

func (*ObjectSessionContext_Target) GetContainer 

func (x *ObjectSessionContext_Target) GetContainer() *grpc.ContainerID

func (*ObjectSessionContext_Target) GetObjects 

func (x *ObjectSessionContext_Target) GetObjects() []*grpc.ObjectID

func (*ObjectSessionContext_Target) HasContainer 

func (x *ObjectSessionContext_Target) HasContainer() bool

func (*ObjectSessionContext_Target) ProtoMessage 

func (*ObjectSessionContext_Target) ProtoMessage()

func (*ObjectSessionContext_Target) ProtoReflect 

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

func (*ObjectSessionContext_Target) Reset 

func (x *ObjectSessionContext_Target) Reset()

func (*ObjectSessionContext_Target) SetContainer 

func (x *ObjectSessionContext_Target) SetContainer(v *grpc.ContainerID)

func (*ObjectSessionContext_Target) SetObjects 

func (x *ObjectSessionContext_Target) SetObjects(v []*grpc.ObjectID)

func (*ObjectSessionContext_Target) String 

func (x *ObjectSessionContext_Target) String() string

type ObjectSessionContext_Target_builder 

type ObjectSessionContext_Target_builder struct {

	// Indicates which container the session is spread to. Field MUST be set
	// and correct.
	Container *grpc.ContainerID
	// Indicates which objects the session is spread to. Objects are expected
	// to be stored in the FrostFS container referenced by `container` field.
	// Each element MUST have correct format.
	Objects []*grpc.ObjectID
	// contains filtered or unexported fields
}

func (ObjectSessionContext_Target_builder) Build 

func (b0 ObjectSessionContext_Target_builder) Build() *ObjectSessionContext_Target

type ObjectSessionContext_Verb 

type ObjectSessionContext_Verb int32

Object request verbs 

const (
	// Unknown verb
	ObjectSessionContext_VERB_UNSPECIFIED ObjectSessionContext_Verb = 0
	// Refers to object.Put RPC call
	ObjectSessionContext_PUT ObjectSessionContext_Verb = 1
	// Refers to object.Get RPC call
	ObjectSessionContext_GET ObjectSessionContext_Verb = 2
	// Refers to object.Head RPC call
	ObjectSessionContext_HEAD ObjectSessionContext_Verb = 3
	// Refers to object.Search RPC call
	ObjectSessionContext_SEARCH ObjectSessionContext_Verb = 4
	// Refers to object.Delete RPC call
	ObjectSessionContext_DELETE ObjectSessionContext_Verb = 5
	// Refers to object.GetRange RPC call
	ObjectSessionContext_RANGE ObjectSessionContext_Verb = 6
	// Refers to object.GetRangeHash RPC call
	ObjectSessionContext_RANGEHASH ObjectSessionContext_Verb = 7
	// Refers to object.Patch RPC call
	ObjectSessionContext_PATCH ObjectSessionContext_Verb = 8
)

func (ObjectSessionContext_Verb) Descriptor 

func (ObjectSessionContext_Verb) Descriptor() protoreflect.EnumDescriptor

func (ObjectSessionContext_Verb) Enum 

func (x ObjectSessionContext_Verb) Enum() *ObjectSessionContext_Verb

func (ObjectSessionContext_Verb) Number 

func (x ObjectSessionContext_Verb) Number() protoreflect.EnumNumber

func (ObjectSessionContext_Verb) String 

func (x ObjectSessionContext_Verb) String() string

func (ObjectSessionContext_Verb) Type 

func (ObjectSessionContext_Verb) Type() protoreflect.EnumType

type ObjectSessionContext_builder 

type ObjectSessionContext_builder struct {

	// Type of request for which the token is issued
	Verb *ObjectSessionContext_Verb
	// Object session target. MUST be correctly formed and set. If `objects`
	// field is not empty, then the session applies only to these elements,
	// otherwise, to all objects from the specified container.
	Target *ObjectSessionContext_Target
	// contains filtered or unexported fields
}

func (ObjectSessionContext_builder) Build 

func (b0 ObjectSessionContext_builder) Build() *ObjectSessionContext

type RequestMetaHeader 

type RequestMetaHeader struct {

	// Peer's API version used
	Version *grpc.Version `protobuf:"bytes,1,opt,name=version" json:"version,omitempty"`
	// Peer's local epoch number. Set to 0 if unknown.
	Epoch *uint64 `protobuf:"varint,2,opt,name=epoch" json:"epoch,omitempty"`
	// Maximum number of intermediate nodes in the request route
	Ttl *uint32 `protobuf:"varint,3,opt,name=ttl" json:"ttl,omitempty"`
	// Request X-Headers
	XHeaders []*XHeader `protobuf:"bytes,4,rep,name=x_headers,json=xHeaders" json:"x_headers,omitempty"`
	// Session token within which the request is sent
	SessionToken *SessionToken `protobuf:"bytes,5,opt,name=session_token,json=sessionToken" json:"session_token,omitempty"`
	// `BearerToken` with eACL overrides for the request
	BearerToken *grpc1.BearerToken `protobuf:"bytes,6,opt,name=bearer_token,json=bearerToken" json:"bearer_token,omitempty"`
	// `RequestMetaHeader` of the origin request
	Origin *RequestMetaHeader `protobuf:"bytes,7,opt,name=origin" json:"origin,omitempty"`
	// FrostFS network magic. Must match the value for the network
	// that the server belongs to.
	MagicNumber *uint64 `protobuf:"varint,8,opt,name=magic_number,json=magicNumber" json:"magic_number,omitempty"`
	// contains filtered or unexported fields
}

Meta information attached to the request. When forwarded between peers, request meta headers are folded in matryoshka style.

func (*RequestMetaHeader) ClearBearerToken 

func (x *RequestMetaHeader) ClearBearerToken()

func (*RequestMetaHeader) ClearEpoch 

func (x *RequestMetaHeader) ClearEpoch()

func (*RequestMetaHeader) ClearMagicNumber 

func (x *RequestMetaHeader) ClearMagicNumber()

func (*RequestMetaHeader) ClearOrigin 

func (x *RequestMetaHeader) ClearOrigin()

func (*RequestMetaHeader) ClearSessionToken 

func (x *RequestMetaHeader) ClearSessionToken()

func (*RequestMetaHeader) ClearTtl 

func (x *RequestMetaHeader) ClearTtl()

func (*RequestMetaHeader) ClearVersion 

func (x *RequestMetaHeader) ClearVersion()

func (*RequestMetaHeader) GetBearerToken 

func (x *RequestMetaHeader) GetBearerToken() *grpc1.BearerToken

func (*RequestMetaHeader) GetEpoch 

func (x *RequestMetaHeader) GetEpoch() uint64

func (*RequestMetaHeader) GetMagicNumber 

func (x *RequestMetaHeader) GetMagicNumber() uint64

func (*RequestMetaHeader) GetOrigin 

func (x *RequestMetaHeader) GetOrigin() *RequestMetaHeader

func (*RequestMetaHeader) GetSessionToken 

func (x *RequestMetaHeader) GetSessionToken() *SessionToken

func (*RequestMetaHeader) GetTtl 

func (x *RequestMetaHeader) GetTtl() uint32

func (*RequestMetaHeader) GetVersion 

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

func (*RequestMetaHeader) GetXHeaders 

func (x *RequestMetaHeader) GetXHeaders() []*XHeader

func (*RequestMetaHeader) HasBearerToken 

func (x *RequestMetaHeader) HasBearerToken() bool

func (*RequestMetaHeader) HasEpoch 

func (x *RequestMetaHeader) HasEpoch() bool

func (*RequestMetaHeader) HasMagicNumber 

func (x *RequestMetaHeader) HasMagicNumber() bool

func (*RequestMetaHeader) HasOrigin 

func (x *RequestMetaHeader) HasOrigin() bool

func (*RequestMetaHeader) HasSessionToken 

func (x *RequestMetaHeader) HasSessionToken() bool

func (*RequestMetaHeader) HasTtl 

func (x *RequestMetaHeader) HasTtl() bool

func (*RequestMetaHeader) HasVersion 

func (x *RequestMetaHeader) HasVersion() bool

func (*RequestMetaHeader) ProtoMessage 

func (*RequestMetaHeader) ProtoMessage()

func (*RequestMetaHeader) ProtoReflect 

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

func (*RequestMetaHeader) Reset 

func (x *RequestMetaHeader) Reset()

func (*RequestMetaHeader) SetBearerToken 

func (x *RequestMetaHeader) SetBearerToken(v *grpc1.BearerToken)

func (*RequestMetaHeader) SetEpoch 

func (x *RequestMetaHeader) SetEpoch(v uint64)

func (*RequestMetaHeader) SetMagicNumber 

func (x *RequestMetaHeader) SetMagicNumber(v uint64)

func (*RequestMetaHeader) SetOrigin 

func (x *RequestMetaHeader) SetOrigin(v *RequestMetaHeader)

func (*RequestMetaHeader) SetSessionToken 

func (x *RequestMetaHeader) SetSessionToken(v *SessionToken)

func (*RequestMetaHeader) SetTtl 

func (x *RequestMetaHeader) SetTtl(v uint32)

func (*RequestMetaHeader) SetVersion 

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

func (*RequestMetaHeader) SetXHeaders 

func (x *RequestMetaHeader) SetXHeaders(v []*XHeader)

func (*RequestMetaHeader) String 

func (x *RequestMetaHeader) String() string

type RequestMetaHeader_builder 

type RequestMetaHeader_builder struct {

	// Peer's API version used
	Version *grpc.Version
	// Peer's local epoch number. Set to 0 if unknown.
	Epoch *uint64
	// Maximum number of intermediate nodes in the request route
	Ttl *uint32
	// Request X-Headers
	XHeaders []*XHeader
	// Session token within which the request is sent
	SessionToken *SessionToken
	// `BearerToken` with eACL overrides for the request
	BearerToken *grpc1.BearerToken
	// `RequestMetaHeader` of the origin request
	Origin *RequestMetaHeader
	// FrostFS network magic. Must match the value for the network
	// that the server belongs to.
	MagicNumber *uint64
	// contains filtered or unexported fields
}

func (RequestMetaHeader_builder) Build 

func (b0 RequestMetaHeader_builder) Build() *RequestMetaHeader

type RequestVerificationHeader 

type RequestVerificationHeader struct {

	// Request Body signature. Should be generated once by the request initiator.
	BodySignature *grpc.Signature `protobuf:"bytes,1,opt,name=body_signature,json=bodySignature" json:"body_signature,omitempty"`
	// Request Meta signature is added and signed by each intermediate node
	MetaSignature *grpc.Signature `protobuf:"bytes,2,opt,name=meta_signature,json=metaSignature" json:"meta_signature,omitempty"`
	// Signature of previous hops
	OriginSignature *grpc.Signature `protobuf:"bytes,3,opt,name=origin_signature,json=originSignature" json:"origin_signature,omitempty"`
	// Chain of previous hops signatures
	Origin *RequestVerificationHeader `protobuf:"bytes,4,opt,name=origin" json:"origin,omitempty"`
	// contains filtered or unexported fields
}

Verification info for the request signed by all intermediate nodes.

func (*RequestVerificationHeader) ClearBodySignature 

func (x *RequestVerificationHeader) ClearBodySignature()

func (*RequestVerificationHeader) ClearMetaSignature 

func (x *RequestVerificationHeader) ClearMetaSignature()

func (*RequestVerificationHeader) ClearOrigin 

func (x *RequestVerificationHeader) ClearOrigin()

func (*RequestVerificationHeader) ClearOriginSignature 

func (x *RequestVerificationHeader) ClearOriginSignature()

func (*RequestVerificationHeader) GetBodySignature 

func (x *RequestVerificationHeader) GetBodySignature() *grpc.Signature

func (*RequestVerificationHeader) GetMetaSignature 

func (x *RequestVerificationHeader) GetMetaSignature() *grpc.Signature

func (*RequestVerificationHeader) GetOrigin 

func (x *RequestVerificationHeader) GetOrigin() *RequestVerificationHeader

func (*RequestVerificationHeader) GetOriginSignature 

func (x *RequestVerificationHeader) GetOriginSignature() *grpc.Signature

func (*RequestVerificationHeader) HasBodySignature 

func (x *RequestVerificationHeader) HasBodySignature() bool

func (*RequestVerificationHeader) HasMetaSignature 

func (x *RequestVerificationHeader) HasMetaSignature() bool

func (*RequestVerificationHeader) HasOrigin 

func (x *RequestVerificationHeader) HasOrigin() bool

func (*RequestVerificationHeader) HasOriginSignature 

func (x *RequestVerificationHeader) HasOriginSignature() bool

func (*RequestVerificationHeader) ProtoMessage 

func (*RequestVerificationHeader) ProtoMessage()

func (*RequestVerificationHeader) ProtoReflect 

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

func (*RequestVerificationHeader) Reset 

func (x *RequestVerificationHeader) Reset()

func (*RequestVerificationHeader) SetBodySignature 

func (x *RequestVerificationHeader) SetBodySignature(v *grpc.Signature)

func (*RequestVerificationHeader) SetMetaSignature 

func (x *RequestVerificationHeader) SetMetaSignature(v *grpc.Signature)

func (*RequestVerificationHeader) SetOrigin 

func (x *RequestVerificationHeader) SetOrigin(v *RequestVerificationHeader)

func (*RequestVerificationHeader) SetOriginSignature 

func (x *RequestVerificationHeader) SetOriginSignature(v *grpc.Signature)

func (*RequestVerificationHeader) String 

func (x *RequestVerificationHeader) String() string

type RequestVerificationHeader_builder 

type RequestVerificationHeader_builder struct {

	// Request Body signature. Should be generated once by the request initiator.
	BodySignature *grpc.Signature
	// Request Meta signature is added and signed by each intermediate node
	MetaSignature *grpc.Signature
	// Signature of previous hops
	OriginSignature *grpc.Signature
	// Chain of previous hops signatures
	Origin *RequestVerificationHeader
	// contains filtered or unexported fields
}

func (RequestVerificationHeader_builder) Build 

func (b0 RequestVerificationHeader_builder) Build() *RequestVerificationHeader

type ResponseMetaHeader 

type ResponseMetaHeader struct {

	// Peer's API version used
	Version *grpc.Version `protobuf:"bytes,1,opt,name=version" json:"version,omitempty"`
	// Peer's local epoch number
	Epoch *uint64 `protobuf:"varint,2,opt,name=epoch" json:"epoch,omitempty"`
	// Maximum number of intermediate nodes in the request route
	Ttl *uint32 `protobuf:"varint,3,opt,name=ttl" json:"ttl,omitempty"`
	// Response X-Headers
	XHeaders []*XHeader `protobuf:"bytes,4,rep,name=x_headers,json=xHeaders" json:"x_headers,omitempty"`
	// `ResponseMetaHeader` of the origin request
	Origin *ResponseMetaHeader `protobuf:"bytes,5,opt,name=origin" json:"origin,omitempty"`
	// Status return
	Status *grpc2.Status `protobuf:"bytes,6,opt,name=status" json:"status,omitempty"`
	// contains filtered or unexported fields
}

Information about the response

func (*ResponseMetaHeader) ClearEpoch 

func (x *ResponseMetaHeader) ClearEpoch()

func (*ResponseMetaHeader) ClearOrigin 

func (x *ResponseMetaHeader) ClearOrigin()

func (*ResponseMetaHeader) ClearStatus 

func (x *ResponseMetaHeader) ClearStatus()

func (*ResponseMetaHeader) ClearTtl 

func (x *ResponseMetaHeader) ClearTtl()

func (*ResponseMetaHeader) ClearVersion 

func (x *ResponseMetaHeader) ClearVersion()

func (*ResponseMetaHeader) GetEpoch 

func (x *ResponseMetaHeader) GetEpoch() uint64

func (*ResponseMetaHeader) GetOrigin 

func (x *ResponseMetaHeader) GetOrigin() *ResponseMetaHeader

func (*ResponseMetaHeader) GetStatus 

func (x *ResponseMetaHeader) GetStatus() *grpc2.Status

func (*ResponseMetaHeader) GetTtl 

func (x *ResponseMetaHeader) GetTtl() uint32

func (*ResponseMetaHeader) GetVersion 

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

func (*ResponseMetaHeader) GetXHeaders 

func (x *ResponseMetaHeader) GetXHeaders() []*XHeader

func (*ResponseMetaHeader) HasEpoch 

func (x *ResponseMetaHeader) HasEpoch() bool

func (*ResponseMetaHeader) HasOrigin 

func (x *ResponseMetaHeader) HasOrigin() bool

func (*ResponseMetaHeader) HasStatus 

func (x *ResponseMetaHeader) HasStatus() bool

func (*ResponseMetaHeader) HasTtl 

func (x *ResponseMetaHeader) HasTtl() bool

func (*ResponseMetaHeader) HasVersion 

func (x *ResponseMetaHeader) HasVersion() bool

func (*ResponseMetaHeader) ProtoMessage 

func (*ResponseMetaHeader) ProtoMessage()

func (*ResponseMetaHeader) ProtoReflect 

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

func (*ResponseMetaHeader) Reset 

func (x *ResponseMetaHeader) Reset()

func (*ResponseMetaHeader) SetEpoch 

func (x *ResponseMetaHeader) SetEpoch(v uint64)

func (*ResponseMetaHeader) SetOrigin 

func (x *ResponseMetaHeader) SetOrigin(v *ResponseMetaHeader)

func (*ResponseMetaHeader) SetStatus 

func (x *ResponseMetaHeader) SetStatus(v *grpc2.Status)

func (*ResponseMetaHeader) SetTtl 

func (x *ResponseMetaHeader) SetTtl(v uint32)

func (*ResponseMetaHeader) SetVersion 

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

func (*ResponseMetaHeader) SetXHeaders 

func (x *ResponseMetaHeader) SetXHeaders(v []*XHeader)

func (*ResponseMetaHeader) String 

func (x *ResponseMetaHeader) String() string

type ResponseMetaHeader_builder 

type ResponseMetaHeader_builder struct {

	// Peer's API version used
	Version *grpc.Version
	// Peer's local epoch number
	Epoch *uint64
	// Maximum number of intermediate nodes in the request route
	Ttl *uint32
	// Response X-Headers
	XHeaders []*XHeader
	// `ResponseMetaHeader` of the origin request
	Origin *ResponseMetaHeader
	// Status return
	Status *grpc2.Status
	// contains filtered or unexported fields
}

func (ResponseMetaHeader_builder) Build 

func (b0 ResponseMetaHeader_builder) Build() *ResponseMetaHeader

type ResponseVerificationHeader 

type ResponseVerificationHeader struct {

	// Response Body signature. Should be generated once by an answering node.
	BodySignature *grpc.Signature `protobuf:"bytes,1,opt,name=body_signature,json=bodySignature" json:"body_signature,omitempty"`
	// Response Meta signature is added and signed by each intermediate node
	MetaSignature *grpc.Signature `protobuf:"bytes,2,opt,name=meta_signature,json=metaSignature" json:"meta_signature,omitempty"`
	// Signature of previous hops
	OriginSignature *grpc.Signature `protobuf:"bytes,3,opt,name=origin_signature,json=originSignature" json:"origin_signature,omitempty"`
	// Chain of previous hops signatures
	Origin *ResponseVerificationHeader `protobuf:"bytes,4,opt,name=origin" json:"origin,omitempty"`
	// contains filtered or unexported fields
}

Verification info for the response signed by all intermediate nodes

func (*ResponseVerificationHeader) ClearBodySignature 

func (x *ResponseVerificationHeader) ClearBodySignature()

func (*ResponseVerificationHeader) ClearMetaSignature 

func (x *ResponseVerificationHeader) ClearMetaSignature()

func (*ResponseVerificationHeader) ClearOrigin 

func (x *ResponseVerificationHeader) ClearOrigin()

func (*ResponseVerificationHeader) ClearOriginSignature 

func (x *ResponseVerificationHeader) ClearOriginSignature()

func (*ResponseVerificationHeader) GetBodySignature 

func (x *ResponseVerificationHeader) GetBodySignature() *grpc.Signature

func (*ResponseVerificationHeader) GetMetaSignature 

func (x *ResponseVerificationHeader) GetMetaSignature() *grpc.Signature

func (*ResponseVerificationHeader) GetOrigin 

func (x *ResponseVerificationHeader) GetOrigin() *ResponseVerificationHeader

func (*ResponseVerificationHeader) GetOriginSignature 

func (x *ResponseVerificationHeader) GetOriginSignature() *grpc.Signature

func (*ResponseVerificationHeader) HasBodySignature 

func (x *ResponseVerificationHeader) HasBodySignature() bool

func (*ResponseVerificationHeader) HasMetaSignature 

func (x *ResponseVerificationHeader) HasMetaSignature() bool

func (*ResponseVerificationHeader) HasOrigin 

func (x *ResponseVerificationHeader) HasOrigin() bool

func (*ResponseVerificationHeader) HasOriginSignature 

func (x *ResponseVerificationHeader) HasOriginSignature() bool

func (*ResponseVerificationHeader) ProtoMessage 

func (*ResponseVerificationHeader) ProtoMessage()

func (*ResponseVerificationHeader) ProtoReflect 

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

func (*ResponseVerificationHeader) Reset 

func (x *ResponseVerificationHeader) Reset()

func (*ResponseVerificationHeader) SetBodySignature 

func (x *ResponseVerificationHeader) SetBodySignature(v *grpc.Signature)

func (*ResponseVerificationHeader) SetMetaSignature 

func (x *ResponseVerificationHeader) SetMetaSignature(v *grpc.Signature)

func (*ResponseVerificationHeader) SetOrigin 

func (x *ResponseVerificationHeader) SetOrigin(v *ResponseVerificationHeader)

func (*ResponseVerificationHeader) SetOriginSignature 

func (x *ResponseVerificationHeader) SetOriginSignature(v *grpc.Signature)

func (*ResponseVerificationHeader) String 

func (x *ResponseVerificationHeader) String() string

type ResponseVerificationHeader_builder 

type ResponseVerificationHeader_builder struct {

	// Response Body signature. Should be generated once by an answering node.
	BodySignature *grpc.Signature
	// Response Meta signature is added and signed by each intermediate node
	MetaSignature *grpc.Signature
	// Signature of previous hops
	OriginSignature *grpc.Signature
	// Chain of previous hops signatures
	Origin *ResponseVerificationHeader
	// contains filtered or unexported fields
}

func (ResponseVerificationHeader_builder) Build 

func (b0 ResponseVerificationHeader_builder) Build() *ResponseVerificationHeader

type SessionServiceClient 

type SessionServiceClient interface {
	// Open a new session between two peers.
	//
	// Statuses:
	// - **OK** (0, SECTION_SUCCESS):
	// session has been successfully opened;
	// - Common failures (SECTION_FAILURE_COMMON).
	Create(ctx context.Context, in *CreateRequest, opts ...grpc.CallOption) (*CreateResponse, error)
}

SessionServiceClient is the client API for SessionService 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.

`SessionService` allows to establish a temporary trust relationship between two peer nodes and generate a `SessionToken` as the proof of trust to be attached in requests for further verification. Please see corresponding section of FrostFS Technical Specification for details.

func NewSessionServiceClient 

func NewSessionServiceClient(cc grpc.ClientConnInterface) SessionServiceClient

type SessionServiceServer 

type SessionServiceServer interface {
	// Open a new session between two peers.
	//
	// Statuses:
	// - **OK** (0, SECTION_SUCCESS):
	// session has been successfully opened;
	// - Common failures (SECTION_FAILURE_COMMON).
	Create(context.Context, *CreateRequest) (*CreateResponse, error)
}

SessionServiceServer is the server API for SessionService service. All implementations should embed UnimplementedSessionServiceServer for forward compatibility.

`SessionService` allows to establish a temporary trust relationship between two peer nodes and generate a `SessionToken` as the proof of trust to be attached in requests for further verification. Please see corresponding section of FrostFS Technical Specification for details.

type SessionToken 

type SessionToken struct {

	// Session Token contains the proof of trust between peers to be attached in
	// requests for further verification. Please see corresponding section of
	// FrostFS Technical Specification for details.
	Body *SessionToken_Body `protobuf:"bytes,1,opt,name=body" json:"body,omitempty"`
	// Signature of `SessionToken` information
	Signature *grpc.Signature `protobuf:"bytes,2,opt,name=signature" json:"signature,omitempty"`
	// contains filtered or unexported fields
}

FrostFS Session Token.

func (*SessionToken) ClearBody 

func (x *SessionToken) ClearBody()

func (*SessionToken) ClearSignature 

func (x *SessionToken) ClearSignature()

func (*SessionToken) GetBody 

func (x *SessionToken) GetBody() *SessionToken_Body

func (*SessionToken) GetSignature 

func (x *SessionToken) GetSignature() *grpc.Signature

func (*SessionToken) HasBody 

func (x *SessionToken) HasBody() bool

func (*SessionToken) HasSignature 

func (x *SessionToken) HasSignature() bool

func (*SessionToken) ProtoMessage 

func (*SessionToken) ProtoMessage()

func (*SessionToken) ProtoReflect 

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

func (*SessionToken) Reset 

func (x *SessionToken) Reset()

func (*SessionToken) SetBody 

func (x *SessionToken) SetBody(v *SessionToken_Body)

func (*SessionToken) SetSignature 

func (x *SessionToken) SetSignature(v *grpc.Signature)

func (*SessionToken) String 

func (x *SessionToken) String() string

type SessionToken_Body 

type SessionToken_Body struct {

	// Token identifier is a valid UUIDv4 in binary form
	Id []byte `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
	// Identifier of the session initiator
	OwnerId *grpc.OwnerID `protobuf:"bytes,2,opt,name=owner_id,json=ownerID" json:"owner_id,omitempty"`
	// Lifetime of the session
	Lifetime *SessionToken_Body_TokenLifetime `protobuf:"bytes,3,opt,name=lifetime" json:"lifetime,omitempty"`
	// Public key used in session
	SessionKey []byte `protobuf:"bytes,4,opt,name=session_key,json=sessionKey" json:"session_key,omitempty"`
	// Session Context information
	//
	// Types that are valid to be assigned to Context:
	//
	//	*SessionToken_Body_Object
	//	*SessionToken_Body_Container
	Context isSessionToken_Body_Context `protobuf_oneof:"context"`
	// contains filtered or unexported fields
}

Session Token body

func (*SessionToken_Body) ClearContainer 

func (x *SessionToken_Body) ClearContainer()

func (*SessionToken_Body) ClearContext 

func (x *SessionToken_Body) ClearContext()

func (*SessionToken_Body) ClearId 

func (x *SessionToken_Body) ClearId()

func (*SessionToken_Body) ClearLifetime 

func (x *SessionToken_Body) ClearLifetime()

func (*SessionToken_Body) ClearObject 

func (x *SessionToken_Body) ClearObject()

func (*SessionToken_Body) ClearOwnerId 

func (x *SessionToken_Body) ClearOwnerId()

func (*SessionToken_Body) ClearSessionKey 

func (x *SessionToken_Body) ClearSessionKey()

func (*SessionToken_Body) GetContainer 

func (x *SessionToken_Body) GetContainer() *ContainerSessionContext

func (*SessionToken_Body) GetContext 

func (x *SessionToken_Body) GetContext() isSessionToken_Body_Context

func (*SessionToken_Body) GetId 

func (x *SessionToken_Body) GetId() []byte

func (*SessionToken_Body) GetLifetime 

func (x *SessionToken_Body) GetLifetime() *SessionToken_Body_TokenLifetime

func (*SessionToken_Body) GetObject 

func (x *SessionToken_Body) GetObject() *ObjectSessionContext

func (*SessionToken_Body) GetOwnerId 

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

func (*SessionToken_Body) GetSessionKey 

func (x *SessionToken_Body) GetSessionKey() []byte

func (*SessionToken_Body) HasContainer 

func (x *SessionToken_Body) HasContainer() bool

func (*SessionToken_Body) HasContext 

func (x *SessionToken_Body) HasContext() bool

func (*SessionToken_Body) HasId 

func (x *SessionToken_Body) HasId() bool

func (*SessionToken_Body) HasLifetime 

func (x *SessionToken_Body) HasLifetime() bool

func (*SessionToken_Body) HasObject 

func (x *SessionToken_Body) HasObject() bool

func (*SessionToken_Body) HasOwnerId 

func (x *SessionToken_Body) HasOwnerId() bool

func (*SessionToken_Body) HasSessionKey 

func (x *SessionToken_Body) HasSessionKey() bool

func (*SessionToken_Body) ProtoMessage 

func (*SessionToken_Body) ProtoMessage()

func (*SessionToken_Body) ProtoReflect 

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

func (*SessionToken_Body) Reset 

func (x *SessionToken_Body) Reset()

func (*SessionToken_Body) SetContainer 

func (x *SessionToken_Body) SetContainer(v *ContainerSessionContext)

func (*SessionToken_Body) SetId 

func (x *SessionToken_Body) SetId(v []byte)

func (*SessionToken_Body) SetLifetime 

func (x *SessionToken_Body) SetLifetime(v *SessionToken_Body_TokenLifetime)

func (*SessionToken_Body) SetObject 

func (x *SessionToken_Body) SetObject(v *ObjectSessionContext)

func (*SessionToken_Body) SetOwnerId 

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

func (*SessionToken_Body) SetSessionKey 

func (x *SessionToken_Body) SetSessionKey(v []byte)

func (*SessionToken_Body) String 

func (x *SessionToken_Body) String() string

func (*SessionToken_Body) WhichContext 

func (x *SessionToken_Body) WhichContext() case_SessionToken_Body_Context

type SessionToken_Body_Container 

type SessionToken_Body_Container struct {
	// ContainerService session context
	Container *ContainerSessionContext `protobuf:"bytes,6,opt,name=container,oneof"`
}

type SessionToken_Body_Object 

type SessionToken_Body_Object struct {
	// ObjectService session context
	Object *ObjectSessionContext `protobuf:"bytes,5,opt,name=object,oneof"`
}

type SessionToken_Body_TokenLifetime 

type SessionToken_Body_TokenLifetime struct {

	// Expiration Epoch
	Exp *uint64 `protobuf:"varint,1,opt,name=exp" json:"exp,omitempty"`
	// Not valid before Epoch
	Nbf *uint64 `protobuf:"varint,2,opt,name=nbf" json:"nbf,omitempty"`
	// Issued at Epoch
	Iat *uint64 `protobuf:"varint,3,opt,name=iat" json:"iat,omitempty"`
	// contains filtered or unexported fields
}

Lifetime parameters of the token. Field names taken from rfc7519.

func (*SessionToken_Body_TokenLifetime) ClearExp 

func (x *SessionToken_Body_TokenLifetime) ClearExp()

func (*SessionToken_Body_TokenLifetime) ClearIat 

func (x *SessionToken_Body_TokenLifetime) ClearIat()

func (*SessionToken_Body_TokenLifetime) ClearNbf 

func (x *SessionToken_Body_TokenLifetime) ClearNbf()

func (*SessionToken_Body_TokenLifetime) GetExp 

func (x *SessionToken_Body_TokenLifetime) GetExp() uint64

func (*SessionToken_Body_TokenLifetime) GetIat 

func (x *SessionToken_Body_TokenLifetime) GetIat() uint64

func (*SessionToken_Body_TokenLifetime) GetNbf 

func (x *SessionToken_Body_TokenLifetime) GetNbf() uint64

func (*SessionToken_Body_TokenLifetime) HasExp 

func (x *SessionToken_Body_TokenLifetime) HasExp() bool

func (*SessionToken_Body_TokenLifetime) HasIat 

func (x *SessionToken_Body_TokenLifetime) HasIat() bool

func (*SessionToken_Body_TokenLifetime) HasNbf 

func (x *SessionToken_Body_TokenLifetime) HasNbf() bool

func (*SessionToken_Body_TokenLifetime) ProtoMessage 

func (*SessionToken_Body_TokenLifetime) ProtoMessage()

func (*SessionToken_Body_TokenLifetime) ProtoReflect 

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

func (*SessionToken_Body_TokenLifetime) Reset 

func (x *SessionToken_Body_TokenLifetime) Reset()

func (*SessionToken_Body_TokenLifetime) SetExp 

func (x *SessionToken_Body_TokenLifetime) SetExp(v uint64)

func (*SessionToken_Body_TokenLifetime) SetIat 

func (x *SessionToken_Body_TokenLifetime) SetIat(v uint64)

func (*SessionToken_Body_TokenLifetime) SetNbf 

func (x *SessionToken_Body_TokenLifetime) SetNbf(v uint64)

func (*SessionToken_Body_TokenLifetime) String 

func (x *SessionToken_Body_TokenLifetime) String() string

type SessionToken_Body_TokenLifetime_builder 

type SessionToken_Body_TokenLifetime_builder struct {

	// Expiration Epoch
	Exp *uint64
	// Not valid before Epoch
	Nbf *uint64
	// Issued at Epoch
	Iat *uint64
	// contains filtered or unexported fields
}

func (SessionToken_Body_TokenLifetime_builder) Build 

func (b0 SessionToken_Body_TokenLifetime_builder) Build() *SessionToken_Body_TokenLifetime

type SessionToken_Body_builder 

type SessionToken_Body_builder struct {

	// Token identifier is a valid UUIDv4 in binary form
	Id []byte
	// Identifier of the session initiator
	OwnerId *grpc.OwnerID
	// Lifetime of the session
	Lifetime *SessionToken_Body_TokenLifetime
	// Public key used in session
	SessionKey []byte

	// Fields of oneof Context:
	// ObjectService session context
	Object *ObjectSessionContext
	// ContainerService session context
	Container *ContainerSessionContext
	// contains filtered or unexported fields
}

func (SessionToken_Body_builder) Build 

func (b0 SessionToken_Body_builder) Build() *SessionToken_Body

type SessionToken_builder 

type SessionToken_builder struct {

	// Session Token contains the proof of trust between peers to be attached in
	// requests for further verification. Please see corresponding section of
	// FrostFS Technical Specification for details.
	Body *SessionToken_Body
	// Signature of `SessionToken` information
	Signature *grpc.Signature
	// contains filtered or unexported fields
}

func (SessionToken_builder) Build 

func (b0 SessionToken_builder) Build() *SessionToken

type UnimplementedSessionServiceServer 

type UnimplementedSessionServiceServer struct{}

UnimplementedSessionServiceServer 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 (UnimplementedSessionServiceServer) Create 

func (UnimplementedSessionServiceServer) Create(context.Context, *CreateRequest) (*CreateResponse, error)

type UnsafeSessionServiceServer 

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

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

type XHeader 

type XHeader struct {

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

Extended headers for Request/Response. They may contain any user-defined headers to be interpreted on application level.

Key name must be a unique valid UTF-8 string. Value can't be empty. Requests or Responses with duplicated header names or headers with empty values will be considered invalid.

There are some "well-known" headers starting with `__SYSTEM__` (`__NEOFS__` is deprecated) prefix that affect system behaviour:

  • [ __SYSTEM__NETMAP_EPOCH ] \ (`__NEOFS__NETMAP_EPOCH` is deprecated) \ Netmap epoch to use for object placement calculation. The `value` is string encoded `uint64` in decimal presentation. If set to '0' or not set, the current epoch only will be used.
  • [ __SYSTEM__NETMAP_LOOKUP_DEPTH ] \ (`__NEOFS__NETMAP_LOOKUP_DEPTH` is deprecated) \ If object can't be found using current epoch's netmap, this header limits how many past epochs the node can look up through. The `value` is string encoded `uint64` in decimal presentation. If set to '0' or not set, only the current epoch will be used.

func (*XHeader) ClearKey 

func (x *XHeader) ClearKey()

func (*XHeader) ClearValue 

func (x *XHeader) ClearValue()

func (*XHeader) GetKey 

func (x *XHeader) GetKey() string

func (*XHeader) GetValue 

func (x *XHeader) GetValue() string

func (*XHeader) HasKey 

func (x *XHeader) HasKey() bool

func (*XHeader) HasValue 

func (x *XHeader) HasValue() bool

func (*XHeader) ProtoMessage 

func (*XHeader) ProtoMessage()

func (*XHeader) ProtoReflect 

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

func (*XHeader) Reset 

func (x *XHeader) Reset()

func (*XHeader) SetKey 

func (x *XHeader) SetKey(v string)

func (*XHeader) SetValue 

func (x *XHeader) SetValue(v string)

func (*XHeader) String 

func (x *XHeader) String() string

type XHeader_builder 

type XHeader_builder struct {

	// Key of the X-Header
	Key *string
	// Value of the X-Header
	Value *string
	// contains filtered or unexported fields
}

func (XHeader_builder) Build 

func (b0 XHeader_builder) Build() *XHeader

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.