store

Documentation

Index

• type AccessPolicies
  • func NewAccessPolicies(manager store.Manager) (*AccessPolicies, error)
  • func (s *AccessPolicies) Create(policy *AccessPolicy) error
  • func (s *AccessPolicies) Delete(name string) (*AccessPolicy, error)
  • func (s *AccessPolicies) Get(name string) *AccessPolicy
  • func (s *AccessPolicies) GetAll() []*AccessPolicy
  • func (s *AccessPolicies) Len() int
  • func (s *AccessPolicies) Update(name string, mutator func(*AccessPolicy) *AccessPolicy) error
• type AccessPolicy
  • func NewAccessPolicy(policy *api.Policy) *AccessPolicy
• type Export
  • func NewExport(export *v1alpha1.Export) *Export
• type Exports
  • func NewExports(manager store.Manager) (*Exports, error)
  • func (s *Exports) Create(export *Export) error
  • func (s *Exports) Delete(name string) (*Export, error)
  • func (s *Exports) Get(name string) *Export
  • func (s *Exports) GetAll() []*Export
  • func (s *Exports) Len() int
  • func (s *Exports) Update(name string, mutator func(*Export) *Export) error
• type Import
  • func NewImport(imp *v1alpha1.Import) *Import
• type Imports
  • func NewImports(manager store.Manager) (*Imports, error)
  • func (s *Imports) Create(imp *Import) error
  • func (s *Imports) Delete(name string) (*Import, error)
  • func (s *Imports) Get(name string) *Import
  • func (s *Imports) GetAll() []*Import
  • func (s *Imports) Len() int
  • func (s *Imports) Update(name string, mutator func(*Import) *Import) error
• type LBPolicies
  • func NewLBPolicies(manager store.Manager) (*LBPolicies, error)
  • func (s *LBPolicies) Create(policy *LBPolicy) error
  • func (s *LBPolicies) Delete(name string) (*LBPolicy, error)
  • func (s *LBPolicies) Get(name string) *LBPolicy
  • func (s *LBPolicies) GetAll() []*LBPolicy
  • func (s *LBPolicies) Len() int
  • func (s *LBPolicies) Update(name string, mutator func(*LBPolicy) *LBPolicy) error
• type LBPolicy
  • func NewLBPolicy(policy *api.Policy) *LBPolicy
• type Peer
  • func NewPeer(peer *v1alpha1.Peer) *Peer
• type Peers
  • func NewPeers(manager store.Manager) (*Peers, error)
  • func (s *Peers) Create(peer *Peer) error
  • func (s *Peers) Delete(name string) (*Peer, error)
  • func (s *Peers) Get(name string) *Peer
  • func (s *Peers) GetAll() []*Peer
  • func (s *Peers) Len() int
  • func (s *Peers) Update(name string, mutator func(*Peer) *Peer) error

Types

type AccessPolicies

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

AccessPolicies is a cached persistent store of Access Policies.

func NewAccessPolicies

func NewAccessPolicies(manager store.Manager) (*AccessPolicies, error)

NewAccessPolicies returns a new cached store of access policies.

func (*AccessPolicies) Create

func (s *AccessPolicies) Create(policy *AccessPolicy) error

Create an AccessPolicy.

func (*AccessPolicies) Delete

func (s *AccessPolicies) Delete(name string) (*AccessPolicy, error)

Delete an access policy.

func (*AccessPolicies) Get

func (s *AccessPolicies) Get(name string) *AccessPolicy

Get an access policy.

func (*AccessPolicies) GetAll

func (s *AccessPolicies) GetAll() []*AccessPolicy

GetAll returns all access policies in the cache.

func (*AccessPolicies) Len

func (s *AccessPolicies) Len() int

Len returns the number of cached access policies.

func (*AccessPolicies) Update

func (s *AccessPolicies) Update(name string, mutator func(*AccessPolicy) *AccessPolicy) error

Update an access policy.

type AccessPolicy

type AccessPolicy struct {
	api.Policy
	// Version of the struct when object was created.
	Version uint32
}

AccessPolicy to allow/deny specific connections.

func NewAccessPolicy

func NewAccessPolicy(policy *api.Policy) *AccessPolicy

NewAccessPolicy creates a new access policy.

type Export

type Export struct {
	v1alpha1.ExportSpec
	// Name of the export.
	Name string
	// Version of the struct when object was created.
	Version uint32
}

Export represents a local service that may be exported.

func NewExport

