server

Documentation

Index

• func NewErrJobNotFound(job string) error
• func NewErrParentInputsMismatch(parent string) error
• func NewErrPipelineNotFound(pipeline string) error
• func RepoNameToEnvString(repoName string) string
• type APIServer
  • func NewAPIServer(hasher *ppsserver.Hasher, address string, kubeClient *kube.Client, ...) APIServer
• type ErrEmptyInput
  • func NewErrEmptyInput(commitID string) *ErrEmptyInput
• type JobInputs
  • func (inputs JobInputs) Len() int
  • func (inputs JobInputs) Less(i, j int) bool
  • func (inputs JobInputs) Swap(i, j int)

Functions

func NewErrJobNotFound

func NewErrJobNotFound(job string) error

NewErrJobNotFound creates a job-not-found error.

func NewErrParentInputsMismatch

func NewErrParentInputsMismatch(parent string) error

NewErrParentInputsMismatch creates an error for mismatched job parents.

func NewErrPipelineNotFound

func NewErrPipelineNotFound(pipeline string) error

NewErrPipelineNotFound creates a pipeline-not-found error.

func RepoNameToEnvString

func RepoNameToEnvString(repoName string) string

RepoNameToEnvString is a helper which uppercases a repo name for use in environment variable names.

Types

type APIServer

type APIServer interface {
	ppsclient.APIServer
	ppsserver.InternalJobAPIServer
	shard.Frontend
	shard.Server
}

APIServer represents an api server.

func NewAPIServer

func NewAPIServer(
	hasher *ppsserver.Hasher,
	address string,
	kubeClient *kube.Client,
	namespace string,
) APIServer

NewAPIServer creates an APIServer.

type ErrEmptyInput

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

ErrEmptyInput is an input returned for empty inputs.

func NewErrEmptyInput

func NewErrEmptyInput(commitID string) *ErrEmptyInput

NewErrEmptyInput creates a new ErrEmptyInput

type JobInputs

type JobInputs []*ppsclient.JobInput

JobInputs implements sort.Interface so job inputs can be sorted We sort job inputs based on repo names

func (JobInputs) Len

func (inputs JobInputs) Len() int

func (JobInputs) Less

func (inputs JobInputs) Less(i, j int) bool

func (JobInputs) Swap

func (inputs JobInputs) Swap(i, j int)