Documentation
¶
Index ¶
- type JobServiceServer
- func (s *JobServiceServer) GetJobStatus(ctx context.Context, opts *js.JobServiceRequest) (*js.JobServiceResponse, error)
- func (s *JobServiceServer) GetNewSubscriptionChannel() <-chan *repository.SubscribedTuple
- func (s *JobServiceServer) Health(ctx context.Context, _ *types.Empty) (*js.HealthCheckResponse, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type JobServiceServer ¶
type JobServiceServer struct {
// contains filtered or unexported fields
}
func NewJobService ¶
func NewJobService(config *configuration.JobServiceConfiguration, sqlService repository.SQLJobService) *JobServiceServer
func (*JobServiceServer) GetJobStatus ¶
func (s *JobServiceServer) GetJobStatus(ctx context.Context, opts *js.JobServiceRequest) (*js.JobServiceResponse, error)
func (*JobServiceServer) GetNewSubscriptionChannel ¶ added in v0.3.72
func (s *JobServiceServer) GetNewSubscriptionChannel() <-chan *repository.SubscribedTuple
func (*JobServiceServer) Health ¶
func (s *JobServiceServer) Health(ctx context.Context, _ *types.Empty) (*js.HealthCheckResponse, error)
Source Files
Click to show internal directories.
Click to hide internal directories.