clients

Documentation

Index

• Constants
• func NewElasticsearchBulkIndexer(client *elasticsearch.Client) (esutil.BulkIndexer, error)
• func NewElasticsearchClient(clientURL string) (*elasticsearch.Client, error)
• func NewLogCLIClient(clientURL, tenant string, disableSecurityCheck bool) (*logcli.DefaultClient, error)
• func NewPromtailClient(clientURL, tenantID string, disableSecurityCheck bool) (promtail.Client, error)
• func QueryLogsWithElasticsearch(client *elasticsearch.Client, index, query string) error
• func QueryLogsWithLogCLI(client *logcli.DefaultClient, query string, queryRange time.Duration) error
• func RecreateElasticsearchIndex(client *elasticsearch.Client, index string) error
• func SendLogWithElasticsearch(indexer esutil.BulkIndexer, logData []byte) error
• func SendLogWithPromtail(client promtail.Client, log string, labels model.LabelSet)

Constants

const (
	IndexName = "logger"
)

Functions

func NewElasticsearchBulkIndexer

func NewElasticsearchBulkIndexer(client *elasticsearch.Client) (esutil.BulkIndexer, error)

func NewElasticsearchClient

func NewElasticsearchClient(clientURL string) (*elasticsearch.Client, error)

func NewLogCLIClient

func NewLogCLIClient(clientURL, tenant string, disableSecurityCheck bool) (*logcli.DefaultClient, error)

NewLogCLIClient creates a new logCLI client

func NewPromtailClient

func NewPromtailClient(clientURL, tenantID string, disableSecurityCheck bool) (promtail.Client, error)

NewPromtailClient creates a Promtail client

func QueryLogsWithElasticsearch

func QueryLogsWithElasticsearch(client *elasticsearch.Client, index, query string) error

func QueryLogsWithLogCLI

func QueryLogsWithLogCLI(client *logcli.DefaultClient, query string, queryRange time.Duration) error

QueryLogsWithLogCLI executes a query range action with logCLI

func RecreateElasticsearchIndex

func RecreateElasticsearchIndex(client *elasticsearch.Client, index string) error

func SendLogWithElasticsearch

func SendLogWithElasticsearch(indexer esutil.BulkIndexer, logData []byte) error

func SendLogWithPromtail

func SendLogWithPromtail(client promtail.Client, log string, labels model.LabelSet)

SendLogWithPromtail creates an entry for the log using the Promtail API