worker

Documentation

Overview

Package worker provides the worker for mesh controller.

Index

• Variables
• type EgressServer
  • func NewEgressServer(superSpec *supervisor.Spec, super *supervisor.Supervisor, ...) *EgressServer
  • func (egs *EgressServer) Close()
  • func (egs *EgressServer) InitEgress(service *spec.Service) error
  • func (egs *EgressServer) Ready() bool
• type IngressServer
  • func NewIngressServer(superSpec *supervisor.Spec, super *supervisor.Supervisor, ...) *IngressServer
  • func (ings *IngressServer) Close()
  • func (ings *IngressServer) InitIngress(service *spec.Service, port uint32) error
  • func (ings *IngressServer) Ready() bool
• type ObservabilityManager
  • func NewObservabilityServer(serviceName string) *ObservabilityManager
• type Worker
  • func New(superSpec *supervisor.Spec) *Worker
  • func (worker *Worker) Close()
  • func (worker *Worker) Status() *supervisor.Status

Variables

var ErrIngressClosed = fmt.Errorf("ingress has been closed")

ErrIngressClosed is the error when operating in a closed Ingress server

Types

type EgressServer

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

EgressServer manages one/many ingress pipelines and one HTTPServer

func NewEgressServer

func NewEgressServer(superSpec *supervisor.Spec, super *supervisor.Supervisor,
	serviceName, instanceID string, service *service.Service,
) *EgressServer

NewEgressServer creates an initialized egress server

func (*EgressServer) Close

func (egs *EgressServer) Close()

Close closes the Egress HTTPServer and Pipelines

func (*EgressServer) InitEgress

func (egs *EgressServer) InitEgress(service *spec.Service) error

InitEgress initializes the Egress HTTPServer.

func (*EgressServer) Ready

func (egs *EgressServer) Ready() bool

Ready checks Egress HTTPServer has been created or not. Not need to check pipelines, cause they will be dynamically added.

type IngressServer

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

IngressServer manages one ingress pipeline and one HTTPServer

func NewIngressServer

func NewIngressServer(superSpec *supervisor.Spec, super *supervisor.Supervisor,
	serviceName, instaceID string, service *service.Service,
) *IngressServer

NewIngressServer creates an initialized ingress server

func (*IngressServer) Close

func (ings *IngressServer) Close()

Close closes the Ingress HTTPServer and Pipeline

func (*IngressServer) InitIngress

func (ings *IngressServer) InitIngress(service *spec.Service, port uint32) error

InitIngress creates local default pipeline and httpServer for ingress

func (*IngressServer) Ready

func (ings *IngressServer) Ready() bool

Ready checks ingress's pipeline and HTTPServer are created or not

type ObservabilityManager

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

ObservabilityManager is the manager for observability.

func NewObservabilityServer

func NewObservabilityServer(serviceName string) *ObservabilityManager

NewObservabilityServer creates an ObservabilityServer.

type Worker

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

Worker is a sidecar in service mesh.

func New

func New(superSpec *supervisor.Spec) *Worker

New creates a mesh worker.

func (*Worker) Close

func (worker *Worker) Close()

Close closes the worker

func (*Worker) Status

func (worker *Worker) Status() *supervisor.Status

Status returns the status of worker.