store

Documentation

Index

• Constants
• func AddService(s *http.Server, name string, init func(), exit func())
• func CloseService()
• func Dump() ([]byte, error)
• func GetMOSNConfig(typ string) interface{}
• func ListServiceListenersFile() ([]*os.File, error)
• func RegisterOnStateChanged(f OnStateChanged)
• func RemoveClusterConfig(clusterName string)
• func Reset()
• func SetClusterConfig(clusterName string, cluster v2.Cluster)
• func SetHosts(clusterName string, hostConfigs []v2.Host)
• func SetListenerConfig(listenerName string, listenerConfig v2.Listener)
• func SetMosnConfig(cfg *v2.MOSNConfig)
• func SetMosnState(s State)
• func SetRouter(routerName string, router v2.RouterConfiguration)
• func SetStateCode(s State)
• func StartService(inheritListeners []net.Listener) error
• func StopService()
• type ConfigAutoFeature
  • func (f *ConfigAutoFeature) InitFunc()
• type OnStateChanged
• type State
  • func GetMosnState() State

Constants

const (
	CfgTypeMOSN     = "MOSN"
	CfgTypeRouter   = "Router"
	CfgTypeCluster  = "Cluster"
	CfgTypeListener = "Listener"
)

const ConfigAutoWrite featuregate.Feature = "auto_config"

Functions

func AddService

func AddService(s *http.Server, name string, init func(), exit func())

func CloseService

func CloseService()

CloseService close the services directly

func Dump

func Dump() ([]byte, error)

Dump Dump all config

func GetMOSNConfig

func GetMOSNConfig(typ string) interface{}

func ListServiceListenersFile

func ListServiceListenersFile() ([]*os.File, error)

func RegisterOnStateChanged

func RegisterOnStateChanged(f OnStateChanged)

func RemoveClusterConfig

func RemoveClusterConfig(clusterName string)

func Reset

func Reset()

func SetClusterConfig

func SetClusterConfig(clusterName string, cluster v2.Cluster)

func SetHosts

func SetHosts(clusterName string, hostConfigs []v2.Host)

func SetListenerConfig

func SetListenerConfig(listenerName string, listenerConfig v2.Listener)

SetListenerConfig Set listener config when AddOrUpdateListener

func SetMosnConfig

func SetMosnConfig(cfg *v2.MOSNConfig)

func SetMosnState

func SetMosnState(s State)

func SetRouter

func SetRouter(routerName string, router v2.RouterConfiguration)

func SetStateCode

func SetStateCode(s State)

func StartService

func StartService(inheritListeners []net.Listener) error

func StopService

func StopService()

Types

type ConfigAutoFeature

type ConfigAutoFeature struct {
	featuregate.BaseFeatureSpec
	// contains filtered or unexported fields
}

ConfigAutoFeature controls xDS update config will overwrite config file or not, default is not

func (*ConfigAutoFeature) InitFunc

func (f *ConfigAutoFeature) InitFunc()

type OnStateChanged

type OnStateChanged func(s State)

type State

type State int

const (
	Init State = iota
	Running
	Active_Reconfiguring
	Passive_Reconfiguring
)

func GetMosnState

func GetMosnState() State