mosn

Documentation

Index

• Constants
• func DefaultInitStage(c *v2.MOSNConfig)
• func DefaultPreStartStage(m *Mosn)
• func DefaultStartStage(m *Mosn)
• func InitDebugServe(c *v2.MOSNConfig)
• func InitializeMetrics(c *v2.MOSNConfig)
• func InitializePidFile(c *v2.MOSNConfig)
• func InitializePlugin(c *v2.MOSNConfig)
• func InitializeThirdPartCodec(c *v2.MOSNConfig)
• func InitializeTracing(c *v2.MOSNConfig)
• func InitializeWasm(c *v2.MOSNConfig)
• type Data
• type Mosn
  • func NewMosn(c *v2.MOSNConfig) *Mosn
  • func (m *Mosn) CleanUpgrade()
  • func (m *Mosn) Close()
  • func (m *Mosn) HandleExtendConfig()
  • func (m *Mosn) Start()
  • func (m *Mosn) StartXdsClient()
  • func (m *Mosn) TransferConnection()
  • func (m *Mosn) Wait()
• type StageManager
  • func NewStageManager(ctx *cli.Context, path string) *StageManager
  • func (stm *StageManager) AppendInitStage(f func(*v2.MOSNConfig)) *StageManager
  • func (stm *StageManager) AppendParamsParsedStage(f func(*cli.Context)) *StageManager
  • func (stm *StageManager) AppendPreStartStage(f func(*Mosn)) *StageManager
  • func (stm *StageManager) AppendStartStage(f func(*Mosn)) *StageManager
  • func (stm *StageManager) Run()
  • func (stm *StageManager) WaitFinish()
• type UpgradeData

Constants

const (
	DefaultLoaderFunctionName string = "LoadCodec"
)

Functions

func DefaultInitStage

func DefaultInitStage(c *v2.MOSNConfig)

Default Init Stage wrappers. if more initialize needs to extend. modify it in main function

func DefaultPreStartStage

func DefaultPreStartStage(m *Mosn)

Default Pre-start Stage wrappers

func DefaultStartStage

func DefaultStartStage(m *Mosn)

Default Start Stage wrappers

func InitDebugServe

func InitDebugServe(c *v2.MOSNConfig)

Init Stages Function

func InitializeMetrics

func InitializeMetrics(c *v2.MOSNConfig)

func InitializePidFile

func InitializePidFile(c *v2.MOSNConfig)

func InitializePlugin

func InitializePlugin(c *v2.MOSNConfig)

func InitializeThirdPartCodec

func InitializeThirdPartCodec(c *v2.MOSNConfig)

func InitializeTracing

func InitializeTracing(c *v2.MOSNConfig)

Init Stages Function

func InitializeWasm

func InitializeWasm(c *v2.MOSNConfig)

Types

type Data

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

Data contains objects used in stages

type Mosn

type Mosn struct {
	Upgrade        UpgradeData
	Clustermanager types.ClusterManager
	RouterManager  types.RouterManager
	Config         *v2.MOSNConfig
	// contains filtered or unexported fields
}

func NewMosn

func NewMosn(c *v2.MOSNConfig) *Mosn

func (*Mosn) CleanUpgrade

func (m *Mosn) CleanUpgrade()

func (*Mosn) Close

func (m *Mosn) Close()

func (*Mosn) HandleExtendConfig

func (m *Mosn) HandleExtendConfig()

func (*Mosn) Start

func (m *Mosn) Start()

func (*Mosn) StartXdsClient

func (m *Mosn) StartXdsClient()

func (*Mosn) TransferConnection

func (m *Mosn) TransferConnection()

func (*Mosn) Wait

func (m *Mosn) Wait()

type StageManager

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

StageManager is a stage manager that controls startup stages running. We divide the startup into four stages: 1. The parameters parsed stage. In this stage, parse different parameters from cli.Context, and finally call config load to create a MOSNConfig. 2. The initialize stage. In this stage, do some init actions based on config, and finally create a MOSN object. 3. The pre-startup stage. In this stage, creates some basic instance from MOSN object. 4. The startup stage. In this stage, do some startup actions such as connections transfer for smooth upgrade and so on. The difference between pre-startup stage and startup stage is that startup stage has already accomplished the resources that used to startup mosn.

func NewStageManager

func NewStageManager(ctx *cli.Context, path string) *StageManager

func (*StageManager) AppendInitStage

func (stm *StageManager) AppendInitStage(f func(*v2.MOSNConfig)) *StageManager

func (*StageManager) AppendParamsParsedStage

func (stm *StageManager) AppendParamsParsedStage(f func(*cli.Context)) *StageManager

func (*StageManager) AppendPreStartStage

func (stm *StageManager) AppendPreStartStage(f func(*Mosn)) *StageManager

func (*StageManager) AppendStartStage

func (stm *StageManager) AppendStartStage(f func(*Mosn)) *StageManager

func (*StageManager) Run

func (stm *StageManager) Run()

Run blocks until the mosn is closed

func (*StageManager) WaitFinish

func (stm *StageManager) WaitFinish()

WaitFinish waits mosn start finished. if Run is not called, return directly

type UpgradeData

type UpgradeData struct {
	InheritListeners  []net.Listener
	InheritPacketConn []net.PacketConn
	ListenSockConn    net.Conn
}

UpgradeData stores datas that are used to smooth upgrade