istio: istio.io/istio/galley/pkg/config/source/kube/apiserver/status Index | Files

package status

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

Index

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.

Package status imports 10 packages (graph) and is imported by 3 packages. Updated 2020-04-06. Refresh now. Tools for package owners.