istio: istio.io/istio/pilot/pkg/config/coredatamodel Index | Files

package coredatamodel

import "istio.io/istio/pilot/pkg/config/coredatamodel"

Index

Package Files

controller.go discovery.go syntheticserviceentrycontroller.go

type Controller Uses

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

Controller is a temporary storage for the changes received via MCP server

func (*Controller) Apply Uses

func (c *Controller) Apply(change *sink.Change) error

Apply receives changes from MCP server and creates the corresponding config

func (*Controller) ConfigDescriptor Uses

func (c *Controller) ConfigDescriptor() schema.Set

ConfigDescriptor returns all the ConfigDescriptors that this controller is responsible for

func (*Controller) Create Uses

func (c *Controller) Create(config model.Config) (revision string, err error)

Create is not implemented

func (*Controller) Delete Uses

func (c *Controller) Delete(typ, name, namespace string) error

Delete is not implemented

func (*Controller) Get Uses

func (c *Controller) Get(typ, name, namespace string) *model.Config

Get is not implemented

func (*Controller) GetResourceAtVersion Uses

func (c *Controller) GetResourceAtVersion(version string, key string) (resourceVersion string, err error)

func (*Controller) HasSynced Uses

func (c *Controller) HasSynced() bool

HasSynced returns true if the first batch of items has been popped

func (*Controller) List Uses

func (c *Controller) List(typ, namespace string) (out []model.Config, err error)

List returns all the config that is stored by type and namespace if namespace is empty string it returns config for all the namespaces

func (*Controller) RegisterEventHandler Uses

func (c *Controller) RegisterEventHandler(typ string, handler func(model.Config, model.Event))

RegisterEventHandler registers a handler using the type as a key

func (*Controller) Run Uses

func (c *Controller) Run(stop <-chan struct{})

Run is not implemented

func (*Controller) Update Uses

func (c *Controller) Update(config model.Config) (newRevision string, err error)

Update is not implemented

func (*Controller) Version Uses

func (c *Controller) Version() string

type CoreDataModel Uses

type CoreDataModel interface {
    model.ConfigStoreCache
    sink.Updater
}

CoreDataModel is a combined interface for ConfigStoreCache and MCP Updater

func NewController Uses

func NewController(options *Options) CoreDataModel

NewController provides a new CoreDataModel controller

func NewSyntheticServiceEntryController Uses

func NewSyntheticServiceEntryController(options *Options, d *MCPDiscovery) CoreDataModel

NewSyntheticServiceEntryController provides a new incremental CoreDataModel controller

type DiscoveryOptions Uses

type DiscoveryOptions struct {
    XDSUpdater   model.XDSUpdater
    Env          *model.Environment
    ClusterID    string
    DomainSuffix string
}

DiscoveryOptions stores the configurable attributes of a Control

type MCPDiscovery Uses

type MCPDiscovery struct {
    *DiscoveryOptions
    // contains filtered or unexported fields
}

MCPDiscovery provides storage for NotReadyEndpoints

func NewMCPDiscovery Uses

func NewMCPDiscovery(options *DiscoveryOptions) *MCPDiscovery

NewMCPDiscovery provides a new instance of Discovery

func (*MCPDiscovery) AppendInstanceHandler Uses

func (d *MCPDiscovery) AppendInstanceHandler(f func(*model.ServiceInstance, model.Event)) error

AppendInstanceHandler Not Supported

func (*MCPDiscovery) AppendServiceHandler Uses

func (d *MCPDiscovery) AppendServiceHandler(f func(*model.Service, model.Event)) error

AppendServiceHandler Not Supported

func (*MCPDiscovery) GetIstioServiceAccounts Uses

func (d *MCPDiscovery) GetIstioServiceAccounts(svc *model.Service, ports []int) []string

GetIstioServiceAccounts Not Supported

func (*MCPDiscovery) GetProxyServiceInstances Uses

func (d *MCPDiscovery) GetProxyServiceInstances(proxy *model.Proxy) ([]*model.ServiceInstance, error)

GetProxyServiceInstances returns service instances co-located with a given proxy

func (*MCPDiscovery) GetProxyWorkloadLabels Uses

func (d *MCPDiscovery) GetProxyWorkloadLabels(*model.Proxy) (labels.Collection, error)

