Version: v0.8.0 Latest Latest

This package is not in the latest version of its module.

Go to latest
Published: Jul 11, 2017 License: Apache-2.0 Imports: 17 Imported by: 0




View Source
const DEFAULT_TTL time.Duration = 8760 * time.Hour // one year


This section is empty.


func NewLocalManager

func NewLocalManager(config *EtcdConfig, prevSubnet ip.IP4Net) (Manager, error)

func NewMockManager

func NewMockManager(registry *MockSubnetRegistry) subnet.Manager

func NewMockManagerWithSubnet

func NewMockManagerWithSubnet(registry *MockSubnetRegistry, sn ip.IP4Net) subnet.Manager


type EtcdConfig

type EtcdConfig struct {
	Endpoints []string
	Keyfile   string
	Certfile  string
	CAFile    string
	Prefix    string
	Username  string
	Password  string

type LocalManager

type LocalManager struct {
	// contains filtered or unexported fields

func (*LocalManager) AcquireLease

func (m *LocalManager) AcquireLease(ctx context.Context, attrs *LeaseAttrs) (*Lease, error)

func (*LocalManager) AddReservation

func (m *LocalManager) AddReservation(ctx context.Context, r *Reservation) error

func (*LocalManager) GetNetworkConfig

func (m *LocalManager) GetNetworkConfig(ctx context.Context) (*Config, error)

func (*LocalManager) ListReservations

func (m *LocalManager) ListReservations(ctx context.Context) ([]Reservation, error)

func (*LocalManager) Name

func (m *LocalManager) Name() string

func (*LocalManager) RemoveReservation

func (m *LocalManager) RemoveReservation(ctx context.Context, subnet ip.IP4Net) error

RemoveReservation removes the subnet by setting TTL back to subnetTTL (24hours)

func (*LocalManager) RenewLease

func (m *LocalManager) RenewLease(ctx context.Context, lease *Lease) error

func (*LocalManager) RevokeLease

func (m *LocalManager) RevokeLease(ctx context.Context, sn ip.IP4Net) error

func (*LocalManager) WatchLease

func (m *LocalManager) WatchLease(ctx context.Context, sn ip.IP4Net, cursor interface{}) (LeaseWatchResult, error)

func (*LocalManager) WatchLeases

func (m *LocalManager) WatchLeases(ctx context.Context, cursor interface{}) (LeaseWatchResult, error)

type MockSubnetRegistry

type MockSubnetRegistry struct {
	// contains filtered or unexported fields

func NewMockRegistry

func NewMockRegistry(config string, initialSubnets []Lease) *MockSubnetRegistry

type Registry

type Registry interface {
	// contains filtered or unexported methods

Jump to

Keyboard shortcuts

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