patchsvc

Documentation

Index

• type Service
  • func NewService(cfg *objectwriter.Config, getSvc *getsvc.Service) *Service
  • func (s *Service) Patch() (object.PatchObjectStream, error)
• type Streamer
  • func (s *Streamer) CloseAndRecv(ctx context.Context) (*objectV2.PatchResponse, error)
  • func (s *Streamer) Send(ctx context.Context, req *objectV2.PatchRequest) error

Types

type Service

type Service struct {
	*objectwriter.Config
	// contains filtered or unexported fields
}

Service implements Put operation of Object service v2.

func NewService

func NewService(cfg *objectwriter.Config,
	getSvc *getsvc.Service,
) *Service

NewService constructs Service instance from provided options.

Patch service can use the same objectwriter.Config initializied by Put service.

func (*Service) Patch

func (s *Service) Patch() (object.PatchObjectStream, error)

Patch calls internal service and returns v2 object streamer.

type Streamer

type Streamer struct {
	*objectwriter.Config
	// contains filtered or unexported fields
}

Streamer for the patch handler is a pipeline that merges two incoming streams of patches and original object payload chunks. The merged result is fed to Put stream target.

func (*Streamer) CloseAndRecv

func (s *Streamer) CloseAndRecv(ctx context.Context) (*objectV2.PatchResponse, error)

func (*Streamer) Send

func (s *Streamer) Send(ctx context.Context, req *objectV2.PatchRequest) error