routing

package

v0.14.0 Latest Latest Go to latest Published: Jul 21, 2022 License: Apache-2.0, MIT, Apache-2.0, + 1 more Imports: 12 Imported by: 0

Details

This section is empty.

This section is empty.

func GetPriority(params map[string]string) int

GetPriority extract priority from config params. Small numbers represent more important routers.

func NewParamNeededErr(param, routing string) error

func RoutingFromConfig(c config.Router) (routing.Routing, error)

RoutingFromConfig creates a Routing instance from the specified configuration.

type ParamNeededError struct {
	ParamName  string
	RouterType string
}

func (e *ParamNeededError) Error() string

type ProvideMany interface {
	ProvideMany(ctx context.Context, keys []multihash.Multihash) error
	Ready() bool
}

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

func (pmw *ProvideManyWrapper) ProvideMany(ctx context.Context, keys []multihash.Multihash) error

func (pmw *ProvideManyWrapper) Ready() bool

Ready is ready if all providers are ready

type RouterTypeNotFoundError struct {
	RouterType string
}

func (e *RouterTypeNotFoundError) Error() string

type Tiered struct {
	routinghelpers.Tiered
}

Tiered is a routing Tiered implementation providing some extra methods to fill some special use cases when initializing the client.

func (ds Tiered) ProvideMany() ProvideMany

ProvideMany returns a ProvideMany implementation including all Routers that implements ProvideMany

type TieredRouter interface {
	routing.Routing
	ProvideMany() ProvideMany
}