coordinator

Documentation

Index

• type Config
  • func NewConfig() Config
• type Coordinator
  • func New(config Config) (*Coordinator, error)
  • func (s *Coordinator) Close() error
• type MetadataProviderImpl
  • func (m *MetadataProviderImpl) Set(s string) error
  • func (m *MetadataProviderImpl) String() string
  • func (*MetadataProviderImpl) Type() string

Types

type Config

type Config struct {
	InternalServiceAddr              string
	InternalSecureServiceAddr        string
	PeerTLS                          *tls.Config `json:"-"`
	ServerTLS                        *tls.Config `json:"-"`
	MetricsServiceAddr               string
	MetadataProviderImpl             MetadataProviderImpl
	K8SMetadataNamespace             string
	K8SMetadataConfigMapName         string
	FileMetadataPath                 string
	ClusterConfigProvider            func() (model.ClusterConfig, error) `json:"-"`
	ClusterConfigChangeNotifications chan any                            `json:"-"`
}

func NewConfig

func NewConfig() Config

type Coordinator

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

func New

func New(config Config) (*Coordinator, error)

func (*Coordinator) Close

func (s *Coordinator) Close() error

type MetadataProviderImpl

type MetadataProviderImpl string

var (
	Memory    MetadataProviderImpl = "memory"
	Configmap MetadataProviderImpl = "configmap"
	File      MetadataProviderImpl = "file"
)

func (*MetadataProviderImpl) Set

func (m *MetadataProviderImpl) Set(s string) error

func (*MetadataProviderImpl) String

func (m *MetadataProviderImpl) String() string

func (*MetadataProviderImpl) Type

func (*MetadataProviderImpl) Type() string