Documentation ¶ Index ¶ type Core func New(opts ...Option) *Core func (core *Core) Run(ctx context.Context) error func (core *Core) Stop() (err error) type Option func WithRegistry(r registry.Registry) Option func WithServers(srvs ...Server) Option type Server Constants ¶ This section is empty. Variables ¶ This section is empty. Functions ¶ This section is empty. Types ¶ type Core ¶ type Core struct { // contains filtered or unexported fields } func New ¶ func New(opts ...Option) *Core func (*Core) Run ¶ func (core *Core) Run(ctx context.Context) error func (*Core) Stop ¶ func (core *Core) Stop() (err error) type Option ¶ type Option func(core *Core) func WithRegistry ¶ func WithRegistry(r registry.Registry) Option func WithServers ¶ func WithServers(srvs ...Server) Option type Server ¶ type Server interface { Run(ctx context.Context) error Stop(ctx context.Context) error } Source Files ¶ View all Source files core.go server.go Directories ¶ Show internal Expand all Path Synopsis balancer consts coordinator executor dao gorm gorm/query mongodb endponit entity notify dingtalk lark telegram Package telegram is the telegram notification package. Package telegram is the telegram notification package. registry consulx etcdx resolver direct servers grpcsrv httpsrv runner transport common grpc http Click to show internal directories. Click to hide internal directories.