common

Documentation

Index

• Constants
• func AnyResourcesInUse(resources []client.ResourceWithVolumes) bool
• func ClusterPrivateVolumeAgent(deployedVol client.Volume, resource string) *reactor.ResourceAgent
• func DevicePath(vol client.Volume) string
• func NoResourcesInUse(resources []client.ResourceWithVolumes) bool
• func WaitUntilResourceCondition(ctx context.Context, cli *client.Client, name string, ...) error
• type IpCidr
  • func ServiceIPFromParts(ip net.IP, prefix int) IpCidr
  • func ServiceIPFromString(s string) (IpCidr, error)
  • func (s *IpCidr) IP() net.IP
  • func (s IpCidr) MarshalJSON() ([]byte, error)
  • func (s *IpCidr) Prefix() int
  • func (s *IpCidr) Set(raw string) error
  • func (s *IpCidr) Type() string
  • func (s *IpCidr) UnmarshalJSON(b []byte) error
• type ResourceState
  • func (l ResourceState) MarshalJSON() ([]byte, error)
  • func (l ResourceState) String() string
  • func (l *ResourceState) UnmarshalJSON(text []byte) error
• type ResourceStatus
• type ServiceState
  • func (s ServiceState) MarshalJSON() ([]byte, error)
  • func (s ServiceState) String() string
  • func (s *ServiceState) UnmarshalJSON(text []byte) error
• type UidGid
  • func (u *UidGid) String() string
• type ValidationError
  • func (v ValidationError) Error() string
• type Volume
• type VolumeConfig
  • func ClusterPrivateVolume() VolumeConfig
• type VolumeState

Constants

const (
	ClusterPrivateVolumeMountPath = "/srv/ha/internal"
	ClusterPrivateVolumeAgentName = "fs_cluster_private"
)

Functions

func AnyResourcesInUse

func AnyResourcesInUse(resources []client.ResourceWithVolumes) bool

func ClusterPrivateVolumeAgent

func ClusterPrivateVolumeAgent(deployedVol client.Volume, resource string) *reactor.ResourceAgent

func DevicePath

func DevicePath(vol client.Volume) string

func NoResourcesInUse

func NoResourcesInUse(resources []client.ResourceWithVolumes) bool

func WaitUntilResourceCondition

func WaitUntilResourceCondition(ctx context.Context, cli *client.Client, name string, condition func([]client.ResourceWithVolumes) bool) error

Types

type IpCidr

type IpCidr struct {
	net.IPNet
}

func ServiceIPFromParts

func ServiceIPFromParts(ip net.IP, prefix int) IpCidr

func ServiceIPFromString

func ServiceIPFromString(s string) (IpCidr, error)

func (*IpCidr) IP

func (s *IpCidr) IP() net.IP

func (IpCidr) MarshalJSON

func (s IpCidr) MarshalJSON() ([]byte, error)

func (*IpCidr) Prefix

func (s *IpCidr) Prefix() int

func (*IpCidr) Set

func (s *IpCidr) Set(raw string) error

func (*IpCidr) Type

func (s *IpCidr) Type() string

func (*IpCidr) UnmarshalJSON

func (s *IpCidr) UnmarshalJSON(b []byte) error

type ResourceState

type ResourceState int

const (
	Unknown ResourceState = iota
	ResourceStateOK
	ResourceStateDegraded
	ResourceStateBad
)

func (ResourceState) MarshalJSON

func (l ResourceState) MarshalJSON() ([]byte, error)

func (ResourceState) String

func (l ResourceState) String() string

func (*ResourceState) UnmarshalJSON

func (l *ResourceState) UnmarshalJSON(text []byte) error

type ResourceStatus

type ResourceStatus struct {
	State   ResourceState `json:"state"`
	Service ServiceState  `json:"service"`
	Primary string        `json:"primary"`
	Nodes   []string      `json:"nodes"`
	Volumes []VolumeState `json:"volumes"`
}

type ServiceState

type ServiceState int

const (
	ServiceStateStopped ServiceState = iota
	ServiceStateStarted
)

func (ServiceState) MarshalJSON

func (s ServiceState) MarshalJSON() ([]byte, error)

func (ServiceState) String

func (s ServiceState) String() string

func (*ServiceState) UnmarshalJSON

func (s *ServiceState) UnmarshalJSON(text []byte) error

type UidGid

type UidGid struct {
	Uid int
	Gid int
}

func (*UidGid) String

func (u *UidGid) String() string

type ValidationError

type ValidationError string

func (ValidationError) Error

func (v ValidationError) Error() string

type Volume

type Volume struct {
	Volume VolumeConfig `json:"volume"`
	Status VolumeState  `json:"status"`
}

type VolumeConfig

type VolumeConfig struct {
	Number              int    `json:"number"`
	SizeKiB             uint64 `json:"size_kib"`
	FileSystem          string `json:"file_system,omitempty"`
	FileSystemRootOwner UidGid `json:"file_system_root_owner,omitempty"`
}

func ClusterPrivateVolume

func ClusterPrivateVolume() VolumeConfig

type VolumeState

type VolumeState struct {
	Number int           `json:"number"`
	State  ResourceState `json:"state"`
}