etcd

package

v0.0.0-...-319b497 Latest Latest Go to latest Published: Sep 2, 2020 License: MIT Imports: 10 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/projecteru2/minions

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
type Codec
type ContainerInfoCodec
type Decoder
type Encoder
type Etcd
- func NewEtcdClient(ctx context.Context, config apiconfig.CalicoAPIConfig) (*Etcd, error)
type ReserveRequestCodec
type ReservedAddressCodec

Constants ¶

This section is empty.

Variables ¶

View Source

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

Functions ¶

This section is empty.

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 .

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL