object

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

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

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

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 interface {
	Send(*object.PutRequest) error
	CloseAndRecv() (*object.PutResponse, error)
}

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

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

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)
}

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

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