getsvc

Documentation

Index

• type Option
  • func WithLogger(l *logger.Logger) Option
• type Service
  • func NewService(svc *getsvc.Service, keyStorage *objutil.KeyStorage, clientSource clientSource, ...) *Service
  • func (s *Service) Get(req *objectV2.GetRequest, stream objectSvc.GetObjectStream) error
  • func (s *Service) GetRange(req *objectV2.GetRangeRequest, stream objectSvc.GetObjectRangeStream) error
  • func (s *Service) GetRangeHash(ctx context.Context, req *objectV2.GetRangeHashRequest) (*objectV2.GetRangeHashResponse, error)
  • func (s *Service) Head(ctx context.Context, req *objectV2.HeadRequest) (*objectV2.HeadResponse, error)

Types

type Option

type Option func(*cfg)

Option represents Service constructor option.

func WithLogger

func WithLogger(l *logger.Logger) Option

type Service

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

Service implements Get operation of Object service v2.

func NewService

func NewService(svc *getsvc.Service,
	keyStorage *objutil.KeyStorage,
	clientSource clientSource,
	netmapSource netmap.Source,
	announcedKeys netmap.AnnouncedKeys,
	contSource container.Source,
	opts ...Option,
) *Service

NewService constructs Service instance from provided options.

func (*Service) Get

func (s *Service) Get(req *objectV2.GetRequest, stream objectSvc.GetObjectStream) error

Get calls internal service and returns v2 object stream.

func (*Service) GetRange

func (s *Service) GetRange(req *objectV2.GetRangeRequest, stream objectSvc.GetObjectRangeStream) error

GetRange calls internal service and returns v2 payload range stream.

func (*Service) GetRangeHash

func (s *Service) GetRangeHash(ctx context.Context, req *objectV2.GetRangeHashRequest) (*objectV2.GetRangeHashResponse, error)

GetRangeHash calls internal service and returns v2 response.

func (*Service) Head

func (s *Service) Head(ctx context.Context, req *objectV2.HeadRequest) (*objectV2.HeadResponse, error)

Head serves ForstFS API v2 compatible HEAD requests.