func NewExport(export *v1alpha1.Export) *Export

NewExport creates a new export.

type Exports

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

Exports is a cached persistent store of exports.

func NewExports

func NewExports(manager store.Manager) (*Exports, error)

NewExports returns a new cached store of exports.

func (*Exports) Create

func (s *Exports) Create(export *Export) error

Create an export.

func (*Exports) Delete

func (s *Exports) Delete(name string) (*Export, error)

Delete an export.

func (*Exports) Get

func (s *Exports) Get(name string) *Export

Get an export.

func (*Exports) GetAll

func (s *Exports) GetAll() []*Export

GetAll returns all exports in the cache.

func (*Exports) Len

func (s *Exports) Len() int

Len returns the number of cached exports.

func (*Exports) Update

func (s *Exports) Update(name string, mutator func(*Export) *Export) error

Update an export.

type Import

type Import struct {
	v1alpha1.ImportSpec
	// Name of import.
	Name string
	// Version of the struct when object was created.
	Version uint32
}

Import represents an external service that can be bound to (multiple) exported services of remote peers.

func NewImport

func NewImport(imp *v1alpha1.Import) *Import

NewImport creates a new import.

type Imports

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

Imports is a cached persistent store of imports.

func NewImports

func NewImports(manager store.Manager) (*Imports, error)

NewImports returns a new cached store of imports.

func (*Imports) Create

func (s *Imports) Create(imp *Import) error

Create an import.

func (*Imports) Delete

func (s *Imports) Delete(name string) (*Import, error)

Delete an import.

func (*Imports) Get

func (s *Imports) Get(name string) *Import

Get an import.

func (*Imports) GetAll

func (s *Imports) GetAll() []*Import

GetAll returns all imports in the cache.

func (*Imports) Len

func (s *Imports) Len() int

Len returns the number of cached imports.

func (*Imports) Update

func (s *Imports) Update(name string, mutator func(*Import) *Import) error

Update an import.

type LBPolicies

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

LBPolicies is a cached persistent store of Load-Balancing Policies.

func NewLBPolicies

func NewLBPolicies(manager store.Manager) (*LBPolicies, error)

NewLBPolicies returns a new cached store of load-balancing policies.

func (*LBPolicies) Create

func (s *LBPolicies) Create(policy *LBPolicy) error

Create a Load-Balancing Policy.

func (*LBPolicies) Delete

func (s *LBPolicies) Delete(name string) (*LBPolicy, error)

Delete a load-balancing policy.

func (*LBPolicies) Get

func (s *LBPolicies) Get(name string) *LBPolicy

Get a load-balancing policy.

func (*LBPolicies) GetAll

func (s *LBPolicies) GetAll() []*LBPolicy

GetAll returns all load-balancing policies in the cache.

func (*LBPolicies) Len

func (s *LBPolicies) Len() int

Len returns the number of cached load-balancing policies.

func (*LBPolicies) Update

func (s *LBPolicies) Update(name string, mutator func(*LBPolicy) *LBPolicy) error

Update a load-balancing policy.

type LBPolicy

type LBPolicy struct {
	api.Policy
	// Version of the struct when object was created.
	Version uint32
}

LBPolicy specifies the load-balancing scheme for specific connections.

func NewLBPolicy

func NewLBPolicy(policy *api.Policy) *LBPolicy

NewLBPolicy creates a new load-balancing policy.

type Peer

type Peer struct {
	v1alpha1.PeerSpec
	// Name of the peer.
	Name string
	// Version of the struct when object was created.
	Version uint32
}

Peer represents a remote peer.

func NewPeer

func NewPeer(peer *v1alpha1.Peer) *Peer

NewPeer creates a new peer.

type Peers

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

Peers is a cached persistent store of peers.

func NewPeers

func NewPeers(manager store.Manager) (*Peers, error)

NewPeers returns a new cached store of peers.

func (*Peers) Create

func (s *Peers) Create(peer *Peer) error

Create a peer.

func (*Peers) Delete

func (s *Peers) Delete(name string) (*Peer, error)

Delete a peer.

func (*Peers) Get

func (s *Peers) Get(name string) *Peer

Get a peer.

func (*Peers) GetAll

func (s *Peers) GetAll() []*Peer

GetAll returns all peers in the cache.

func (*Peers) Len

func (s *Peers) Len() int

Len returns the number of cached peers.

func (*Peers) Update

func (s *Peers) Update(name string, mutator func(*Peer) *Peer) error

Update a peer.