object

Documentation

Index

• func NewResponseService(objSvc object.Service, respSvc *response.Service) object.Service
• func NewSignService(key *ecdsa.PrivateKey, svc object.Service) object.Service
• type TransportSplitter
  • func NewTransportSplitter(size, amount uint64, next object.Service) *TransportSplitter
  • func (c TransportSplitter) Delete(ctx context.Context, request *object.DeleteRequest) (*object.DeleteResponse, error)
  • func (c TransportSplitter) Get(ctx context.Context, request *object.GetRequest) (object.GetObjectStreamer, error)
  • func (c TransportSplitter) GetRange(ctx context.Context, request *object.GetRangeRequest) (object.GetRangeObjectStreamer, error)
  • func (c TransportSplitter) GetRangeHash(ctx context.Context, request *object.GetRangeHashRequest) (*object.GetRangeHashResponse, error)
  • func (c TransportSplitter) Head(ctx context.Context, request *object.HeadRequest) (*object.HeadResponse, error)
  • func (c TransportSplitter) Put(ctx context.Context) (object.PutObjectStreamer, error)
  • func (c TransportSplitter) Search(ctx context.Context, request *object.SearchRequest) (object.SearchObjectStreamer, error)

Functions

func NewResponseService

func NewResponseService(objSvc object.Service, respSvc *response.Service) object.Service

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

func NewSignService

func NewSignService(key *ecdsa.PrivateKey, svc object.Service) object.Service

Types

type TransportSplitter

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

func NewTransportSplitter

func NewTransportSplitter(size, amount uint64, next object.Service) *TransportSplitter

func (TransportSplitter) Delete

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

func (TransportSplitter) Get

func (c TransportSplitter) Get(ctx context.Context, request *object.GetRequest) (object.GetObjectStreamer, error)

func (TransportSplitter) GetRange

func (c TransportSplitter) GetRange(ctx context.Context, request *object.GetRangeRequest) (object.GetRangeObjectStreamer, 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) (object.PutObjectStreamer, error)

func (TransportSplitter) Search

func (c TransportSplitter) Search(ctx context.Context, request *object.SearchRequest) (object.SearchObjectStreamer, error)