container

Documentation

Index

• type ContextWithToken
• type Server
  • func NewExecutionService(exec ServiceExecutor) Server
  • func NewResponseService(cnrSvc Server, respSvc *response.Service) Server
  • func NewSignService(key *ecdsa.PrivateKey, svc Server) Server
• type ServiceExecutor

Types

type ContextWithToken

type ContextWithToken struct {
	context.Context

	SessionToken *session.Token
}

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

type Server

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