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 *v1alpha1.AccessPolicy) *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 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 {
	v1alpha1.AccessPolicySpec
	// Name of access policy.
	Name string
	// Version of the struct when object was created.
	Version uint32
}

AccessPolicy to allow/deny specific connections.

func NewAccessPolicy

func NewAccessPolicy(policy *v1alpha1.AccessPolicy) *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
	// Labels defined for the import
	Labels map[string]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 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.