object

package
v0.27.1 Latest Latest
Warning

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

 Go to latest Published: Dec 20, 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
client
Package internal provides functionality for NeoFS Node Object service communication with NeoFS network.
 Package internal provides functionality for NeoFS Node Object service communication with NeoFS network.
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.