Documentation
¶
Index ¶
- type CRPCService
- func (crs *CRPCService) GetInfo(filters map[string]any, reply *map[string]any) error
- func (crs *CRPCService) Heartbeat(args *agscheduler.Node, reply *agscheduler.Node) error
- func (crs *CRPCService) RaftHeartbeat(args agscheduler.HeartbeatArgs, reply *agscheduler.HeartbeatReply) error
- func (crs *CRPCService) RaftRequestVote(args agscheduler.VoteArgs, reply *agscheduler.VoteReply) error
- func (crs *CRPCService) Register(args *agscheduler.Node, reply *agscheduler.Node) error
- func (crs *CRPCService) RunJob(j agscheduler.Job, reply *any) error
- type ClusterProxy
- type ClusterService
- type GRPCService
- type HTTPService
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CRPCService ¶
type CRPCService struct {
// contains filtered or unexported fields
}
func (*CRPCService) Heartbeat ¶
func (crs *CRPCService) Heartbeat(args *agscheduler.Node, reply *agscheduler.Node) error
func (*CRPCService) RaftHeartbeat ¶
func (crs *CRPCService) RaftHeartbeat(args agscheduler.HeartbeatArgs, reply *agscheduler.HeartbeatReply) error
func (*CRPCService) RaftRequestVote ¶
func (crs *CRPCService) RaftRequestVote(args agscheduler.VoteArgs, reply *agscheduler.VoteReply) error
func (*CRPCService) Register ¶
func (crs *CRPCService) Register(args *agscheduler.Node, reply *agscheduler.Node) error
func (*CRPCService) RunJob ¶
func (crs *CRPCService) RunJob(j agscheduler.Job, reply *any) error
type ClusterProxy ¶
type ClusterProxy struct {
Scheduler *agscheduler.Scheduler
}
func (*ClusterProxy) GRPCProxyInterceptor ¶
func (c *ClusterProxy) GRPCProxyInterceptor( ctx context.Context, req any, info *grpc.UnaryServerInfo, handler grpc.UnaryHandler, ) (resp any, err error)
func (*ClusterProxy) GinProxy ¶
func (c *ClusterProxy) GinProxy() gin.HandlerFunc
type ClusterService ¶
type ClusterService struct {
Cn *agscheduler.ClusterNode
// contains filtered or unexported fields
}
func (*ClusterService) Start ¶
func (s *ClusterService) Start() error
func (*ClusterService) Stop ¶
func (s *ClusterService) Stop() error
type GRPCService ¶
type GRPCService struct {
Scheduler *agscheduler.Scheduler
// Default: `127.0.0.1:36360`
Address string
// contains filtered or unexported fields
}
func (*GRPCService) Start ¶
func (s *GRPCService) Start() error
func (*GRPCService) Stop ¶
func (s *GRPCService) Stop() error
type HTTPService ¶
type HTTPService struct {
Scheduler *agscheduler.Scheduler
// Default: `127.0.0.1:36370`
Address string
// contains filtered or unexported fields
}
func (*HTTPService) Start ¶
func (s *HTTPService) Start() error
func (*HTTPService) Stop ¶
func (s *HTTPService) Stop() error
Source Files
¶
Directories
Click to show internal directories.
Click to hide internal directories.