endpoints

Documentation

Index

• type Endpoints
  • func New(options ...Option) *Endpoints
  • func (e *Endpoints) CollectLogs(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error)
  • func (e *Endpoints) CreateRunnerTask(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error)
  • func (e *Endpoints) FetchRunnerTask(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error)
  • func (e *Endpoints) GetRunnerTask(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error)
  • func (e *Endpoints) Info(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error)
  • func (e *Endpoints) Routes() []httpserver.Endpoint
  • func (e *Endpoints) UpdateRunnerTask(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error)
• type Option
  • func WithBundle(bundle *bundle.Bundle) Option
  • func WithRunnerTask(runnerTask *runnertask.RunnerTask) Option

Types

type Endpoints

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

func New

func New(options ...Option) *Endpoints

New return an new Endpoints .

func (*Endpoints) CollectLogs

func (e *Endpoints) CollectLogs(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error)

func (*Endpoints) CreateRunnerTask

func (e *Endpoints) CreateRunnerTask(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error)

func (*Endpoints) FetchRunnerTask

func (e *Endpoints) FetchRunnerTask(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error)

func (*Endpoints) GetRunnerTask

func (e *Endpoints) GetRunnerTask(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error)

func (*Endpoints) Info

func (e *Endpoints) Info(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error)

Info used for health check.

func (*Endpoints) Routes

func (e *Endpoints) Routes() []httpserver.Endpoint

Routes return all endpoints methods, i.e. routes.

func (*Endpoints) UpdateRunnerTask

func (e *Endpoints) UpdateRunnerTask(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error)

type Option

type Option func(*Endpoints)

func WithBundle

func WithBundle(bundle *bundle.Bundle) Option

WithBundle set bundle .

func WithRunnerTask

func WithRunnerTask(runnerTask *runnertask.RunnerTask) Option

WithRunnerTask set runnerTask .