GetProxyWorkloadLabels Not Supported

func (*MCPDiscovery) GetService Uses

func (d *MCPDiscovery) GetService(hostname host.Name) (*model.Service, error)

GetService implements a service catalog operation by hostname specified.

func (*MCPDiscovery) InstancesByPort Uses

func (d *MCPDiscovery) InstancesByPort(svc *model.Service, servicePort int, labels labels.Collection) ([]*model.ServiceInstance, error)

InstancesByPort implements a service catalog operation

func (*MCPDiscovery) ManagementPorts Uses

func (d *MCPDiscovery) ManagementPorts(addr string) model.PortList

ManagementPorts Not Supported

func (*MCPDiscovery) RegisterNotReadyEndpoints Uses

func (d *MCPDiscovery) RegisterNotReadyEndpoints(conf *model.Config)

RegisterNotReadyEndpoints registers newly received NotReadyEndpoints via MCP annotations

func (*MCPDiscovery) Run Uses

func (d *MCPDiscovery) Run(stop <-chan struct{})

Run until a signal is received

func (*MCPDiscovery) Services Uses

func (d *MCPDiscovery) Services() ([]*model.Service, error)

Services Not Supported

func (*MCPDiscovery) WorkloadHealthCheckInfo Uses

func (d *MCPDiscovery) WorkloadHealthCheckInfo(addr string) model.ProbeList

WorkloadHealthCheckInfo Not Supported

type Options Uses

type Options struct {
    ClusterID    string
    DomainSuffix string
    XDSUpdater   model.XDSUpdater
    ConfigLedger ledger.Ledger
}

Options stores the configurable attributes of a Control

type SyntheticServiceEntryController Uses

type SyntheticServiceEntryController struct {
    *Options
    // contains filtered or unexported fields
}

SyntheticServiceEntryController is a temporary storage for the changes received via MCP server

func (*SyntheticServiceEntryController) Apply Uses

func (c *SyntheticServiceEntryController) Apply(change *sink.Change) error

Apply receives changes from MCP server and creates the corresponding config

func (*SyntheticServiceEntryController) ConfigDescriptor Uses

func (c *SyntheticServiceEntryController) ConfigDescriptor() schema.Set

ConfigDescriptor returns all the ConfigDescriptors that this controller is responsible for

func (*SyntheticServiceEntryController) Create Uses

func (c *SyntheticServiceEntryController) Create(config model.Config) (revision string, err error)

Create is not implemented

func (*SyntheticServiceEntryController) Delete Uses

func (c *SyntheticServiceEntryController) Delete(typ, name, namespace string) error

Delete is not implemented

func (*SyntheticServiceEntryController) Get Uses

func (c *SyntheticServiceEntryController) Get(typ, name, namespace string) *model.Config

Get is not implemented

func (*SyntheticServiceEntryController) GetResourceAtVersion Uses

func (c *SyntheticServiceEntryController) GetResourceAtVersion(version string, key string) (resourceVersion string, err error)

GetResourceAtVersion is not implemented

func (*SyntheticServiceEntryController) HasSynced Uses

func (c *SyntheticServiceEntryController) HasSynced() bool

HasSynced returns true if the first batch of items has been popped

func (*SyntheticServiceEntryController) List Uses

func (c *SyntheticServiceEntryController) List(typ, namespace string) (out []model.Config, err error)

List returns all the SyntheticServiceEntries that is stored by type and namespace if namespace is empty string it returns config for all the namespaces

func (*SyntheticServiceEntryController) RegisterEventHandler Uses

func (c *SyntheticServiceEntryController) RegisterEventHandler(typ string, handler func(model.Config, model.Event))

RegisterEventHandler registers a handler using the type as a key

func (*SyntheticServiceEntryController) Run Uses

func (c *SyntheticServiceEntryController) Run(stop <-chan struct{})

Run is not implemented

func (*SyntheticServiceEntryController) Update Uses

func (c *SyntheticServiceEntryController) Update(config model.Config) (newRevision string, err error)

Update is not implemented

func (*SyntheticServiceEntryController) Version Uses

func (c *SyntheticServiceEntryController) Version() string

Version is not implemented

Package coredatamodel imports 21 packages (graph) and is imported by 2 packages. Updated 2019-10-16. Refresh now. Tools for package owners.