etcd

Documentation

Index

• Variables
• type Codec
• type ContainerInfoCodec
  • func (codec ContainerInfoCodec) Decode(input string) error
  • func (codec ContainerInfoCodec) Encode() (string, error)
  • func (codec ContainerInfoCodec) Key() string
  • func (codec *ContainerInfoCodec) SetVersion(version int64)
  • func (codec *ContainerInfoCodec) Version() int64
• type Decoder
• type Encoder
• type Etcd
  • func NewEtcdClient(ctx context.Context, config apiconfig.CalicoAPIConfig) (*Etcd, error)
  • func (e *Etcd) AquireIfReserved(ctx context.Context, address *types.ReservedAddress) (bool, error)
  • func (e *Etcd) ConsumeRequestMarkIfPresent(ctx context.Context, request *types.ReserveRequest) (bool, error)
  • func (e *Etcd) Delete(ctx context.Context, encoder Encoder) (bool, error)
  • func (e *Etcd) Get(ctx context.Context, decoder Decoder) (bool, error)
  • func (e *Etcd) GetAndDelete(ctx context.Context, decoder Decoder) (bool, error)
  • func (e *Etcd) IPIsReserved(ctx context.Context, address *types.ReservedAddress) (bool, error)
  • func (e *Etcd) Put(ctx context.Context, encoder Encoder) error
  • func (e *Etcd) PutMulti(ctx context.Context, encoders ...Encoder) error
  • func (e *Etcd) ReserveIPforContainer(ctx context.Context, address *types.ReservedAddress, containerID string) error
  • func (e *Etcd) Update(ctx context.Context, encoder Encoder) (bool, error)
• type ReserveRequestCodec
  • func (codec ReserveRequestCodec) Decode(input string) error
  • func (codec ReserveRequestCodec) Encode() (string, error)
  • func (codec ReserveRequestCodec) Key() string
  • func (codec *ReserveRequestCodec) SetVersion(version int64)
  • func (codec *ReserveRequestCodec) Version() int64
• type ReservedAddressCodec
  • func (codec ReservedAddressCodec) Decode(input string) error
  • func (codec *ReservedAddressCodec) Encode() (string, error)
  • func (codec *ReservedAddressCodec) Key() string
  • func (codec *ReservedAddressCodec) SetVersion(version int64)
  • func (codec *ReservedAddressCodec) Version() int64

Variables

var (
	// ErrKeyIsBlank .
	ErrKeyIsBlank = errors.New("Key shouldn't be blank")
)

Types

type Codec

type Codec interface {
	Encoder
	Decoder
}

Codec .

type ContainerInfoCodec

type ContainerInfoCodec struct {
	Info *types.ContainerInfo
	// contains filtered or unexported fields
}

ContainerInfoCodec .

func (ContainerInfoCodec) Decode

func (codec ContainerInfoCodec) Decode(input string) error

Decode .

func (ContainerInfoCodec) Encode

func (codec ContainerInfoCodec) Encode() (string, error)

Encode .

func (ContainerInfoCodec) Key

func (codec ContainerInfoCodec) Key() string

Key .

func (*ContainerInfoCodec) SetVersion

func (codec *ContainerInfoCodec) SetVersion(version int64)

SetVersion .

func (*ContainerInfoCodec) Version

func (codec *ContainerInfoCodec) Version() int64

Version .

type Decoder

type Decoder interface {
	Key() string
	Decode(string) error
	SetVersion(int64)
}

Decoder .

type Encoder

type Encoder interface {
	Key() string
	Encode() (string, error)
	Version() int64
}

Encoder .

type Etcd

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

Etcd .

func NewEtcdClient

func NewEtcdClient(ctx context.Context, config apiconfig.CalicoAPIConfig) (*Etcd, error)

NewEtcdClient .

func (*Etcd) AquireIfReserved

func (e *Etcd) AquireIfReserved(ctx context.Context, address *types.ReservedAddress) (bool, error)

AquireIfReserved .

func (*Etcd) ConsumeRequestMarkIfPresent

func (e *Etcd) ConsumeRequestMarkIfPresent(ctx context.Context, request *types.ReserveRequest) (bool, error)

ConsumeRequestMarkIfPresent .

func (*Etcd) Delete

func (e *Etcd) Delete(ctx context.Context, encoder Encoder) (bool, error)

Delete delete key returns true on delete count > 0

func (*Etcd) Get

func (e *Etcd) Get(ctx context.Context, decoder Decoder) (bool, error)

Get .

func (*Etcd) GetAndDelete

func (e *Etcd) GetAndDelete(ctx context.Context, decoder Decoder) (bool, error)

GetAndDelete delete key, and return value returns true on delete count > 0

func (*Etcd) IPIsReserved

func (e *Etcd) IPIsReserved(ctx context.Context, address *types.ReservedAddress) (bool, error)

IPIsReserved .

func (*Etcd) Put

func (e *Etcd) Put(ctx context.Context, encoder Encoder) error

Put save a key value

func (*Etcd) PutMulti

func (e *Etcd) PutMulti(ctx context.Context, encoders ...Encoder) error

PutMulti .

func (*Etcd) ReserveIPforContainer

func (e *Etcd) ReserveIPforContainer(ctx context.Context, address *types.ReservedAddress, containerID string) error

ReserveIPforContainer .

func (*Etcd) Update

func (e *Etcd) Update(ctx context.Context, encoder Encoder) (bool, error)

Update .

type ReserveRequestCodec

type ReserveRequestCodec struct {
	Request *types.ReserveRequest
	// contains filtered or unexported fields
}

ReserveRequestCodec .

func (ReserveRequestCodec) Decode

func (codec ReserveRequestCodec) Decode(input string) error

Decode .

func (ReserveRequestCodec) Encode

func (codec ReserveRequestCodec) Encode() (string, error)

Encode .

func (ReserveRequestCodec) Key

func (codec ReserveRequestCodec) Key() string

Key .

func (*ReserveRequestCodec) SetVersion

func (codec *ReserveRequestCodec) SetVersion(version int64)

SetVersion .

func (*ReserveRequestCodec) Version

func (codec *ReserveRequestCodec) Version() int64

Version .

type ReservedAddressCodec

type ReservedAddressCodec struct {
	Address *types.ReservedAddress
	// contains filtered or unexported fields
}

ReservedAddressCodec .

func (ReservedAddressCodec) Decode

func (codec ReservedAddressCodec) Decode(input string) error

Decode .

func (*ReservedAddressCodec) Encode

func (codec *ReservedAddressCodec) Encode() (string, error)

Encode .

func (*ReservedAddressCodec) Key

func (codec *ReservedAddressCodec) Key() string

Key .

func (*ReservedAddressCodec) SetVersion

func (codec *ReservedAddressCodec) SetVersion(version int64)

SetVersion .

func (*ReservedAddressCodec) Version

func (codec *ReservedAddressCodec) Version() int64

Version .