package status

import "istio.io/istio/galley/pkg/config/source/kube/apiserver/status"

Index ¶

• Constants
• type Controller
• type ControllerImpl
• func NewController(subfield string) *ControllerImpl
• func (c *ControllerImpl) Report(messages diag.Messages)
• func (c *ControllerImpl) Start(p *rt.Provider, resources []collection.Schema)
• func (c *ControllerImpl) Stop()
• func (c *ControllerImpl) UpdateResourceStatus( col collection.Name, name resource.FullName, version resource.Version, status interface{})
• type Messages
• func NewMessageSet() Messages
• func (m *Messages) Add(origin *rt.Origin, msg diag.Message)

Package Files ¶

controller.go messages.go state.go status.go util.go

Constants ¶

const DocRef = "status-controller"

DocRef is the doc ref value used by the status controller

type Controller ¶ Uses

type Controller interface {
    Start(p *rt.Provider, resources []collection.Schema)
    Stop()
    UpdateResourceStatus(col collection.Name, name resource.FullName, version resource.Version, status interface{})
    Report(messages diag.Messages)
}

Controller is the interface for a status controller. It is mainly used to separate implementation from interface, so that code can be tested separately.

type ControllerImpl ¶ Uses

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

ControllerImpl keeps track of status information for a given K8s style collection and continuously reconciles.

func NewController ¶ Uses

func NewController(subfield string) *ControllerImpl

NewController returns a new instance of controller.

func (*ControllerImpl) Report ¶ Uses

func (c *ControllerImpl) Report(messages diag.Messages)

Report the given set of messages towards particular resources.

func (*ControllerImpl) Start ¶ Uses

func (c *ControllerImpl) Start(p *rt.Provider, resources []collection.Schema)

Start the controller. This will reset the internal state.

func (*ControllerImpl) Stop ¶ Uses

func (c *ControllerImpl) Stop()

Stop the controller

func (*ControllerImpl) UpdateResourceStatus ¶ Uses

func (c *ControllerImpl) UpdateResourceStatus(
    col collection.Name, name resource.FullName, version resource.Version, status interface{})

UpdateResourceStatus is called by the source to relay the currently observed status of a resource.

type Messages ¶ Uses

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

Messages is a data structure for capturing incoming messages

func NewMessageSet ¶ Uses

func NewMessageSet() Messages

NewMessageSet returns a new instance of message set.

func (*Messages) Add ¶ Uses

func (m *Messages) Add(origin *rt.Origin, msg diag.Message)

Add a new message for a given origin.