k8spool

Documentation

Index

• type Config
• type K8sPool
  • func New(conf Config) (*K8sPool, error)
  • func (e *K8sPool) Close()
• type Logger
• type StdLogger
  • func (c StdLogger) Debugf(format string, v ...any)
  • func (c StdLogger) Errorf(format string, v ...any)
• type UpdateFunc
• type WatchMechanism

Types

type Config

type Config struct {
	Logger     Logger
	Mechanism  WatchMechanism
	OnUpdate   UpdateFunc
	Namespace  string
	Selector   string
	PeerScheme string
	PeerPort   int
}

type K8sPool

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

func New

func New(conf Config) (*K8sPool, error)

func (*K8sPool) Close

func (e *K8sPool) Close()

type Logger

type Logger interface {
	Debugf(format string, v ...any)
	Errorf(format string, v ...any)
}

type StdLogger

type StdLogger struct {
	Debug bool
	Error bool
}

func (StdLogger) Debugf

func (c StdLogger) Debugf(format string, v ...any)

func (StdLogger) Errorf

func (c StdLogger) Errorf(format string, v ...any)

type UpdateFunc

type UpdateFunc func(peers []string)

type WatchMechanism

type WatchMechanism string

const (
	WatchEndpoints WatchMechanism = "endpoints"
	WatchPods      WatchMechanism = "pods"
)