server

Documentation

Index

• type Dataplane
  • func NewDataplane(dataplaneID string, controlplaneClient grpc.ClientConnInterface, ...) *Dataplane
  • func (d *Dataplane) AddCluster(c *cluster.Cluster)
  • func (d *Dataplane) AddListener(ln *listener.Listener)
  • func (d *Dataplane) AddSecret(secret *tlsv3.Secret) error
  • func (d *Dataplane) CreateListener(name, ip string, port uint32)
  • func (d *Dataplane) GetClusterHost(name string) (string, error)
  • func (d *Dataplane) GetClusterHostname(name string) (string, error)
  • func (d *Dataplane) GetClusterTarget(name string) (string, error)
  • func (d *Dataplane) GetClusters() map[string]*cluster.Cluster
  • func (d *Dataplane) GetListeners() map[string]*listener.Listener
  • func (d *Dataplane) IsReady() bool
  • func (d *Dataplane) RemoveCluster(name string)
  • func (d *Dataplane) RemoveListener(name string)
  • func (d *Dataplane) StartDataplaneServer(dataplaneServerAddress string) error

Types

type Dataplane

type Dataplane struct {
	ID string
	// contains filtered or unexported fields
}

Dataplane implements the server and api client which sends authorization to the control plane. Assumption: The caller implements lock mechanism which operating with clusters and listeners.

func NewDataplane

func NewDataplane(
	dataplaneID string,
	controlplaneClient grpc.ClientConnInterface,
	parsedCertData *utiltls.ParsedCertData,
) *Dataplane

NewDataplane returns a new dataplane HTTP server.

func (*Dataplane) AddCluster

func (d *Dataplane) AddCluster(c *cluster.Cluster)

AddCluster adds/updates a cluster to the map.

func (*Dataplane) AddListener

func (d *Dataplane) AddListener(ln *listener.Listener)

AddListener adds a listener to the map.

func (*Dataplane) AddSecret

func (d *Dataplane) AddSecret(secret *tlsv3.Secret) error

AddSecret adds a secret (dataplane cert or CA).

func (*Dataplane) CreateListener

func (d *Dataplane) CreateListener(name, ip string, port uint32)

CreateListener starts a listener to an imported service.

func (*Dataplane) GetClusterHost

func (d *Dataplane) GetClusterHost(name string) (string, error)

GetClusterHost returns the cluster hostname after trimming ":".

func (*Dataplane) GetClusterHostname

func (d *Dataplane) GetClusterHostname(name string) (string, error)

GetClusterHostname returns the cluster hostname.

func (*Dataplane) GetClusterTarget

func (d *Dataplane) GetClusterTarget(name string) (string, error)

GetClusterTarget returns the cluster address:port from the cluster map.

func (*Dataplane) GetClusters

func (d *Dataplane) GetClusters() map[string]*cluster.Cluster

GetClusters returns the clusters map.

func (*Dataplane) GetListeners

func (d *Dataplane) GetListeners() map[string]*listener.Listener

GetListeners returns the listeners map.

func (*Dataplane) IsReady

func (d *Dataplane) IsReady() bool

func (*Dataplane) RemoveCluster

func (d *Dataplane) RemoveCluster(name string)

RemoveCluster adds a cluster to the map.

func (*Dataplane) RemoveListener

func (d *Dataplane) RemoveListener(name string)

RemoveListener removes a listener.

func (*Dataplane) StartDataplaneServer

func (d *Dataplane) StartDataplaneServer(dataplaneServerAddress string) error

StartDataplaneServer starts the Dataplane server.