transport

type AddressInfo interface {
	MetaInfo
	GetAddress() refs.Address
}

type ContainerTraverseExecutor interface {
	Execute(context.Context, TraverseParams)
}

type GetInfo interface {
	AddressInfo
}

type GetParams struct {
	SelectiveParams
	Handler func(multiaddr.Multiaddr, *object.Object)
}

type HeadInfo interface {
	GetInfo
	GetFullHeaders() bool
}

type HeadParams struct {
	GetParams
	FullHeaders bool
}

type MetaInfo interface {
	GetTTL() uint32
	GetTimeout() time.Duration
	service.SessionTokenSource
	GetRaw() bool
	Type() object.RequestType
	service.BearerTokenSource
	service.ExtendedHeadersSource
}

type ObjectContainerHandlerParams struct {
	NodeLister *placement.PlacementWrapper
	Executor   ContainerTraverseExecutor
	*zap.Logger
}

type ObjectTransport interface {
	Transport(context.Context, ObjectTransportParams)
}

type ObjectTransportParams struct {
	TransportInfo MetaInfo
	TargetNode    multiaddr.Multiaddr
	ResultHandler ResultHandler
}

type ProgressControlFlag int

type PutInfo interface {
	MetaInfo
	GetHead() *object.Object
	Payload() io.Reader
	CopiesNumber() uint32
}

type PutParams struct {
	SelectiveParams
	Object  *object.Object
	Handler func(multiaddr.Multiaddr, bool)

	CopiesNumber uint32
}

type RangeHashInfo interface {
	AddressInfo
	GetRanges() []object.Range
	GetSalt() []byte
}

type RangeHashParams struct {
	SelectiveParams
	Ranges  []object.Range
	Salt    []byte
	Handler func(multiaddr.Multiaddr, []hash.Hash)
}

type RangeInfo interface {
	AddressInfo
	GetRange() object.Range
}

type ResultHandler interface {
	HandleResult(context.Context, multiaddr.Multiaddr, interface{}, error)
}

type SearchInfo interface {
	MetaInfo
	GetCID() refs.CID
	GetQuery() []byte
}

type SearchParams struct {
	SelectiveParams
	SearchCID   refs.CID
	SearchQuery []byte
	Handler     func(multiaddr.Multiaddr, []refs.Address)
}

type SelectiveContainerExecutor interface {
	Put(context.Context, *PutParams) error
	Get(context.Context, *GetParams) error
	Head(context.Context, *HeadParams) error
	Search(context.Context, *SearchParams) error
	RangeHash(context.Context, *RangeHashParams) error
}

type SelectiveParams struct {
	/* Should be set to true only if service under object transport implementations is served on localhost. */
	ServeLocal bool

	/* Raw option of the request */
	Raw bool

	/* TTL for object transport. All transport operations inherit same value. */
	TTL uint32

	/* Required ID of processing container. If empty or not set, an error is returned. */
	CID container.ID

	/* List of nodes selected for processing. If not specified => nodes will be selected during. */
	Nodes []multiaddr.Multiaddr

	/* List of objects to process (overlaps query). */
	IDList []refs.ObjectID
	/* If no objects is indicated, query is used for selection. */
	Query []byte

	/*
		If function provided, it is called after every successful operation.
		True result breaks operation performing.
	*/
	Breaker func(refs.Address) ProgressControlFlag

	/* Public session token */
	Token service.SessionToken

	/* Bearer token */
	Bearer service.BearerToken

	/* Extended headers */
	ExtendedHeaders []service.ExtendedHeader
}

type TraverseParams struct {
	TransportInfo        MetaInfo
	Handler              ResultHandler
	Traverser            Traverser
	WorkerPool           WorkerPool
	ExecutionInterceptor func(context.Context, multiaddr.Multiaddr) bool
}

type Traverser interface {
	Next(context.Context) []multiaddr.Multiaddr
}

type WorkerPool interface {
	Submit(func()) error
}