concurrent

Documentation

Overview

Package concurrent contains the logic to manage same gateway replicas. They are managed using an active/passive approach. The gateway container try to acquire the active role using the controller manager lease. Then, the active gateway is labeled with the ActiveGatewayKey and ActiveGatewayValue, and the passive gateways are unlabeled. The gateway service target the active gateway using the ActiveGatewayKey and ActiveGatewayValue labels. In order to cohordinate the sidecar containers, the gateway uses a unix socket to manage the IPC, and to start the sidecars when it becomes leader.

Index

• Constants
• func AddActiveGatewayLabel(ctx context.Context, cl client.Client, key client.ObjectKey) error
• func ListAllGatewaysReplicas(ctx context.Context, cl client.Client, namespace, gatewayName string) ([]corev1.Pod, error)
• func RemoveActiveGatewayLabel(ctx context.Context, cl client.Client, key client.ObjectKey) error
• type RunnableGateway
  • func NewRunnableGatewayStartup(cl client.Client, podName, gatewayName, namespace string, ...) (*RunnableGateway, error)
  • func (rg *RunnableGateway) Close()
  • func (rg *RunnableGateway) Start(ctx context.Context) error
• type RunnableGuest
  • func NewRunnableGuest(guestID string) (*RunnableGuest, error)
  • func (rg *RunnableGuest) Close()
  • func (rg *RunnableGuest) Start(_ context.Context) error

Constants

const (
	// ActiveGatewayKey is the key used to label the active pod gateway.
	ActiveGatewayKey = "networking.liqo.io/active"
	// ActiveGatewayValue is the value used to label the active pod gateway.
	ActiveGatewayValue = "true"
)

Functions

func AddActiveGatewayLabel

func AddActiveGatewayLabel(ctx context.Context, cl client.Client, key client.ObjectKey) error

AddActiveGatewayLabel adds the active gateway label to the pod.

func ListAllGatewaysReplicas

func ListAllGatewaysReplicas(ctx context.Context, cl client.Client, namespace, gatewayName string) ([]corev1.Pod, error)

ListAllGatewaysReplicas returns the list of all the gateways replicas of the same gateway.

func RemoveActiveGatewayLabel

func RemoveActiveGatewayLabel(ctx context.Context, cl client.Client, key client.ObjectKey) error

RemoveActiveGatewayLabel removes the active gateway label from the pod.

Types

type RunnableGateway

type RunnableGateway struct {
	Client client.Client

	PodName     string
	GatewayName string
	Namespace   string

	Socket           net.Listener
	GuestConnections ipc.GuestConnections
}

RunnableGateway is a RunnableGateway that manages concurrency.

func NewRunnableGatewayStartup

func NewRunnableGatewayStartup(cl client.Client, podName, gatewayName, namespace string, containerNames []string) (*RunnableGateway, error)

NewRunnableGatewayStartup creates a new Runnable.

func (*RunnableGateway) Close

func (rg *RunnableGateway) Close()

Close closes the Runnable.

func (*RunnableGateway) Start

func (rg *RunnableGateway) Start(ctx context.Context) error

Start starts the ConcurrentRunnable.

type RunnableGuest

type RunnableGuest struct {
	GuestID    string
	Connection net.Conn
}

RunnableGuest is a RunnableGuest that manages concurrency.

func NewRunnableGuest

func NewRunnableGuest(guestID string) (*RunnableGuest, error)

NewRunnableGuest creates a new Runnable.

func (*RunnableGuest) Close

func (rg *RunnableGuest) Close()

Close closes the Runnable.

func (*RunnableGuest) Start

func (rg *RunnableGuest) Start(_ context.Context) error

Start starts the ConcurrentRunnable.