controller

Documentation

Overview

Package aggregator contains an aggregator service client

Index

• type Client
  • func New(options Options) Client
  • func (ac Client) GetRunStatus(ctx context.Context) (*controller.RunStatus, error)
  • func (ac Client) GetRunningJobs(ctx context.Context) ([]string, error)
• type Options
• type Query

Types

type Client

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

Client represents the client to the aggregator service.

func New

func New(options Options) Client

New creates a new client with the specified address and apiKey.

func (Client) GetRunStatus

func (ac Client) GetRunStatus(ctx context.Context) (*controller.RunStatus, error)

func (Client) GetRunningJobs

func (ac Client) GetRunningJobs(ctx context.Context) ([]string, error)

type Options

type Options struct {
	Host   string
	Port   int
	ApiKey string
}

type Query

type Query interface {
	GetRunningJobs(ctx context.Context) ([]string, error)
	GetRunStatus(ctx context.Context) (*controller.RunStatus, error)
}