cluster

Documentation

Index

• type ChangeEventProvider
• type Dynamic
  • func (d *Dynamic) Mode() servermode.Mode
  • func (d *Dynamic) Run(ctx context.Context) error

Types

type ChangeEventProvider

type ChangeEventProvider interface {
	ServerMode(ctx context.Context) <-chan servermode.ChangeEvent
	WorkspaceIDs(ctx context.Context) <-chan workspace.ChangeEvent
}

type Dynamic

type Dynamic struct {
	Provider ChangeEventProvider

	GatewayComponent bool

	GatewayDB     lifecycle
	RouterDB      lifecycle
	BatchRouterDB lifecycle
	ErrorDB       lifecycle
	EventSchemaDB lifecycle
	ArchivalDB    lifecycle

	Processor lifecycle
	Router    lifecycle

	SchemaForwarder lifecycle
	Archiver        lifecycle

	BackendConfig configLifecycle
	// contains filtered or unexported fields
}

func (*Dynamic) Mode

func (d *Dynamic) Mode() servermode.Mode

func (*Dynamic) Run

func (d *Dynamic) Run(ctx context.Context) error