elasticsearch

Documentation

Index

• func DieWhenConnectionFails(ctx context.Context, es *elasticsearch.TypedClient)
• func NewClientFromConfiguration(configuration *pb.ClientConfiguration) (*elasticsearch.TypedClient, error)
• type Uploader
  • func NewUploader(elasticsearchClient *elasticsearch.TypedClient, index string, ...) Uploader

Functions

func DieWhenConnectionFails

func DieWhenConnectionFails(ctx context.Context, es *elasticsearch.TypedClient)

DieWhenConnectionFails checks periodically that Elasticsearch can be reached. If this fails after a few retries, it panics.

TODO: Patch bb-storage to allow for dynamic health status.

func NewClientFromConfiguration

func NewClientFromConfiguration(configuration *pb.ClientConfiguration) (*elasticsearch.TypedClient, error)

NewClientFromConfiguration creates an elasticsearch.TypedClient object based on the provided configuration.

Types

type Uploader

type Uploader interface {
	Put(ctx context.Context, id string, document interface{}) error
}

The Uploader can be used to push documents into Elasticsearch.

func NewUploader

func NewUploader(
	elasticsearchClient *elasticsearch.TypedClient,
	index string,
	clock clock.Clock,
	warningLogger util.ErrorLogger,
) Uploader

NewUploader creates a new Uploader that uploads generic documents to Elasticsearch.