manager

Documentation

Index

• Constants
• func Dedup[I Identifyable](items []I) []I
• type Identifyable
• type Manager
  • func NewManager(ctx context.Context, reg registry.Registry, srcUrl string, namespace string, ...) Manager

Constants

const (
	CommandStart   = "start"
	CommandStop    = "stop"
	CommandRestart = "restart"
)

Functions

func Dedup

func Dedup[I Identifyable](items []I) []I

Types

type Identifyable

type Identifyable interface {
	ID() string
}

type Manager

type Manager interface {
	Init(ctx context.Context) error
	ServeAll(...server.ServeOption)
	StopAll()
	SetServeOptions(...server.ServeOption)
	WatchServicesConfigs()
	WatchBroker(ctx context.Context, br broker.Broker) error
}

func NewManager

func NewManager(ctx context.Context, reg registry.Registry, srcUrl string, namespace string, logger log.ZapLogger) Manager