container

Documentation

Index

• type Server
  • func NewAPEServer(router policyengine.ChainRouter, reader containers, ir ir, nm netmap.Source, ...) Server
  • func NewExecutionService(exec ServiceExecutor, respSvc *response.Service) Server
  • func NewSignService(key *ecdsa.PrivateKey, svc Server) Server
• type ServiceExecutor

Types

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 FrostFS API Container service server.

func NewAPEServer

func NewAPEServer(router policyengine.ChainRouter, reader containers, ir ir, nm netmap.Source, frostFSIDClient frostfsidSubjectProvider, srv Server) Server

func NewExecutionService

func NewExecutionService(exec ServiceExecutor, respSvc *response.Service) Server

NewExecutionService wraps ServiceExecutor and returns Container Service interface.

func NewSignService

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

type ServiceExecutor

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