object

package
v0.42.0-rc.9 Latest Latest
Warning

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

 Go to latest Published: Jul 22, 2024 License: GPL-3.0 Imports: 26 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var ErrNotFound = errors.New("object header not found")
View Source 
var RequestContextKey = RequestContextKeyT{}

Functions

This section is empty.

Types

type ClientConstructor added in v0.40.0 

type ClientConstructor interface {
	Get(clientcore.NodeInfo) (clientcore.MultiAddressClient, error)
}

type Common 

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

Common is an Object API ServiceServer which encapsulates logic spread to all object operations.

If underlying NodeState.IsMaintenance returns true, all operations are immediately failed with apistatus.NodeUnderMaintenance.

func (*Common) Delete 

func (x *Common) Delete(ctx context.Context, req *objectV2.DeleteRequest) (*objectV2.DeleteResponse, error)

func (*Common) Get 

func (x *Common) Get(req *objectV2.GetRequest, stream GetObjectStream) error

func (*Common) GetRange 

func (x *Common) GetRange(req *objectV2.GetRangeRequest, stream GetObjectRangeStream) error

func (*Common) GetRangeHash 

func (x *Common) GetRangeHash(ctx context.Context, req *objectV2.GetRangeHashRequest) (*objectV2.GetRangeHashResponse, error)

func (*Common) Head 

func (x *Common) Head(ctx context.Context, req *objectV2.HeadRequest) (*objectV2.HeadResponse, error)

func (*Common) Init 

func (x *Common) Init(state NodeState, nextHandler ServiceServer)

Init initializes the Common instance.

func (*Common) Put 

func (x *Common) Put() (PutObjectStream, error)

func (*Common) PutSingle added in v0.37.0 

func (x *Common) PutSingle(ctx context.Context, req *objectV2.PutSingleRequest) (*objectV2.PutSingleResponse, error)

func (*Common) Search 

func (x *Common) Search(req *objectV2.SearchRequest, stream SearchStream) error

type GetObjectRangeStream 

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

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

type GetObjectStream 

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

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

type MetricCollector 

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

func NewMetricCollector 

func NewMetricCollector(next ServiceServer, register MetricRegister, enabled bool) *MetricCollector

func (MetricCollector) Delete 

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

func (*MetricCollector) Disable 

func (m *MetricCollector) Disable()

func (*MetricCollector) Enable 

func (m *MetricCollector) Enable()

func (MetricCollector) Get 

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

func (MetricCollector) GetRange 

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

func (MetricCollector) GetRangeHash 

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

func (MetricCollector) Head 

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

func (MetricCollector) Put 

func (m MetricCollector) Put() (PutObjectStream, error)

func (MetricCollector) PutSingle added in v0.37.0 

func (m MetricCollector) PutSingle(ctx context.Context, request *object.PutSingleRequest) (*object.PutSingleResponse, error)

func (MetricCollector) Search 

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

type MetricRegister 

type MetricRegister interface {
	AddRequestDuration(string, time.Duration, bool)
	AddPayloadSize(string, int)
}

type NodeState 

type NodeState interface {
	// IsMaintenance checks if node is under maintenance. Node MUST NOT serve
	// local object operations. Node MUST respond with apistatus.NodeUnderMaintenance
	// error if IsMaintenance returns true.
	IsMaintenance() bool
}

NodeState is storage node state processed by Object service.

type PutObjectStream 

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

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

type RemoteReader added in v0.40.0 

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

RemoteReader represents utility for getting the object from a remote host.

func NewRemoteReader added in v0.40.0 

func NewRemoteReader(keyStorage *util.KeyStorage, cache ClientConstructor) *RemoteReader

NewRemoteReader creates, initializes and returns new RemoteHeader instance.

func (*RemoteReader) Get added in v0.40.0 

func (h *RemoteReader) Get(ctx context.Context, prm *RemoteRequestPrm) (*objectSDK.Object, error)

func (*RemoteReader) Head added in v0.40.0 

func (h *RemoteReader) Head(ctx context.Context, prm *RemoteRequestPrm) (*objectSDK.Object, error)

Head requests object header from the remote node.

type RemoteRequestPrm added in v0.40.0 

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

RemoteRequestPrm groups remote operation parameters.

func (*RemoteRequestPrm) WithNodeInfo added in v0.40.0 

func (p *RemoteRequestPrm) WithNodeInfo(v netmap.NodeInfo) *RemoteRequestPrm

WithNodeInfo sets information about the remote node.

func (*RemoteRequestPrm) WithObjectAddress added in v0.40.0 

func (p *RemoteRequestPrm) WithObjectAddress(v oid.Address) *RemoteRequestPrm

WithObjectAddress sets object address.

func (*RemoteRequestPrm) WithRaw added in v0.40.0 

func (p *RemoteRequestPrm) WithRaw(v bool) *RemoteRequestPrm

type RequestContext added in v0.38.0 

type RequestContext struct {
	Namespace string

	SenderKey []byte

	ContainerOwner user.ID

	Role acl.Role

	SoftAPECheck bool

	BearerToken *bearer.Token
}

RequestContext is a context passed between middleware handlers.

type RequestContextKeyT added in v0.38.0 

type RequestContextKeyT struct{}

type ResponseService 

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 

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

func (*ResponseService) Get 

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

func (*ResponseService) GetRange 

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

func (*ResponseService) GetRangeHash 

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

func (*ResponseService) Head 

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

func (*ResponseService) Put 

func (s *ResponseService) Put() (PutObjectStream, error)

func (*ResponseService) PutSingle added in v0.37.0 

func (s *ResponseService) PutSingle(ctx context.Context, req *object.PutSingleRequest) (*object.PutSingleResponse, error)

func (*ResponseService) Search 

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

type SearchStream 

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

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

type ServiceServer 

type ServiceServer interface {
	Get(*object.GetRequest, GetObjectStream) error
	Put() (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)
	PutSingle(context.Context, *object.PutSingleRequest) (*object.PutSingleResponse, error)
}

ServiceServer is an interface of utility serving v2 Object service.

func NewAuditService added in v0.42.0 

func NewAuditService(next ServiceServer, log *logger.Logger, enabled *atomic.Bool) ServiceServer

type SignService 

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

func NewSignService 

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

func (*SignService) Delete 

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

func (*SignService) Get 

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

func (*SignService) GetRange 

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

func (*SignService) GetRangeHash 

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

func (*SignService) Head 

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

func (*SignService) Put 

func (s *SignService) Put() (PutObjectStream, error)

func (*SignService) PutSingle added in v0.37.0 

func (s *SignService) PutSingle(ctx context.Context, req *object.PutSingleRequest) (*object.PutSingleResponse, error)

func (*SignService) Search 

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() (PutObjectStream, error)

func (TransportSplitter) PutSingle added in v0.37.0 

func (c TransportSplitter) PutSingle(ctx context.Context, req *object.PutSingleRequest) (*object.PutSingleResponse, 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/v2
v2
v2
get
v2
client
Package internal provides functionality for FrostFS Node Object service communication with FrostFS network.
 Package internal provides functionality for FrostFS Node Object service communication with FrostFS 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.