container

Documentation

Index

• type Server
  • func NewAPEServer(router policyengine.ChainRouter, reader containers, ir ir, nm netmap.Source, ...) Server
  • func NewAuditService(next Server, log *logger.Logger, enabled *atomic.Bool) 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 frostfsidcore.SubjectProvider, srv Server) Server

func NewAuditService

func NewAuditService(next Server, log *logger.Logger, enabled *atomic.Bool) 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)
}