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 ¶ added in v0.2.0
type CRPCService struct {
// contains filtered or unexported fields
}
func (*CRPCService) Heartbeat ¶ added in v0.4.0
func (crs *CRPCService) Heartbeat(args *agscheduler.Node, reply *agscheduler.Node) error
func (*CRPCService) RaftHeartbeat ¶ added in v0.3.0
func (crs *CRPCService) RaftHeartbeat(args agscheduler.HeartbeatArgs, reply *agscheduler.HeartbeatReply) error
func (*CRPCService) RaftRequestVote ¶ added in v0.3.0
func (crs *CRPCService) RaftRequestVote(args agscheduler.VoteArgs, reply *agscheduler.VoteReply) error
func (*CRPCService) Register ¶ added in v0.2.0
func (crs *CRPCService) Register(args *agscheduler.Node, reply *agscheduler.Node) error
func (*CRPCService) RunJob ¶ added in v0.3.0
func (crs *CRPCService) RunJob(j agscheduler.Job, reply *any) error
type ClusterProxy ¶ added in v0.3.0
type ClusterProxy struct {
Scheduler *agscheduler.Scheduler
}
func (*ClusterProxy) GRPCProxyInterceptor ¶ added in v0.3.0
func (c *ClusterProxy) GRPCProxyInterceptor( ctx context.Context, req any, info *grpc.UnaryServerInfo, handler grpc.UnaryHandler, ) (resp any, err error)
func (*ClusterProxy) GinProxy ¶ added in v0.3.0
func (c *ClusterProxy) GinProxy() gin.HandlerFunc
type ClusterService ¶ added in v0.2.2
type ClusterService struct { Cn *agscheduler.ClusterNode // contains filtered or unexported fields }
func (*ClusterService) Start ¶ added in v0.2.2
func (s *ClusterService) Start() error
func (*ClusterService) Stop ¶ added in v0.3.0
func (s *ClusterService) Stop() error
type GRPCService ¶ added in v0.4.0
type GRPCService struct { Scheduler *agscheduler.Scheduler // Default: `127.0.0.1:36360` Address string // contains filtered or unexported fields }
func (*GRPCService) Start ¶ added in v0.4.0
func (s *GRPCService) Start() error
func (*GRPCService) Stop ¶ added in v0.4.0
func (s *GRPCService) Stop() error
type HTTPService ¶ added in v0.1.0
type HTTPService struct { Scheduler *agscheduler.Scheduler // Default: `127.0.0.1:36370` Address string // contains filtered or unexported fields }
func (*HTTPService) Start ¶ added in v0.1.0
func (s *HTTPService) Start() error
func (*HTTPService) Stop ¶ added in v0.1.0
func (s *HTTPService) Stop() error
Source Files ¶
Click to show internal directories.
Click to hide internal directories.