dhstore

Documentation

Overview

Package dhstore defines an dhstore client.

When creating an indexer that uses this value store, the indexer should generally not be given a cache, unless the same multihashes and values are frequently written.

Index

• Variables
• func New(dhstoreURL string, options ...Option) (*dhStore, error)
• type Option
  • func WithDHBatchSize(size int) Option
  • func WithDHStoreCluster(clusterUrls []string) Option
  • func WithHttpClientTimeout(timeout time.Duration) Option

Variables

var (
	ErrNotSupported = errors.New("not supported")
)

Functions

func New

func New(dhstoreURL string, options ...Option) (*dhStore, error)

Types

type Option

type Option func(*config) error

func WithDHBatchSize

func WithDHBatchSize(size int) Option

WithDHBatchSize configures the batch size when sending batches of merge requests to DHStore. A value < 1 results in the default size.

func WithDHStoreCluster

func WithDHStoreCluster(clusterUrls []string) Option

WithDHStoreCluster provide addional URLs that the core will send delete requests to. Deletes are send to the dhstoreURL as well as to all dhstoreClusterURLs. This is required as deletes need to be applied to all nodes until consistent hashing is implemented. dhstoreURL must not be included in this list.

func WithHttpClientTimeout

func WithHttpClientTimeout(timeout time.Duration) Option

WithHttpClientTimeout sets http timeout for queries to DHStore