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

func NewErrParentInputsMismatch

func NewErrParentInputsMismatch(parent string) error

func NewErrPipelineNotFound

func NewErrPipelineNotFound(pipeline string) error

func RepoNameToEnvString

func RepoNameToEnvString(repoName string) string

Types

type APIServer

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

func NewAPIServer

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

type ErrEmptyInput

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

func NewErrEmptyInput

func NewErrEmptyInput(commitID string) *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)