etcd

Documentation

Index

• func NewEtcd(logger logger.Logger) bindings.OutputBinding
• type Etcd
  • func (e *Etcd) GetRole(ctx context.Context, req *bindings.InvokeRequest, ...) (string, error)
  • func (e *Etcd) GetRoleOps(ctx context.Context, req *bindings.InvokeRequest, ...) (OpsResult, error)
  • func (e *Etcd) GetRunningPort() int
  • func (e *Etcd) Init(metadata bindings.Metadata) error
  • func (e *Etcd) InitDelay() error
  • func (e *Etcd) StatusCheck(ctx context.Context, cmd string, response *bindings.InvokeResponse) ([]byte, error)

Functions

func NewEtcd

func NewEtcd(logger logger.Logger) bindings.OutputBinding

NewEtcd returns a new etcd binding instance.

Types

type Etcd

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

func (*Etcd) GetRole

func (e *Etcd) GetRole(ctx context.Context, req *bindings.InvokeRequest, resp *bindings.InvokeResponse) (string, error)

func (*Etcd) GetRoleOps

func (e *Etcd) GetRoleOps(ctx context.Context, req *bindings.InvokeRequest, resp *bindings.InvokeResponse) (OpsResult, error)

func (*Etcd) GetRunningPort

func (e *Etcd) GetRunningPort() int

func (*Etcd) Init

func (e *Etcd) Init(metadata bindings.Metadata) error

func (*Etcd) InitDelay

func (e *Etcd) InitDelay() error

func (*Etcd) StatusCheck

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