acl

Documentation

Index

• Variables
• type InnerRingFetcher
• type Option
  • func WithContainerSource(v container.Source) Option
  • func WithEACLValidatorOptions(v ...eacl.Option) Option
  • func WithLocalStorage(v *engine.StorageEngine) Option
  • func WithNetmapState(v netmap.State) Option
  • func WithNextService(v objectSvc.ServiceServer) Option
  • func WithSenderClassifier(v SenderClassifier) Option
• type SenderClassifier
  • func NewSenderClassifier(ir InnerRingFetcher, nm core.Source) SenderClassifier
  • func (c SenderClassifier) Classify(req metaWithToken, cid *container.ID, cnr *container.Container) (role acl.Role, isIR bool, key []byte, err error)
• type Service
  • func New(opts ...Option) Service
  • func (b Service) Delete(ctx context.Context, request *object.DeleteRequest) (*object.DeleteResponse, error)
  • func (b Service) Get(request *object.GetRequest, stream objectSvc.GetObjectStream) error
  • func (b Service) GetRange(request *object.GetRangeRequest, stream objectSvc.GetObjectRangeStream) error
  • func (b Service) GetRangeHash(ctx context.Context, request *object.GetRangeHashRequest) (*object.GetRangeHashResponse, error)
  • func (b Service) Head(ctx context.Context, request *object.HeadRequest) (*object.HeadResponse, error)
  • func (b Service) Put(ctx context.Context) (object.PutObjectStreamer, error)
  • func (b Service) Search(request *object.SearchRequest, stream objectSvc.SearchStream) error

Variables

var (
	ErrMalformedRequest = errors.New("malformed request")
	ErrUnknownRole      = errors.New("can't classify request sender")
	ErrUnknownContainer = errors.New("can't fetch container info")
)

Types

type InnerRingFetcher

type InnerRingFetcher interface {
	InnerRingKeys() ([][]byte, error)
}

type Option

type Option func(*cfg)

Option represents Service constructor option.

func WithContainerSource

func WithContainerSource(v container.Source) Option

WithContainerSource returns option to set container source.

func WithEACLValidatorOptions

func WithEACLValidatorOptions(v ...eacl.Option) Option

WithEACLValidator returns options to set eACL validator options.

func WithLocalStorage

func WithLocalStorage(v *engine.StorageEngine) Option

WithLocalStorage returns options to set local object storage.

func WithNetmapState

func WithNetmapState(v netmap.State) Option

WithNetmapState returns options to set global netmap state.

func WithNextService

func WithNextService(v objectSvc.ServiceServer) Option

WithNextService returns option to set next object service.

func WithSenderClassifier

func WithSenderClassifier(v SenderClassifier) Option

WithSenderClassifier returns option to set sender classifier.

type SenderClassifier

type SenderClassifier struct {
	// contains filtered or unexported fields
}

func NewSenderClassifier

func NewSenderClassifier(ir InnerRingFetcher, nm core.Source) SenderClassifier

fixme: update classifier constructor

func (SenderClassifier) Classify

func (c SenderClassifier) Classify(
	req metaWithToken,
	cid *container.ID,
	cnr *container.Container) (role acl.Role, isIR bool, key []byte, err error)

type Service

type Service struct {
	// contains filtered or unexported fields
}

Service checks basic ACL rules.

func New

func New(opts ...Option) Service

New is a constructor for object ACL checking service.

func (Service) Delete

func (b Service) Delete(
	ctx context.Context,
	request *object.DeleteRequest) (*object.DeleteResponse, error)

func (Service) Get

func (b Service) Get(request *object.GetRequest, stream objectSvc.GetObjectStream) error

func (Service) GetRange

func (b Service) GetRange(request *object.GetRangeRequest, stream objectSvc.GetObjectRangeStream) error

func (Service) GetRangeHash

func (b Service) GetRangeHash(
	ctx context.Context,
	request *object.GetRangeHashRequest) (*object.GetRangeHashResponse, error)

func (Service) Head

func (b Service) Head(
	ctx context.Context,
	request *object.HeadRequest) (*object.HeadResponse, error)

func (Service) Put

func (b Service) Put(ctx context.Context) (object.PutObjectStreamer, error)

func (Service) Search

func (b Service) Search(request *object.SearchRequest, stream objectSvc.SearchStream) error