object

package
v0.21.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 10, 2021 License: GPL-3.0 Imports: 8 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type GetObjectRangeStream added in v0.13.0 

type GetObjectRangeStream interface {
	util.ServerStream
	Send(*object.GetRangeResponse) error
}

GetObjectRangeStream is an interface of NeoFS API v2 compatible payload range streamer.

type GetObjectStream added in v0.13.0 

type GetObjectStream interface {
	util.ServerStream
	Send(*object.GetResponse) error
}

GetObjectStream is an interface of NeoFS API v2 compatible object streamer.

type MetricCollector added in v0.17.0 

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

func NewMetricCollector added in v0.17.0 

func NewMetricCollector(next ServiceServer, register MetricRegister) *MetricCollector

func (MetricCollector) Delete added in v0.17.0 

func (m MetricCollector) Delete(ctx context.Context, request *object.DeleteRequest) (*object.DeleteResponse, error)

func (MetricCollector) Get added in v0.17.0 

func (m MetricCollector) Get(req *object.GetRequest, stream GetObjectStream) error

func (MetricCollector) GetRange added in v0.17.0 

func (m MetricCollector) GetRange(req *object.GetRangeRequest, stream GetObjectRangeStream) error

func (MetricCollector) GetRangeHash added in v0.17.0 

func (m MetricCollector) GetRangeHash(ctx context.Context, request *object.GetRangeHashRequest) (*object.GetRangeHashResponse, error)

func (MetricCollector) Head added in v0.17.0 

func (m MetricCollector) Head(ctx context.Context, request *object.HeadRequest) (*object.HeadResponse, error)

func (MetricCollector) Put added in v0.17.0 

func (m MetricCollector) Put(ctx context.Context) (PutObjectStream, error)

func (MetricCollector) Search added in v0.17.0 

func (m MetricCollector) Search(req *object.SearchRequest, stream SearchStream) error

type MetricRegister added in v0.17.0 

type MetricRegister interface {
	IncGetReqCounter()
	IncPutReqCounter()
	IncHeadReqCounter()
	IncSearchReqCounter()
	IncDeleteReqCounter()
	IncRangeReqCounter()
	IncRangeHashReqCounter()

	AddGetReqDuration(time.Duration)
	AddPutReqDuration(time.Duration)
	AddHeadReqDuration(time.Duration)
	AddSearchReqDuration(time.Duration)
	AddDeleteReqDuration(time.Duration)
	AddRangeReqDuration(time.Duration)
	AddRangeHashReqDuration(time.Duration)

	AddPutPayload(int)
	AddGetPayload(int)
}

type PutObjectStream added in v0.17.0 

type PutObjectStream interface {
	Send(*object.PutRequest) error
	CloseAndRecv() (*object.PutResponse, error)
}

PutObjectStream is an interface of NeoFS API v2 compatible client's object streamer.

type ResponseService added in v0.13.0 

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

func NewResponseService 

func NewResponseService(objSvc ServiceServer, respSvc *response.Service) *ResponseService

NewResponseService returns object service instance that passes internal service call to response service.

func (*ResponseService) Delete added in v0.13.0 

func (s *ResponseService) Delete(ctx context.Context, req *object.DeleteRequest) (*object.DeleteResponse, error)

func (*ResponseService) Get added in v0.13.0 

func (s *ResponseService) Get(req *object.GetRequest, stream GetObjectStream) error

func (*ResponseService) GetRange added in v0.13.0 

func (s *ResponseService) GetRange(req *object.GetRangeRequest, stream GetObjectRangeStream) error

func (*ResponseService) GetRangeHash added in v0.13.0 

func (s *ResponseService) GetRangeHash(ctx context.Context, req *object.GetRangeHashRequest) (*object.GetRangeHashResponse, error)

func (*ResponseService) Head added in v0.13.0 

func (s *ResponseService) Head(ctx context.Context, req *object.HeadRequest) (*object.HeadResponse, error)

func (*ResponseService) Put added in v0.13.0 

func (s *ResponseService) Put(ctx context.Context) (PutObjectStream, error)

func (*ResponseService) Search added in v0.13.0 

func (s *ResponseService) Search(req *object.SearchRequest, stream SearchStream) error

type SearchStream added in v0.13.0 

type SearchStream interface {
	util.ServerStream
	Send(*object.SearchResponse) error
}

SearchStream is an interface of NeoFS API v2 compatible search streamer.

type ServiceServer added in v0.13.0 

type ServiceServer interface {
	Get(*object.GetRequest, GetObjectStream) error
	Put(context.Context) (PutObjectStream, error)
	Head(context.Context, *object.HeadRequest) (*object.HeadResponse, error)
	Search(*object.SearchRequest, SearchStream) error
	Delete(context.Context, *object.DeleteRequest) (*object.DeleteResponse, error)
	GetRange(*object.GetRangeRequest, GetObjectRangeStream) error
	GetRangeHash(context.Context, *object.GetRangeHashRequest) (*object.GetRangeHashResponse, error)
}

ServiceServer is an interface of utility serving v2 Object service.

type SignService added in v0.13.0 

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

func NewSignService 

func NewSignService(key *ecdsa.PrivateKey, svc ServiceServer) *SignService

func (*SignService) Delete added in v0.13.0 

func (s *SignService) Delete(ctx context.Context, req *object.DeleteRequest) (*object.DeleteResponse, error)

func (*SignService) Get added in v0.13.0 

func (s *SignService) Get(req *object.GetRequest, stream GetObjectStream) error

func (*SignService) GetRange added in v0.13.0 

func (s *SignService) GetRange(req *object.GetRangeRequest, stream GetObjectRangeStream) error

func (*SignService) GetRangeHash added in v0.13.0 

func (s *SignService) GetRangeHash(ctx context.Context, req *object.GetRangeHashRequest) (*object.GetRangeHashResponse, error)

func (*SignService) Head added in v0.13.0 

func (s *SignService) Head(ctx context.Context, req *object.HeadRequest) (*object.HeadResponse, error)

func (*SignService) Put added in v0.13.0 

func (s *SignService) Put(ctx context.Context) (PutObjectStream, error)

func (*SignService) Search added in v0.13.0 

func (s *SignService) Search(req *object.SearchRequest, stream SearchStream) error

type TransportSplitter 

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

func NewTransportSplitter 

func NewTransportSplitter(size, amount uint64, next ServiceServer) *TransportSplitter

func (TransportSplitter) Delete 

func (c TransportSplitter) Delete(ctx context.Context, request *object.DeleteRequest) (*object.DeleteResponse, error)

func (*TransportSplitter) Get 

func (c *TransportSplitter) Get(req *object.GetRequest, stream GetObjectStream) error

func (TransportSplitter) GetRange 

func (c TransportSplitter) GetRange(req *object.GetRangeRequest, stream GetObjectRangeStream) error

func (TransportSplitter) GetRangeHash 

func (c TransportSplitter) GetRangeHash(ctx context.Context, request *object.GetRangeHashRequest) (*object.GetRangeHashResponse, error)

func (TransportSplitter) Head 

func (c TransportSplitter) Head(ctx context.Context, request *object.HeadRequest) (*object.HeadResponse, error)

func (TransportSplitter) Put 

func (c TransportSplitter) Put(ctx context.Context) (PutObjectStream, error)

func (TransportSplitter) Search 

func (c TransportSplitter) Search(req *object.SearchRequest, stream SearchStream) error

Source Files

View all Source files

Directories

Path Synopsis
acl
eacl
eacl/v2
v2
get
v2
put
v2
v2

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.