services

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
  • func (c *ClusterProxy) GRPCProxyInterceptor(ctx context.Context, req any, info *grpc.UnaryServerInfo, ...) (resp any, err error)
  • func (c *ClusterProxy) GinProxy() gin.HandlerFunc
• type ClusterService
  • func (s *ClusterService) Start() error
  • func (s *ClusterService) Stop() error
• type GRPCService
  • func (s *GRPCService) Start() error
  • func (s *GRPCService) Stop() error
• type HTTPService
  • func (s *HTTPService) Start() error
  • func (s *HTTPService) Stop() error

Types

type CRPCService

type CRPCService struct {
	// contains filtered or unexported fields
}

func (*CRPCService) GetInfo

func (crs *CRPCService) GetInfo(filters map[string]any, reply *map[string]any) error

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