catapult

Documentation

Index

• type Catapult
  • func New(client kubernetes.Client, options CatapultOptions) (*Catapult, error)
  • func (c *Catapult) Refresh(ctx context.Context) error
  • func (c *Catapult) Start(ctx context.Context) error
• type CatapultOptions

Types

type Catapult

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

func New

func New(client kubernetes.Client, options CatapultOptions) (*Catapult, error)

func (*Catapult) Refresh

func (c *Catapult) Refresh(ctx context.Context) error

func (*Catapult) Start

func (c *Catapult) Start(ctx context.Context) error

type CatapultOptions

type CatapultOptions struct {
	Scope      string
	Namespaces []string

	Logger *slog.Logger

	AddFunc    func(address string, hosts []string, ports []int)
	DeleteFunc func(address string, hosts []string, ports []int)
}