Versions in this module Expand all Collapse all v1 v1.0.8 Jan 2, 2024 v1.0.7 Dec 18, 2023 v1.0.6 Dec 15, 2023 v1.0.5 Dec 13, 2023 v1.0.4 Dec 13, 2023 v1.0.3 Dec 12, 2023 Changes in this version + type GossipKVCacheComponent struct + ClusterName string + InMachineMode bool + OnJoinCluster func() + OnNodeJoin func(*GossipKVCacheNodeMeta) + OnNodeLeave func(*GossipKVCacheNodeMeta) + Port int + func (c *GossipKVCacheComponent) Add(key, val string) error + func (c *GossipKVCacheComponent) AddKeys(keys []string, sameValue string) error + func (c *GossipKVCacheComponent) Delete(key string) error + func (c *GossipKVCacheComponent) FindMemberIPs(cluster, service string) (string, string, error) + func (c *GossipKVCacheComponent) FindNodeMetasByPrefix(cluster, servicePrefix string) []*GossipKVCacheNodeMeta + func (c *GossipKVCacheComponent) Get(key string) (string, bool) + func (c *GossipKVCacheComponent) GetAll() (map[string]string, error) + func (c *GossipKVCacheComponent) GetBroadcasts(overhead, limit int) [][]byte + func (c *GossipKVCacheComponent) GetMembers() []*memberlist.Node + func (c *GossipKVCacheComponent) HaveSensorID(sensorid string) error + func (c *GossipKVCacheComponent) HaveSensorIDs(sensorids []string) error + func (c *GossipKVCacheComponent) Init(server *micro.Server) error + func (c *GossipKVCacheComponent) LocalState(join bool) []byte + func (c *GossipKVCacheComponent) MergeRemoteState(buf []byte, join bool) + func (c *GossipKVCacheComponent) Name() string + func (c *GossipKVCacheComponent) NodeMeta(limit int) []byte + func (c *GossipKVCacheComponent) NotifyJoin(node *memberlist.Node) + func (c *GossipKVCacheComponent) NotifyLeave(node *memberlist.Node) + func (c *GossipKVCacheComponent) NotifyMsg(b []byte) + func (c *GossipKVCacheComponent) NotifyUpdate(node *memberlist.Node) + func (c *GossipKVCacheComponent) PostStart(ctx context.Context) error + func (c *GossipKVCacheComponent) PreStop(ctx context.Context) error + func (c *GossipKVCacheComponent) SensorIDHandlerWrapper(selfServiceName string, f echo.HandlerFunc, permitSelfHandlerFunc bool) echo.HandlerFunc + func (c *GossipKVCacheComponent) SensorIDsHandlerWrapper(selfServiceName string, fhttp echo.HandlerFunc, ...) echo.HandlerFunc + func (c *GossipKVCacheComponent) SetupHandler(root echoswagger.ApiRoot, base string) error + type GossipKVCacheNodeMeta struct + GlobalCluster string + GlobalIP string + InClusterIP string + Name string + Port int + PrivateCluster string + PrivateIP string + ServiceName string + WorkLoad int + type LoggerGroupComponent struct + func (c *LoggerGroupComponent) Init(server *micro.Server) error + func (c *LoggerGroupComponent) Name() string + func (c *LoggerGroupComponent) PostStop(ctx context.Context) error + func (c *LoggerGroupComponent) PreInit(ctx context.Context) error + func (c *LoggerGroupComponent) SetDynamicConfig(config *platformConf.NodeConfig) error + func (c *LoggerGroupComponent) SetupHandler(root echoswagger.ApiRoot, base string) error + type LoggingComponent struct + func (c *LoggingComponent) Init(server *micro.Server) error + func (c *LoggingComponent) Name() string + func (c *LoggingComponent) PostStop(ctx context.Context) error + func (c *LoggingComponent) PreInit(ctx context.Context) error + func (c *LoggingComponent) SetDynamicConfig(config *platformConf.NodeConfig) error + type MockComponent struct + func (_m *MockComponent) GetSubscribeServiceList() []string + func (_m *MockComponent) Init(server *micro.Server) error + func (_m *MockComponent) Name() string + func (_m *MockComponent) OnConfigChanged(_a0 *conf.NodeConfig) error + func (_m *MockComponent) OnServiceChanged(services []model.SubscribeService, err error) + func (_m *MockComponent) PostInit(ctx context.Context) error + func (_m *MockComponent) PostStart(ctx context.Context) error + func (_m *MockComponent) PostStop(ctx context.Context) error + func (_m *MockComponent) PreInit(ctx context.Context) error + func (_m *MockComponent) PreStart(ctx context.Context) error + func (_m *MockComponent) PreStop(ctx context.Context) error + func (_m *MockComponent) SetDynamicConfig(_a0 *conf.NodeConfig) error + func (_m *MockComponent) SetupHandler(root echoswagger.ApiRoot, base string) error + func (_m *MockComponent) Start(ctx context.Context) error + func (_m *MockComponent) Status() *micro.ComponentStatus + func (_m *MockComponent) Stop(ctx context.Context) error + type RaftClusterComponent struct + ClusterID uint64 + CreateFun statemachine.CreateStateMachineFunc + func (c *RaftClusterComponent) Init(server *micro.Server) error + func (c *RaftClusterComponent) Name() string + func (c *RaftClusterComponent) PostStart(ctx context.Context) error + func (c *RaftClusterComponent) PreInit(ctx context.Context) error + func (c *RaftClusterComponent) PreStop(ctx context.Context) error + func (c *RaftClusterComponent) SetupHandler(root echoswagger.ApiRoot, base string) error v1.0.2 Dec 12, 2023
Go to main page