datastore

Documentation

Index

• func NewPostgreSQLDatastore(ctx context.Context, connstr string) (*pgds.Datastore, error)
• func NewProxy(ctx context.Context, ds datastore.Batching, getRouting GetRoutingFunc, ...) datastore.Batching
• type AddProviderFunc
• type GetRoutingFunc
• type Options

Functions

func NewPostgreSQLDatastore

func NewPostgreSQLDatastore(ctx context.Context, connstr string) (*pgds.Datastore, error)

NewPostgreSQLDatastore creates a new pgds.Datastore that talks to a PostgreSQL database

func NewProxy

func NewProxy(ctx context.Context, ds datastore.Batching, getRouting GetRoutingFunc, opts Options) datastore.Batching

NewProxy returns a new proxy to a datastore that adds hooks to perform hydra things

Types

type AddProviderFunc

type AddProviderFunc func(ctx context.Context, c cid.Cid, id peer.ID)

AddProviderFunc adds a provider for a given CID to the datastore

type GetRoutingFunc

type GetRoutingFunc func(cid.Cid) (routing.Routing, AddProviderFunc, error)

GetRoutingFunc is a function that returns an appropriate routing module given a CID

type Options

type Options struct {
	// total number of find provider queries we should queue
	FindProvidersQueueSize int
	// number of providers to find when a provider record does not exist in the store
	FindProvidersCount int
	// number of find provider requests we will concurrently process
	FindProvidersConcurrency int
	// maximum time a find providers call is allowed to take
	FindProvidersTimeout time.Duration
	// period after a find failure that another find request for the same key will be discarded
	FindProvidersFailureBackoff time.Duration
}

Options are options for the Hydra datastore