container

package

v0.28.0-rc.2 Latest Latest Go to latest Published: Mar 24, 2022 License: GPL-3.0 Imports: 7 Imported by: 1

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/nspcc-dev/neofs-node

Links

Open Source Insights

Documentation ¶

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type ContextWithToken ¶ added in v0.21.0

type ContextWithToken struct {
	context.Context

	SessionToken *session.Token
}

FIXME: #1159 (temp solution) we need to pass session token from header

type Server ¶ added in v0.17.0

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

Server is an interface of the NeoFS API Container service server

func NewExecutionService ¶

func NewExecutionService(exec ServiceExecutor) Server

NewExecutionService wraps ServiceExecutor and returns Container Service interface.

func NewResponseService ¶

func NewResponseService(cnrSvc Server, respSvc *response.Service) Server

NewResponseService returns container service instance that passes internal service call to response service.

func NewSignService ¶

func NewSignService(key *ecdsa.PrivateKey, svc Server) Server

type ServiceExecutor ¶

type ServiceExecutor interface {
	Put(ContextWithToken, *container.PutRequestBody) (*container.PutResponseBody, error)
	Delete(ContextWithToken, *container.DeleteRequestBody) (*container.DeleteResponseBody, error)
	Get(context.Context, *container.GetRequestBody) (*container.GetResponseBody, error)
	List(context.Context, *container.ListRequestBody) (*container.ListResponseBody, error)
	SetExtendedACL(ContextWithToken, *container.SetExtendedACLRequestBody) (*container.SetExtendedACLResponseBody, error)
	GetExtendedACL(context.Context, *container.GetExtendedACLRequestBody) (*container.GetExtendedACLResponseBody, error)
}

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
announcement
load/controller
load/route
load/route/placement
load/storage
morph

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL