vips

Documentation

Index

• Constants
• Variables
• func ConfigKey(mesh string) string
• func MeshFromConfigKey(name string) (string, bool)
• type Change
  • func (c Change) String() string
• type ChangeType
• type EntryType
  • func (t EntryType) String() string
• type GlobalView
  • func NewGlobalView(cidr string) (*GlobalView, error)
  • func (g *GlobalView) Allocate(hostname HostnameEntry) (string, error)
  • func (g *GlobalView) Reserve(hostname HostnameEntry, ip string) error
  • func (g *GlobalView) ToVIPMap() map[HostnameEntry]string
• type HostnameEntry
  • func NewFqdnEntry(name string) HostnameEntry
  • func NewHostEntry(host string) HostnameEntry
  • func NewServiceEntry(name string) HostnameEntry
  • func (e *HostnameEntry) Less(o *HostnameEntry) bool
  • func (e HostnameEntry) MarshalText() (text []byte, err error)
  • func (e HostnameEntry) String() string
  • func (e *HostnameEntry) UnmarshalText(text []byte) error
• type OutboundEntry
  • func (mo *OutboundEntry) Less(o *OutboundEntry) bool
  • func (mo *OutboundEntry) String() string
• type Persistence
  • func NewPersistence(resourceManager manager.ReadOnlyResourceManager, ...) *Persistence
  • func (m *Persistence) GetByMesh(ctx context.Context, mesh string) (*VirtualOutboundMeshView, error)
  • func (m *Persistence) Set(ctx context.Context, mesh string, vips *VirtualOutboundMeshView) error
• type VirtualOutbound
  • func (vo *VirtualOutbound) Equal(other *VirtualOutbound) bool
• type VirtualOutboundMeshView
  • func NewEmptyVirtualOutboundView() *VirtualOutboundMeshView
  • func NewVirtualOutboundView(all map[HostnameEntry]VirtualOutbound) (*VirtualOutboundMeshView, error)
  • func (vo *VirtualOutboundMeshView) Add(entry HostnameEntry, outbound OutboundEntry) error
  • func (vo *VirtualOutboundMeshView) DeleteByOrigin(origin string)
  • func (vo *VirtualOutboundMeshView) Get(entry HostnameEntry) *VirtualOutbound
  • func (vo *VirtualOutboundMeshView) HostnameEntries() []HostnameEntry
  • func (vo *VirtualOutboundMeshView) Update(new *VirtualOutboundMeshView) (changes []Change, out *VirtualOutboundMeshView)

Constants

const (
	OriginHost    = "host"
	OriginService = "service"
	OriginKube    = "kubernetes"
)

const (
	Add    = ChangeType("Add")
	Remove = ChangeType("Remove")
	Modify = ChangeType("Modify")
)

Variables

var OriginVirtualOutbound = func(name string) string { return "virtual-outbound:" + name }

Functions

func ConfigKey

func ConfigKey(mesh string) string

func MeshFromConfigKey

func MeshFromConfigKey(name string) (string, bool)

Types

type Change

type Change struct {
	Type  ChangeType
	Entry HostnameEntry
}

func (Change) String

func (c Change) String() string

type ChangeType

type ChangeType string

type EntryType

type EntryType int

const (
	Service EntryType = iota
	Host
	FullyQualifiedDomain
)

func (EntryType) String

func (t EntryType) String() string

type GlobalView

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

GlobalView keeps a list of all hostname/ips and add the possibility to allocate new ips

func NewGlobalView

func NewGlobalView(cidr string) (*GlobalView, error)

func (*GlobalView) Allocate

func (g *GlobalView) Allocate(hostname HostnameEntry) (string, error)

Allocate assign an ip to a host

func (*GlobalView) Reserve

func (g *GlobalView) Reserve(hostname HostnameEntry, ip string) error

Reserve add an ip/host to the list of reserved ips (useful when loading an existing view).

func (*GlobalView) ToVIPMap

func (g *GlobalView) ToVIPMap() map[HostnameEntry]string

type HostnameEntry

type HostnameEntry struct {
	Type EntryType `json:"type"`
	Name string    `json:"name"`
}

HostnameEntry is the definition of a DNS entry. The type indicates where the entry comes from (.e.g: Service is auto-generated, FullyQualifiedDomain comes from `virtual-outbound` policies...)

func NewFqdnEntry

func NewFqdnEntry(name string) HostnameEntry

func NewHostEntry

func NewHostEntry(host string) HostnameEntry

func NewServiceEntry

func NewServiceEntry(name string) HostnameEntry

func (*HostnameEntry) Less

func (e *HostnameEntry) Less(o *HostnameEntry) bool

func (HostnameEntry) MarshalText

func (e HostnameEntry) MarshalText() (text []byte, err error)

func (HostnameEntry) String

func (e HostnameEntry) String() string

func (*HostnameEntry) UnmarshalText

func (e *HostnameEntry) UnmarshalText(text []byte) error

type OutboundEntry

type OutboundEntry struct {
	Port   uint32
	TagSet map[string]string
	// A string to identify where this outbound was defined (usually the name of the outbound policy)
	Origin string
}

func (*OutboundEntry) Less

func (mo *OutboundEntry) Less(o *OutboundEntry) bool

func (*OutboundEntry) String

func (mo *OutboundEntry) String() string

type Persistence

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

func NewPersistence

func NewPersistence(resourceManager manager.ReadOnlyResourceManager, configManager config_manager.ConfigManager) *Persistence

func (*Persistence) GetByMesh

func (m *Persistence) GetByMesh(ctx context.Context, mesh string) (*VirtualOutboundMeshView, error)

func (*Persistence) Set

func (m *Persistence) Set(ctx context.Context, mesh string, vips *VirtualOutboundMeshView) error

type VirtualOutbound

type VirtualOutbound struct {
	// This is not default in the legacy case (hostnames won't be complete)
	Address   string          `json:"address,omitempty"`
	Outbounds []OutboundEntry `json:"outbounds,omitempty"`
}

VirtualOutbound the description of a hostname -> address and a list of port/tagSet that identifies each outbound.

func (*VirtualOutbound) Equal

func (vo *VirtualOutbound) Equal(other *VirtualOutbound) bool

type VirtualOutboundMeshView

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

func NewEmptyVirtualOutboundView

func NewEmptyVirtualOutboundView() *VirtualOutboundMeshView

func NewVirtualOutboundView

func NewVirtualOutboundView(all map[HostnameEntry]VirtualOutbound) (*VirtualOutboundMeshView, error)

func (*VirtualOutboundMeshView) Add

func (vo *VirtualOutboundMeshView) Add(entry HostnameEntry, outbound OutboundEntry) error

func (*VirtualOutboundMeshView) DeleteByOrigin

func (vo *VirtualOutboundMeshView) DeleteByOrigin(origin string)

func (*VirtualOutboundMeshView) Get

func (vo *VirtualOutboundMeshView) Get(entry HostnameEntry) *VirtualOutbound

func (*VirtualOutboundMeshView) HostnameEntries

func (vo *VirtualOutboundMeshView) HostnameEntries() []HostnameEntry

func (*VirtualOutboundMeshView) Update

func (vo *VirtualOutboundMeshView) Update(new *VirtualOutboundMeshView) (changes []Change, out *VirtualOutboundMeshView)

Update merges `new` and `vo` in a new `out` and returns a list of changes.