reports

Documentation

Index

• type CtxPoolPair
• type LeaderProxyingSchedulingReportsServer
  • func NewLeaderProxyingSchedulingReportsServer(schedulingReportsRepository schedulerobjects.SchedulerReportingServer, ...) *LeaderProxyingSchedulingReportsServer
  • func (s *LeaderProxyingSchedulingReportsServer) GetJobReport(ctx context.Context, request *schedulerobjects.JobReportRequest) (*schedulerobjects.JobReport, error)
  • func (s *LeaderProxyingSchedulingReportsServer) GetQueueReport(ctx context.Context, request *schedulerobjects.QueueReportRequest) (*schedulerobjects.QueueReport, error)
  • func (s *LeaderProxyingSchedulingReportsServer) GetSchedulingReport(ctx context.Context, request *schedulerobjects.SchedulingReportRequest) (*schedulerobjects.SchedulingReport, error)
• type ProxyingSchedulingReportsServer
  • func NewProxyingSchedulingReportsServer(client schedulerobjects.SchedulerReportingClient) *ProxyingSchedulingReportsServer
  • func (s *ProxyingSchedulingReportsServer) GetJobReport(ctx context.Context, request *schedulerobjects.JobReportRequest) (*schedulerobjects.JobReport, error)
  • func (s *ProxyingSchedulingReportsServer) GetQueueReport(ctx context.Context, request *schedulerobjects.QueueReportRequest) (*schedulerobjects.QueueReport, error)
  • func (s *ProxyingSchedulingReportsServer) GetSchedulingReport(ctx context.Context, request *schedulerobjects.SchedulingReportRequest) (*schedulerobjects.SchedulingReport, error)
• type SchedulingContextRepository
  • func NewSchedulingContextRepository() *SchedulingContextRepository
  • func (r *SchedulingContextRepository) JobSchedulingContext(jobId string) []CtxPoolPair[*schedulercontext.JobSchedulingContext]
  • func (r *SchedulingContextRepository) QueueSchedulingContext(queue string) []CtxPoolPair[*schedulercontext.QueueSchedulingContext]
  • func (r *SchedulingContextRepository) RoundSchedulingContext() []CtxPoolPair[*schedulercontext.SchedulingContext]
  • func (r *SchedulingContextRepository) StoreSchedulingContext(sctx *schedulercontext.SchedulingContext)
• type Server
  • func NewServer(repository *SchedulingContextRepository) *Server
  • func (s *Server) GetJobReport(ctx context.Context, request *schedulerobjects.JobReportRequest) (*schedulerobjects.JobReport, error)
  • func (s *Server) GetQueueReport(ctx context.Context, request *schedulerobjects.QueueReportRequest) (*schedulerobjects.QueueReport, error)
  • func (s *Server) GetSchedulingReport(_ context.Context, request *schedulerobjects.SchedulingReportRequest) (*schedulerobjects.SchedulingReport, error)

Types

type CtxPoolPair

type CtxPoolPair[T any] struct {
	// contains filtered or unexported fields
}

type LeaderProxyingSchedulingReportsServer

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

func NewLeaderProxyingSchedulingReportsServer

func NewLeaderProxyingSchedulingReportsServer(
	schedulingReportsRepository schedulerobjects.SchedulerReportingServer,
	leaderClientProvider leader.LeaderClientConnectionProvider,
) *LeaderProxyingSchedulingReportsServer

func (*LeaderProxyingSchedulingReportsServer) GetJobReport

func (s *LeaderProxyingSchedulingReportsServer) GetJobReport(ctx context.Context, request *schedulerobjects.JobReportRequest) (*schedulerobjects.JobReport, error)

func (*LeaderProxyingSchedulingReportsServer) GetQueueReport

func (s *LeaderProxyingSchedulingReportsServer) GetQueueReport(ctx context.Context, request *schedulerobjects.QueueReportRequest) (*schedulerobjects.QueueReport, error)

func (*LeaderProxyingSchedulingReportsServer) GetSchedulingReport

func (s *LeaderProxyingSchedulingReportsServer) GetSchedulingReport(ctx context.Context, request *schedulerobjects.SchedulingReportRequest) (*schedulerobjects.SchedulingReport, error)

type ProxyingSchedulingReportsServer

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

func NewProxyingSchedulingReportsServer

func NewProxyingSchedulingReportsServer(client schedulerobjects.SchedulerReportingClient) *ProxyingSchedulingReportsServer

func (*ProxyingSchedulingReportsServer) GetJobReport

func (s *ProxyingSchedulingReportsServer) GetJobReport(ctx context.Context, request *schedulerobjects.JobReportRequest) (*schedulerobjects.JobReport, error)

func (*ProxyingSchedulingReportsServer) GetQueueReport

func (s *ProxyingSchedulingReportsServer) GetQueueReport(ctx context.Context, request *schedulerobjects.QueueReportRequest) (*schedulerobjects.QueueReport, error)

func (*ProxyingSchedulingReportsServer) GetSchedulingReport

func (s *ProxyingSchedulingReportsServer) GetSchedulingReport(ctx context.Context, request *schedulerobjects.SchedulingReportRequest) (*schedulerobjects.SchedulingReport, error)

type SchedulingContextRepository

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

func NewSchedulingContextRepository

func NewSchedulingContextRepository() *SchedulingContextRepository

func (*SchedulingContextRepository) JobSchedulingContext

func (r *SchedulingContextRepository) JobSchedulingContext(jobId string) []CtxPoolPair[*schedulercontext.JobSchedulingContext]

func (*SchedulingContextRepository) QueueSchedulingContext

func (r *SchedulingContextRepository) QueueSchedulingContext(queue string) []CtxPoolPair[*schedulercontext.QueueSchedulingContext]

func (*SchedulingContextRepository) RoundSchedulingContext

func (r *SchedulingContextRepository) RoundSchedulingContext() []CtxPoolPair[*schedulercontext.SchedulingContext]

func (*SchedulingContextRepository) StoreSchedulingContext

func (r *SchedulingContextRepository) StoreSchedulingContext(sctx *schedulercontext.SchedulingContext)

type Server

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

func NewServer

func NewServer(repository *SchedulingContextRepository) *Server

func (*Server) GetJobReport

func (s *Server) GetJobReport(ctx context.Context, request *schedulerobjects.JobReportRequest) (*schedulerobjects.JobReport, error)

func (*Server) GetQueueReport

func (s *Server) GetQueueReport(ctx context.Context, request *schedulerobjects.QueueReportRequest) (*schedulerobjects.QueueReport, error)

func (*Server) GetSchedulingReport

func (s *Server) GetSchedulingReport(_ context.Context, request *schedulerobjects.SchedulingReportRequest) (*schedulerobjects.SchedulingReport, error)