elasticsearchprobe

Documentation

Index

• type CertPoolGetter
• type DefaultCertPoolGetter
  • func (DefaultCertPoolGetter) FromCustomCA(caCert []byte) *x509.CertPool
  • func (DefaultCertPoolGetter) SystemPool() (*x509.CertPool, error)
• type ElasticsearchProbe
  • func NewElasticsearchProbe(name, url string, opts ...ProbeOpts) ElasticsearchProbe
  • func (p ElasticsearchProbe) Check(_ context.Context) error
  • func (p ElasticsearchProbe) Name() string
• type ProbeOpts
  • func WithCA(caCert []byte) ProbeOpts
  • func WithInsecureSkipVerify() ProbeOpts

Types

type CertPoolGetter

type CertPoolGetter interface {
	FromCustomCA(caCert []byte) *x509.CertPool
	SystemPool() (*x509.CertPool, error)
}

type DefaultCertPoolGetter

type DefaultCertPoolGetter struct{}

func (DefaultCertPoolGetter) FromCustomCA

func (DefaultCertPoolGetter) FromCustomCA(caCert []byte) *x509.CertPool

func (DefaultCertPoolGetter) SystemPool

func (DefaultCertPoolGetter) SystemPool() (*x509.CertPool, error)

type ElasticsearchProbe

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

func NewElasticsearchProbe

func NewElasticsearchProbe(name, url string, opts ...ProbeOpts) ElasticsearchProbe

NewElasticsearchProbe instantiate a new elasticsearch probe: - name: probe name - url : connection string with the form "http://username:password@example.com" - opts: optionnal parameters such as providing a TLS CA certificate or allowing insecure connections

func (ElasticsearchProbe) Check

func (p ElasticsearchProbe) Check(_ context.Context) error

func (ElasticsearchProbe) Name

func (p ElasticsearchProbe) Name() string

type ProbeOpts

type ProbeOpts func(*ElasticsearchProbe)

func WithCA

func WithCA(caCert []byte) ProbeOpts

func WithInsecureSkipVerify

func WithInsecureSkipVerify() ProbeOpts