kvstoremesh

Documentation

Index

• Variables
• func RegisterSyncWaiter(p SyncWaiterParams)
• type Config
  • func (def Config) Flags(flags *pflag.FlagSet)
• type KVStoreMesh
  • func (km *KVStoreMesh) Start(ctx cell.HookContext) error
  • func (km *KVStoreMesh) Stop(cell.HookContext) error
• type SyncWaiterParams

Variables

var Cell = cell.Module(
	"kvstoremesh",
	"KVStoreMesh caches remote cluster information in a local kvstore",

	cell.Provide(newKVStoreMesh),

	cell.Config(common.Config{}),
	store.Cell,

	metrics.Metric(common.MetricsProvider("")),
)

var DefaultConfig = Config{
	PerClusterReadyTimeout: 15 * time.Second,
	GlobalReadyTimeout:     10 * time.Minute,
}

Functions

func RegisterSyncWaiter

func RegisterSyncWaiter(p SyncWaiterParams)

Types

type Config

type Config struct {
	PerClusterReadyTimeout time.Duration
	GlobalReadyTimeout     time.Duration
}

func (Config) Flags

func (def Config) Flags(flags *pflag.FlagSet)

type KVStoreMesh

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

KVStoreMesh is a cache of multiple remote clusters

func (*KVStoreMesh) Start

func (km *KVStoreMesh) Start(ctx cell.HookContext) error

func (*KVStoreMesh) Stop

func (km *KVStoreMesh) Stop(cell.HookContext) error

type SyncWaiterParams

type SyncWaiterParams struct {
	cell.In

	KVStoreMesh *KVStoreMesh
	SyncState   syncstate.SyncState
	Lifecycle   cell.Lifecycle
	JobGroup    job.Group
	Health      cell.Health
}