statusutils

Documentation

Index

• Constants
• func GetSingleStatusInNamespacedStatuses(resource resources.InputResource) *core.Status
• func GetStatusReporterNamespaceFromEnv() (string, error)
• func SetSingleStatusInNamespacedStatuses(resource resources.InputResource, status *core.Status)
• type NamespacedStatusesClient
  • func NewNamespacedStatusesClient(namespace string) *NamespacedStatusesClient
  • func (s *NamespacedStatusesClient) GetStatus(resource resources.InputResource) *core.Status
  • func (s *NamespacedStatusesClient) SetStatus(resource resources.InputResource, status *core.Status)
• type NamespacedStatusesUnmarshaler
  • func NewNamespacedStatusesUnmarshaler(unmarshalMapToProto func(m map[string]interface{}, into proto.Message) error) *NamespacedStatusesUnmarshaler
  • func (n *NamespacedStatusesUnmarshaler) UnmarshalStatus(resourceStatus v1.Status, into resources.InputResource)
• type NoOpStatusClient
  • func NewNoOpStatusClient() *NoOpStatusClient
  • func (n *NoOpStatusClient) GetStatus(resource resources.InputResource) *core.Status
  • func (n *NoOpStatusClient) SetStatus(resource resources.InputResource, status *core.Status)
• type SingleStatusUnmarshaler
  • func (s *SingleStatusUnmarshaler) UnmarshalStatus(status v1.Status, into resources.InputResource)

Constants

const PodNamespaceEnvName = "POD_NAMESPACE"

The name of the environment variable used by resource reporters to associate a resource status with the appropriate controller statusReporterNamespace

Functions

func GetSingleStatusInNamespacedStatuses

func GetSingleStatusInNamespacedStatuses(resource resources.InputResource) *core.Status

func GetStatusReporterNamespaceFromEnv

func GetStatusReporterNamespaceFromEnv() (string, error)

noinspection GoUnusedExportedFunction

func SetSingleStatusInNamespacedStatuses

func SetSingleStatusInNamespacedStatuses(resource resources.InputResource, status *core.Status)

Types

type NamespacedStatusesClient

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

InputResources support multiple statuses, each set by a particular controller Each controller should only update its own status, so we expose a client with simple Get/Set capabilities. This way, the consumers of this client do not need to be aware of the statusReporterNamespace.

func NewNamespacedStatusesClient

func NewNamespacedStatusesClient(namespace string) *NamespacedStatusesClient

func (*NamespacedStatusesClient) GetStatus

func (s *NamespacedStatusesClient) GetStatus(resource resources.InputResource) *core.Status

func (*NamespacedStatusesClient) SetStatus

func (s *NamespacedStatusesClient) SetStatus(resource resources.InputResource, status *core.Status)

type NamespacedStatusesUnmarshaler

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

func NewNamespacedStatusesUnmarshaler

func NewNamespacedStatusesUnmarshaler(
	unmarshalMapToProto func(m map[string]interface{}, into proto.Message) error) *NamespacedStatusesUnmarshaler

func (*NamespacedStatusesUnmarshaler) UnmarshalStatus

func (n *NamespacedStatusesUnmarshaler) UnmarshalStatus(resourceStatus v1.Status, into resources.InputResource)

type NoOpStatusClient

type NoOpStatusClient struct {
}

func NewNoOpStatusClient

func NewNoOpStatusClient() *NoOpStatusClient

noinspection GoUnusedExportedFunction

func (*NoOpStatusClient) GetStatus

func (n *NoOpStatusClient) GetStatus(resource resources.InputResource) *core.Status

func (*NoOpStatusClient) SetStatus

func (n *NoOpStatusClient) SetStatus(resource resources.InputResource, status *core.Status)

type SingleStatusUnmarshaler

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

func (*SingleStatusUnmarshaler) UnmarshalStatus

func (s *SingleStatusUnmarshaler) UnmarshalStatus(status v1.Status, into resources.InputResource)