object

type GetObjectBodyStreamer interface {
	Recv() (*object.GetResponseBody, error)
}

type GetRangeObjectBodyStreamer interface {
	Recv() (*object.GetRangeResponseBody, error)
}

type PutObjectBodyStreamer interface {
	Send(*object.PutRequestBody) error
	CloseAndRecv() (*object.PutResponseBody, error)
}

type SearchObjectBodyStreamer interface {
	Recv() (*object.SearchResponseBody, error)
}

type ServiceExecutor interface {
	Get(context.Context, *object.GetRequestBody) (GetObjectBodyStreamer, error)
	Put(context.Context) (PutObjectBodyStreamer, error)
	Head(context.Context, *object.HeadRequestBody) (*object.HeadResponseBody, error)
	Search(context.Context, *object.SearchRequestBody) (SearchObjectBodyStreamer, error)
	Delete(context.Context, *object.DeleteRequestBody) (*object.DeleteResponseBody, error)
	GetRange(context.Context, *object.GetRangeRequestBody) (GetRangeObjectBodyStreamer, error)
	GetRangeHash(context.Context, *object.GetRangeHashRequestBody) (*object.GetRangeHashResponseBody, error)
}

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