konnect

type ClientFactory ¶ added in v3.4.3

type ClientFactory interface {
	NewKonnectClient(ctx context.Context) (*adminapi.KonnectClient, error)
}

type ConfigSynchronizer ¶ added in v3.3.0

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

ConfigSynchronizer runs a loop to upload the translated Kong configuration to Konnect periodically.

func NewConfigSynchronizer(p ConfigSynchronizerParams) *ConfigSynchronizer

func (s *ConfigSynchronizer) KonnectClientInitialized() bool

func (s *ConfigSynchronizer) NeedLeaderElection() bool

func (s *ConfigSynchronizer) Start(ctx context.Context) error

func (s *ConfigSynchronizer) UpdateKongState(ks *kongstate.KongState, isFallbackConfig bool)

type ConfigSynchronizerParams ¶ added in v3.4.3

type ConfigSynchronizerParams struct {
	Logger                 logr.Logger
	KongConfig             sendconfig.Config
	ConfigUploadTicker     Ticker
	KonnectClientFactory   ClientFactory
	UpdateStrategyResolver sendconfig.UpdateStrategyResolver
	ConfigChangeDetector   sendconfig.ConfigurationChangeDetector
	ConfigStatusNotifier   clients.ConfigStatusNotifier
	MetricsRecorder        metrics.Recorder
}

type GatewayClientGetter ¶

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

GatewayClientGetter gets gateway instances from admin API clients.

func NewGatewayClientGetter(logger logr.Logger, clientsProvider clients.AdminAPIClientsProvider) *GatewayClientGetter

func (p *GatewayClientGetter) GetGatewayInstances(ctx context.Context) ([]GatewayInstance, error)

type GatewayClientsChangesNotifier ¶

type GatewayClientsChangesNotifier interface {
	SubscribeToGatewayClientsChanges() (<-chan struct{}, bool)
}

type GatewayInstance ¶

type GatewayInstance struct {
	Hostname string
	Version  string
	NodeID   string
}

GatewayInstance is a controlled kong gateway instance. its hostname and version will be used to update status of nodes corresponding to the instance in konnect.

type GatewayInstanceGetter ¶

type GatewayInstanceGetter interface {
	GetGatewayInstances(ctx context.Context) ([]GatewayInstance, error)
}

GatewayInstanceGetter is the interface to get currently running gateway instances in the kubernetes cluster.

type ManagerInstanceIDProvider ¶

type ManagerInstanceIDProvider interface {
	GetID() uuid.UUID
}

type NodeAgent ¶

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

NodeAgent gets the running status of KIC node and controlled kong gateway nodes, and update their statuses to konnect.

func NewNodeAgent(
	hostname string,
	version string,
	refreshPeriod time.Duration,
	logger logr.Logger,
	client NodeClient,
	configStatusSubscriber clients.ConfigStatusSubscriber,
	gatewayGetter GatewayInstanceGetter,
	gatewayClientsChangesNotifier GatewayClientsChangesNotifier,
	managerInstanceIDProvider ManagerInstanceIDProvider,
	opts ...NodeAgentOpt,
) *NodeAgent

func (a *NodeAgent) NeedLeaderElection() bool

func (a *NodeAgent) Start(ctx context.Context) error

type NodeAgentOpt ¶

type NodeAgentOpt func(*NodeAgent)

func WithRefreshTicker(ticker Ticker) NodeAgentOpt

type NodeClient ¶

type NodeClient interface {
	CreateNode(ctx context.Context, req *nodes.CreateNodeRequest) (*nodes.CreateNodeResponse, error)
	UpdateNode(ctx context.Context, nodeID string, req *nodes.UpdateNodeRequest) (*nodes.UpdateNodeResponse, error)
	DeleteNode(ctx context.Context, nodeID string) error
	ListAllNodes(ctx context.Context) ([]*nodes.NodeItem, error)
}

NodeClient is the interface to Konnect Control Plane Node API.

type TargetContent ¶ added in v3.4.3

type TargetContent struct {
	*file.Content

	// IsFallback indicates whether the configuration is a fallback configuration.
	IsFallback bool
}

TargetContent wraps the deck content to be uploaded to Konnect and indicates whether the configuration is a fallback configuration.

type TargetKongState ¶ added in v3.4.3

type TargetKongState struct {
	*kongstate.KongState

	// IsFallback indicates whether the configuration is a fallback configuration.
	IsFallback bool
}

TargetKongState wraps the Kong state to be uploaded to Konnect and indicates whether the configuration is a fallback configuration.

type Ticker ¶

type Ticker interface {
	Stop()
	Channel() <-chan time.Time
	Reset(time.Duration)
}