etcd

Documentation

Index

• type Etcd
  • func NewEtcd() *Etcd
  • func (e *Etcd) GetLogger() logr.Logger
  • func (e *Etcd) GetRole(ctx context.Context, req *ProbeRequest, resp *ProbeResponse) (string, error)
  • func (e *Etcd) GetRoleOps(ctx context.Context, req *ProbeRequest, resp *ProbeResponse) (OpsResult, error)
  • func (e *Etcd) GetRunningPort() int
  • func (e *Etcd) Init(metadata component.Properties) error
  • func (e *Etcd) InitDelay() error
  • func (e *Etcd) InternalExec(ctx context.Context, sql string) (int64, error)
  • func (e *Etcd) InternalQuery(ctx context.Context, sql string) ([]byte, error)
  • func (e *Etcd) StatusCheck(ctx context.Context, cmd string, response *ProbeResponse) ([]byte, error)

Types

type Etcd

type Etcd struct {
	BaseOperations
	// contains filtered or unexported fields
}

func NewEtcd

func NewEtcd() *Etcd

NewEtcd returns a new etcd binding instance.

func (*Etcd) GetLogger

func (e *Etcd) GetLogger() logr.Logger

func (*Etcd) GetRole

func (e *Etcd) GetRole(ctx context.Context, req *ProbeRequest, resp *ProbeResponse) (string, error)

func (*Etcd) GetRoleOps

func (e *Etcd) GetRoleOps(ctx context.Context, req *ProbeRequest, resp *ProbeResponse) (OpsResult, error)

func (*Etcd) GetRunningPort

func (e *Etcd) GetRunningPort() int

func (*Etcd) Init

func (e *Etcd) Init(metadata component.Properties) error

func (*Etcd) InitDelay

func (e *Etcd) InitDelay() error

func (*Etcd) InternalExec

func (e *Etcd) InternalExec(ctx context.Context, sql string) (int64, error)

func (*Etcd) InternalQuery

func (e *Etcd) InternalQuery(ctx context.Context, sql string) ([]byte, error)

func (*Etcd) StatusCheck

func (e *Etcd) StatusCheck(ctx context.Context, cmd string, response *ProbeResponse) ([]byte, error)