Versions in this module Expand all Collapse all v0 v0.1.0 Jan 16, 2025 Changes in this version + type Client interface + GetApplication func(ctx context.Context, partitionName, queueName, appID string) (*dao.ApplicationDAOInfo, error) + GetApplications func(ctx context.Context, partitionName, queueName string) ([]*dao.ApplicationDAOInfo, error) + GetAppsHistory func(ctx context.Context) ([]*dao.ApplicationHistoryDAOInfo, error) + GetContainersHistory func(ctx context.Context) ([]*dao.ContainerHistoryDAOInfo, error) + GetEventStream func(ctx context.Context) (*http.Response, error) + GetFullStateDump func(ctx context.Context) (*webservice.AggregatedStateInfo, error) + GetPartitionNodes func(ctx context.Context, partitionName string) ([]*dao.NodeDAOInfo, error) + GetPartitionQueue func(ctx context.Context, partitionName, queueName string) (*dao.PartitionQueueDAOInfo, error) + GetPartitionQueues func(ctx context.Context, partitionName string) (*dao.PartitionQueueDAOInfo, error) + GetPartitions func(ctx context.Context) ([]*dao.PartitionInfo, error) + Healthcheck func(ctx context.Context) (*dao.SchedulerHealthDAOInfo, error) + type EventHandler func(context.Context, *si.EventRecord) error + type MockClient struct + func NewMockClient(ctrl *gomock.Controller) *MockClient + func (m *MockClient) EXPECT() *MockClientMockRecorder + func (m *MockClient) GetApplication(arg0 context.Context, arg1, arg2, arg3 string) (*dao.ApplicationDAOInfo, error) + func (m *MockClient) GetApplications(arg0 context.Context, arg1, arg2 string) ([]*dao.ApplicationDAOInfo, error) + func (m *MockClient) GetAppsHistory(arg0 context.Context) ([]*dao.ApplicationHistoryDAOInfo, error) + func (m *MockClient) GetContainersHistory(arg0 context.Context) ([]*dao.ContainerHistoryDAOInfo, error) + func (m *MockClient) GetEventStream(arg0 context.Context) (*http.Response, error) + func (m *MockClient) GetFullStateDump(arg0 context.Context) (*webservice.AggregatedStateInfo, error) + func (m *MockClient) GetPartitionNodes(arg0 context.Context, arg1 string) ([]*dao.NodeDAOInfo, error) + func (m *MockClient) GetPartitionQueue(arg0 context.Context, arg1, arg2 string) (*dao.PartitionQueueDAOInfo, error) + func (m *MockClient) GetPartitionQueues(arg0 context.Context, arg1 string) (*dao.PartitionQueueDAOInfo, error) + func (m *MockClient) GetPartitions(arg0 context.Context) ([]*dao.PartitionInfo, error) + func (m *MockClient) Healthcheck(arg0 context.Context) (*dao.SchedulerHealthDAOInfo, error) + type MockClientMockRecorder struct + func (mr *MockClientMockRecorder) GetApplication(arg0, arg1, arg2, arg3 any) *gomock.Call + func (mr *MockClientMockRecorder) GetApplications(arg0, arg1, arg2 any) *gomock.Call + func (mr *MockClientMockRecorder) GetAppsHistory(arg0 any) *gomock.Call + func (mr *MockClientMockRecorder) GetContainersHistory(arg0 any) *gomock.Call + func (mr *MockClientMockRecorder) GetEventStream(arg0 any) *gomock.Call + func (mr *MockClientMockRecorder) GetFullStateDump(arg0 any) *gomock.Call + func (mr *MockClientMockRecorder) GetPartitionNodes(arg0, arg1 any) *gomock.Call + func (mr *MockClientMockRecorder) GetPartitionQueue(arg0, arg1, arg2 any) *gomock.Call + func (mr *MockClientMockRecorder) GetPartitionQueues(arg0, arg1 any) *gomock.Call + func (mr *MockClientMockRecorder) GetPartitions(arg0 any) *gomock.Call + func (mr *MockClientMockRecorder) Healthcheck(arg0 any) *gomock.Call + type Option func(*Service) + type RESTClient struct + func NewRESTClient(cfg *config.YunikornConfig) *RESTClient + func (c *RESTClient) GetApplication(ctx context.Context, partitionName, queueName, appID string) (*dao.ApplicationDAOInfo, error) + func (c *RESTClient) GetApplications(ctx context.Context, partitionName, queueName string) ([]*dao.ApplicationDAOInfo, error) + func (c *RESTClient) GetAppsHistory(ctx context.Context) ([]*dao.ApplicationHistoryDAOInfo, error) + func (c *RESTClient) GetContainersHistory(ctx context.Context) ([]*dao.ContainerHistoryDAOInfo, error) + func (c *RESTClient) GetEventStream(ctx context.Context) (*http.Response, error) + func (c *RESTClient) GetFullStateDump(ctx context.Context) (*webservice.AggregatedStateInfo, error) + func (c *RESTClient) GetPartitionNodes(ctx context.Context, partitionName string) ([]*dao.NodeDAOInfo, error) + func (c *RESTClient) GetPartitionQueue(ctx context.Context, partitionName, queueName string) (*dao.PartitionQueueDAOInfo, error) + func (c *RESTClient) GetPartitionQueues(ctx context.Context, partitionName string) (*dao.PartitionQueueDAOInfo, error) + func (c *RESTClient) GetPartitions(ctx context.Context) ([]*dao.PartitionInfo, error) + func (c *RESTClient) Healthcheck(ctx context.Context) (*dao.SchedulerHealthDAOInfo, error) + type Service struct + func NewService(repository repository.Repository, eventRepository repository.EventRepository, ...) *Service + func (s *Service) ProcessEvents(ctx context.Context) error + func (s *Service) Run(ctx context.Context) error
Go to main page