Versions in this module Expand all Collapse all v0 v0.1.3 Aug 2, 2022 v0.1.2 Jul 29, 2022 Changes in this version + func InitFlowEngine(flowEngine *Engine, initContext plugin.InitContext) error + type CombineNotifyContext struct + func NewCombineNotifyContext(svcKey *model.ServiceKey, notifiers []*SingleNotifyContext) *CombineNotifyContext + func (c *CombineNotifyContext) Errs() map[ContextKey]model.SDKError + func (c *CombineNotifyContext) IsDone() bool + func (c *CombineNotifyContext) Wait(timeout time.Duration) (exceedTime bool) + type ContextKey struct + Operation string + ServiceKey *model.ServiceKey + func (c ContextKey) String() string + type Engine struct + func (e *Engine) AsyncGetQuota(request *model.QuotaRequestImpl) (*model.QuotaFutureImpl, error) + func (e *Engine) Destroy() error + func (e *Engine) FlowQuotaAssistant() *quota.FlowQuotaAssistant + func (e *Engine) GetContext() model.ValueContext + func (e *Engine) InitCalleeService(req *model.InitCalleeServiceRequest) error + func (e *Engine) LoadFlowRouteChain() error + func (e *Engine) PluginSupplier() plugin.Supplier + func (e *Engine) ScheduleTask(task *model.PeriodicTask) (chan<- *model.PriorityTask, model.TaskValues) + func (e *Engine) ServiceEventCallback(event *common.PluginEvent) error + func (e *Engine) Start() error + func (e *Engine) SyncDeregister(instance *model.InstanceDeRegisterRequest) error + func (e *Engine) SyncGetAllInstances(req *model.GetAllInstancesRequest) (*model.InstancesResponse, error) + func (e *Engine) SyncGetConfigFile(namespace, fileGroup, fileName string) (model.ConfigFile, error) + func (e *Engine) SyncGetInstances(req *model.GetInstancesRequest) (*model.InstancesResponse, error) + func (e *Engine) SyncGetMesh(eventType model.EventType, req *model.GetMeshRequest) (*model.MeshResponse, error) + func (e *Engine) SyncGetMeshConfig(eventType model.EventType, req *model.GetMeshConfigRequest) (*model.MeshConfigResponse, error) + func (e *Engine) SyncGetOneInstance(req *model.GetOneInstanceRequest) (*model.OneInstanceResponse, error) + func (e *Engine) SyncGetResources(req model.CacheValueQuery) error + func (e *Engine) SyncGetServiceRule(eventType model.EventType, req *model.GetServiceRuleRequest) (*model.ServiceRuleResponse, error) + func (e *Engine) SyncGetServices(eventType model.EventType, req *model.GetServicesRequest) (*model.ServicesResponse, error) + func (e *Engine) SyncHeartbeat(instance *model.InstanceHeartbeatRequest) error + func (e *Engine) SyncRegister(instance *model.InstanceRegisterRequest) (*model.InstanceRegisterResponse, error) + func (e *Engine) SyncReportStat(typ model.MetricType, stat model.InstanceGauge) error + func (e *Engine) SyncUpdateServiceCallResult(result *model.ServiceCallResult) error + func (e *Engine) WatchService(req *model.WatchServiceRequest) (*model.WatchServiceResponse, error) + type SingleNotifyContext struct + func NewSingleNotifyContext(name *ContextKey, notifier *common.Notifier) *SingleNotifyContext + func (s *SingleNotifyContext) Err() model.SDKError + func (s *SingleNotifyContext) Wait(timeout time.Duration) bool
Go to main page