sous

package

Go to main page

Versions in this module

v1

v1.0.1

Apr 11, 2019

Changes in this version

+ const AddedArtifact

+ const ClusterNameLabel

+ const ComingDiff

+ const CreateDiff

+ const DeleteDiff

+ const DeveloperBuild

+ const FlavorLabel

+ const IsBuilder

+ const MaxRefsPerR11nQueue

+ const ModifyDiff

+ const NotService

+ const PathLabel

+ const PollTimeout

+ const R11nQueueCapDefault

+ const RepoLabel

+ const RevisionLabel

+ const SingularityDeployTimeout

+ const StableDiff

+ const VersionLabel

+ var ZeroVersion = semv.MustParse("0.0.0-unversioned")

+ func AllAdvisoryStrings() []string

+ func AnyTransientResolveErrors(err error) bool

+ func DBNameForTest(t *testing.T, optidx ...int) string

+ func DumpDeployStatuses(writer io.Writer, ds DeployStates)

+ func HandlePairsByRegistry(r Registry, dp *DeployablePair, ls logging.LogSink) (*DeployablePair, *DiffResolution)

+ func JSONDeployments(writer io.Writer, ds Deployments)

+ func NewDeployablePairSubmessage(pair *DeployablePair) logging.Submessage

+ func NewDeployableSubmessage(prefix string, dep *Deployable) logging.EachFielder

+ func NewDeploymentSubmessage(prefix string, dep *Deployment) logging.EachFielder

+ func NewStateManagerSpy() (StateManager, StateManagerController)

+ func NewStateManagerSpyFor(state *State) (StateManager, StateManagerController)

+ func NormalizedOffset(root, workdir string) (string, error)

+ func ReleaseDB(t *testing.T, optidx ...int)

+ func SetupDB(t *testing.T, optidx ...int) *sql.DB

+ func SetupDBNamed(t *testing.T, name string) (*sql.DB, error)

+ func TabbedDeployStatusHeaders() string

type Advisories

+ func AllAdvisories() Advisories

+ func (as Advisories) Contains(a AdvisoryName) bool

+ func (as Advisories) Strings() []string

type AutoResolver

+ GDM Deployments

type BuildArtifact

+ DigestReference string

+ VersionName string

+ func (ba BuildArtifact) EachField(f logging.FieldReportFn)

type BuildConfig

+ Dev bool

+ LogSink logging.LogSink

type BuildContext

+ func (bc *BuildContext) RevID() string

+ func (bc *BuildContext) ShouldPullDuringBuild() bool

type BuildManager

+ LogSink logging.LogSink

+ type BuildProduct struct

+ Advisories Advisories

+ DigestName string

+ ID string

+ Kind string

+ RevID string

+ RevisionName string

+ Source SourceID

+ VersionName string

+ func (bp *BuildProduct) String() string

+ func (bp BuildProduct) BuildArtifact() BuildArtifact

type BuildResult

+ Products []*BuildProduct

+ func (br *BuildResult) Contextualize(c *BuildContext)

+ type ClientInserter struct

type Cluster

+ Startup Startup

+ func ClusterFixture(name string) *Cluster

+ func DefaultCluster() *Cluster

+ func (c *Cluster) Diff(oc *Cluster) []string

+ type ClusterManager interface

+ ReadCluster func(clusterName string) (Deployments, error)

+ WriteCluster func(clusterName string, deps Deployments, user User) error

+ func MakeClusterManager(sm StateManager, ls logging.LogSink) ClusterManager

+ func NewClusterManagerSpy() (ClusterManager, *spies.Spy)

type Clusters

+ func GenerateClusters(count int, gen func(idx int) *Cluster) Clusters

type Defs

+ func (ds *Defs) Diff(o *Defs) []string

+ func (ds *Defs) EmptyReceiver() restful.Comparable

+ func (ds *Defs) VariancesFrom(other restful.Comparable) restful.Variances

type DeployConfig

+ Schedule string

+ SingularityRequestID string

+ Startup Startup

+ func DeployConfigFixture(name string) DeployConfig

type DeploySpec

+ func (spec DeploySpec) String() string

type DeploySpecs

+ func (specs DeploySpecs) ClusterNames() []string

+ type DeployState struct

+ ExecutorData interface{}

+ ExecutorMessage string

+ SchedulerURL string

+ Status DeployStatus

+ func (ds *DeployState) Diff(o *DeployState) (bool, []string)

+ func (ds *DeployState) Tabbed() string

+ func (ds DeployState) Clone() *DeployState

+ func (ds DeployState) Final() bool

+ func (ds DeployState) String() string

+ type DeployStates struct

+ func MakeDeployStates(capacity int) DeployStates

+ func NewDeployStates(from ...(*DeployState)) DeployStates

+ func NewDeployStatesFromMap(from ...map[DeploymentID](*DeployState)) DeployStates

+ func (d DeployStates) Diff(other Deployments) *DeployableChans

+ func (ds DeployStates) IgnoringStatus() Deployments

+ func (m *DeployStates) SetAll(v map[DeploymentID](*DeployState))

+ func (m DeployStates) Add(v *DeployState) (ok bool)

+ func (m DeployStates) AddAll(from DeployStates) (conflicting DeploymentID, success bool)

+ func (m DeployStates) Any(predicate func(*DeployState) bool) (*DeployState, bool)

+ func (m DeployStates) Clone() DeployStates

+ func (m DeployStates) Filter(predicate func(*DeployState) bool) DeployStates

+ func (m DeployStates) FilteredSnapshot(predicate func(*DeployState) bool) map[DeploymentID](*DeployState)

+ func (m DeployStates) Get(key DeploymentID) (v *DeployState, ok bool)

+ func (m DeployStates) GetAll() map[DeploymentID](*DeployState)

+ func (m DeployStates) Keys() []DeploymentID

+ func (m DeployStates) Len() int

+ func (m DeployStates) Merge(other DeployStates) DeployStates

+ func (m DeployStates) MustAdd(v *DeployState)

+ func (m DeployStates) Remove(key DeploymentID)

+ func (m DeployStates) Set(key DeploymentID, value *DeployState)

+ func (m DeployStates) Single(predicate func(*DeployState) bool) (*DeployState, bool)

+ func (m DeployStates) Snapshot() map[DeploymentID](*DeployState)

+ type DeployStatus int

+ const DeployStatusActive

+ const DeployStatusAny

+ const DeployStatusFailed

+ const DeployStatusPending

+ func (ds DeployStatus) Failed() bool

+ func (i DeployStatus) String() string

type Deployable

+ Status DeployStatus

+ func DeployableFixture(name string) *Deployable

+ func (d Deployable) EachField(f logging.FieldReportFn)

type DeployableChans

+ Errs chan *DiffResolution

+ Pairs chan *DeployablePair

+ func (d *DeployableChans) Close()

+ func (d *DeployableChans) Collect() DeployablePairs

+ func (d *DeployableChans) Log(ctx context.Context, ls logging.LogSink) *DeployableChans

+ func (d *DeployableChans) Pipeline(ctx context.Context, proc DeployableProcessor) *DeployableChans

type DeployablePair

+ ExecutorData interface{}

+ UUID uuid.UUID

+ func (dp *DeployablePair) Diffs() Differences

+ func (dp *DeployablePair) EachField(fn logging.FieldReportFn)

+ func (dp *DeployablePair) Kind() DeployablePairKind

+ func (dp *DeployablePair) SameResolution() DiffResolution

+ func (dp *DeployablePair) SetID(did DeploymentID)

+ type DeployablePairKind int

+ const AddedKind

+ const ModifiedKind

+ const RemovedKind

+ const SameKind

+ func (kind DeployablePairKind) ExpectedResolutionType() ResolutionType

+ func (kind DeployablePairKind) ResolveVerb() string

+ func (kind DeployablePairKind) String() string

+ type DeployablePairs []*DeployablePair

+ type DeployablePassThrough struct

+ func (DeployablePassThrough) Stable(dp *DeployablePair) (*DeployablePair, *DiffResolution)

+ func (DeployablePassThrough) Start(dp *DeployablePair) (*DeployablePair, *DiffResolution)

+ func (DeployablePassThrough) Stop(dp *DeployablePair) (*DeployablePair, *DiffResolution)

+ func (DeployablePassThrough) Update(dp *DeployablePair) (*DeployablePair, *DiffResolution)

+ type DeployableProcessor interface

+ HandlePairs func(dp *DeployablePair) (*DeployablePair, *DiffResolution)

+ type DeployableResolutionHandler interface

+ HandleResolution func(err *DiffResolution)

type Deployer

+ func NewDeployerSpy() (Deployer, *spies.Spy)

+ Rectify func(*DeployablePair) DiffResolution

+ Status func(Registry, Clusters, *DeployablePair) (*DeployState, error)

+ type DeployerSpy struct

+ func (dd *DeployerSpy) Rectify(p *DeployablePair) DiffResolution

+ func (dd *DeployerSpy) RunningDeployments(reg Registry, from Clusters) (DeployStates, error)

+ func (dd *DeployerSpy) Status(r Registry, c Clusters, p *DeployablePair) (*DeployState, error)

type Deployment

+ User User

+ func DeploymentFixture(name string) *Deployment

+ func (d *Deployment) DeploySpec() DeploySpec

+ func (d *Deployment) Validate() []Flaw

+ func (d Deployment) EachField(f logging.FieldReportFn)

+ type DeploymentID struct

+ Cluster string

+ ManifestID ManifestID

+ func ParseDeploymentID(s string) (DeploymentID, error)

+ func (did *DeploymentID) Digest() []byte

+ func (did DeploymentID) EachField(fn logging.FieldReportFn)

+ func (did DeploymentID) QueryMap() map[string]string

+ func (did DeploymentID) String() string

+ type DeploymentIDSlice []DeploymentID

+ func (dids DeploymentIDSlice) Len() int

+ func (dids DeploymentIDSlice) Less(i, j int) bool

+ func (dids DeploymentIDSlice) Swap(i, j int)

+ type DeploymentManager interface

+ ReadDeployment func(did DeploymentID) (*Deployment, error)

+ WriteDeployment func(dep *Deployment, user User) error

+ func MakeDeploymentManager(sm StateManager, ls logging.LogSink) DeploymentManager

+ func NewDeploymentManagerSpy() (DeploymentManager, *spies.Spy)

type DeploymentPair

+ Status DeployStatus

+ func (dp *DeploymentPair) Diffs() Differences

type Deployments

+ func DeploymentsFromManifest(defs Defs, m *Manifest) (Deployments, error)

+ func (ds *Deployments) EmptyReceiver() restful.Comparable

+ func (ds *Deployments) VariancesFrom(other restful.Comparable) restful.Variances

+ func (ds Deployments) PutbackManifests(defs Defs, olds Manifests, log logging.LogSink) (Manifests, error)

+ func (ds Deployments) RawManifests(defs Defs, log logging.LogSink) (Manifests, error)

type DiffResolution

+ DeployState *DeployState

+ SchedulerURL string

+ func (rez DiffResolution) EachField(f logging.FieldReportFn)

+ func (rez DiffResolution) String() string

+ type Differences []string

+ func (diffs Differences) String() string

+ type DispatchStateManager struct

+ func NewDispatchStateManager(localCluster string, clusters []string, local StateManager, ...) *DispatchStateManager

+ func (dsm *DispatchStateManager) ReadCluster(clusterName string) (Deployments, error)

+ func (dsm *DispatchStateManager) ReadState() (*State, error)

+ func (dsm *DispatchStateManager) WriteCluster(clusterName string, deps Deployments, user User) error

+ func (dsm *DispatchStateManager) WriteState(state *State, user User) error

type DummyStateManager

+ ReadErr error

+ WriteErr error

+ func NewDummyStateManager() *DummyStateManager

type Env

+ func (e Env) Clone() Env

type EnvDef

+ func (ed EnvDef) Diff(o EnvDef) []string

type EnvDefs

+ func (evs EnvDefs) Diff(os EnvDefs) []string

+ type ErrorWrapper struct

+ func WrapResolveError(err error) *ErrorWrapper

+ func (ew ErrorWrapper) Error() string

+ func (ew ErrorWrapper) MarshalJSON() ([]byte, error)

+ type FailedStatusError struct

+ func (e *FailedStatusError) Error() string

type FieldDefinition

+ func (fd FieldDefinition) Diff(o FieldDefinition) []string

type FieldDefinitions

+ func (fds FieldDefinitions) Diff(os FieldDefinitions) []string

+ type FlawMessage struct

+ Flaws []Flaw

+ func (msg FlawMessage) ReturnFlawMsg() string

type GenericFlaw

+ func FatalFlaw(frmt string, vals ...interface{}) GenericFlaw

type HTTPStateManager

+ User User

+ func (hsm *HTTPStateManager) ReadCluster(clusterName string) (Deployments, error)

+ func (hsm *HTTPStateManager) WriteCluster(clusterName string, deps Deployments, user User) error

+ type ImageLabeller interface

+ ImageLabels func(imageName string) (labels map[string]string, err error)

+ type InserterSpy struct

+ func NewInserterSpy() (InserterSpy, *spies.Spy)

+ func (is InserterSpy) Insert(sid SourceID, ba BuildArtifact) error

type Manifest

+ func DefaultManifest(mid ManifestID) *Manifest

+ func ManifestFixture(name string) *Manifest

type ManifestID

+ func GenerateManifestID(idx int, o ManifestIDOpts) ManifestID

+ func (mid ManifestID) EachField(fn logging.FieldReportFn)

+ func (mid ManifestID) QueryMap() map[string]string

+ type ManifestIDOpts struct

+ DirFmt string

+ FlavorFmt string

+ RepoFmt string

+ func DefaultManifestIDOpts(except ...func(*ManifestIDOpts)) ManifestIDOpts

type Manifests

+ func DefaultManifests(count int, except ...func(int, *Manifest)) Manifests

+ func GenerateManifests(count int, gen func(idx int) *Manifest) Manifests

+ func (ms Manifests) Deployments(defs Defs) (Deployments, error)

+ func (ms Manifests) Diff(other Manifests) (bool, []string)

+ func (ms Manifests) Flavors() []string

+ func (ms Manifests) String() string

+ type MarshallableError struct

+ String string

+ Type string

type Metadata

+ func (m Metadata) Clone() Metadata

type OwnerSet

+ func (os OwnerSet) Merge(other OwnerSet)

+ type Qualities []Quality

+ func (qs Qualities) EachField(f logging.FieldReportFn)

+ func (qs Qualities) String() string

+ type QueueSet interface

+ Push func(r *Rectification) (*QueuedR11n, bool)

+ PushIfEmpty func(r *Rectification) (*QueuedR11n, bool)

+ Queues func() map[DeploymentID]*R11nQueue

+ Wait func(did DeploymentID, id R11nID) (DiffResolution, bool)

+ func NewQueueSetSpy() (QueueSet, *spies.Spy)

+ type QueueSetSpy struct

+ func (s QueueSetSpy) Push(r *Rectification) (*QueuedR11n, bool)

+ func (s QueueSetSpy) PushIfEmpty(r *Rectification) (*QueuedR11n, bool)

+ func (s QueueSetSpy) Queues() map[DeploymentID]*R11nQueue

+ func (s QueueSetSpy) Wait(did DeploymentID, id R11nID) (DiffResolution, bool)

+ type QueuedR11n struct

+ ID R11nID

+ Pos int

+ Rectification *Rectification

+ type R11nID string

+ func NewR11nID() R11nID

+ type R11nQueue struct

+ func NewR11nQueue(opts ...R11nQueueOpt) *R11nQueue

+ func (rq *R11nQueue) ByID(id R11nID) (*QueuedR11n, bool)

+ func (rq *R11nQueue) Len() int

+ func (rq *R11nQueue) Push(r *Rectification) (*QueuedR11n, bool)

+ func (rq *R11nQueue) PushIfEmpty(r *Rectification) (*QueuedR11n, bool)

+ func (rq *R11nQueue) Snapshot() []QueuedR11n

+ func (rq *R11nQueue) Start(handler func(*QueuedR11n) DiffResolution)

+ func (rq *R11nQueue) Wait(id R11nID) (DiffResolution, bool)

+ type R11nQueueOpt func(*R11nQueue)

+ func R11nQueueCap(cap int) R11nQueueOpt

+ func R11nQueueStartWithHandler(handler func(*QueuedR11n) DiffResolution) R11nQueueOpt

+ type R11nQueueSet struct

+ func NewR11nQueueSet(opts ...R11nQueueOpt) *R11nQueueSet

+ func (rqs *R11nQueueSet) Push(r *Rectification) (*QueuedR11n, bool)

+ func (rqs *R11nQueueSet) PushIfEmpty(r *Rectification) (*QueuedR11n, bool)

+ func (rqs *R11nQueueSet) Queues() map[DeploymentID]*R11nQueue

+ func (rqs *R11nQueueSet) Wait(did DeploymentID, id R11nID) (DiffResolution, bool)

+ type Rectification struct

+ Pair DeployablePair

+ Resolution DiffResolution

+ func NewRectification(dp DeployablePair, l logging.LogSink) *Rectification

+ func (r *Rectification) Begin(d Deployer, reg Registry, rf *ResolveFilter, stateReader StateReader)

+ func (r *Rectification) EachField(fn logging.FieldReportFn)

+ func (r *Rectification) Wait() DiffResolution

+ type RegistrySpy struct

+ func NewRegistrySpy() (RegistrySpy, *spies.Spy)

+ func (spy RegistrySpy) GetArtifact(sid SourceID) (*BuildArtifact, error)

+ func (spy RegistrySpy) GetSourceID(art *BuildArtifact) (SourceID, error)

+ func (spy RegistrySpy) ImageLabels(imageName string) (labels map[string]string, err error)

+ func (spy RegistrySpy) ListSourceIDs() ([]SourceID, error)

+ func (spy RegistrySpy) Warmup(name string) error

+ type ResolutionType string

+ type ResolveFieldMatcher struct

+ Match *string

+ func NewResolveFieldMatcher(match string) ResolveFieldMatcher

+ func (matcher ResolveFieldMatcher) All() bool

+ func (matcher ResolveFieldMatcher) Value() (string, error)

+ func (matcher ResolveFieldMatcher) ValueOr(def string) string

type ResolveFilter

+ Status DeployStatus

+ func (rf *ResolveFilter) DeploymentID(mid ManifestID) (DeploymentID, error)

+ func (rf *ResolveFilter) EachField(fn logging.FieldReportFn)

+ func (rf *ResolveFilter) FilterDeployStates(d *DeployState) bool

+ func (rf *ResolveFilter) SetTag(tag string) error

+ func (rf *ResolveFilter) SourceID(mid ManifestID) (SourceID, error)

+ func (rf *ResolveFilter) SourceLocation() (SourceLocation, bool)

+ func (rf *ResolveFilter) TagVersion() (semv.Version, error)

type ResolveState

+ const ResolveErredHTTP

+ const ResolveErredRez

+ const ResolveHTTPFailed

+ const ResolveTasksStarting

+ func (rs ResolveState) Prose() string

type ResolveStatus

+ Finished time.Time

+ Intended []*Deployment

+ Started time.Time

type Resolver

+ QueueSet *R11nQueueSet

+ type Server struct

+ ClusterName string

+ URL string

+ type ServerListData struct

+ Servers []Server

type SourceContext

+ DevBuild bool

+ NearestTag Tag

+ func (sc *SourceContext) TagVersion() string

type SourceID

+ func MakeSourceID(repo, dir, version string) SourceID

+ func (sid SourceID) EachField(fn logging.FieldReportFn)

+ func (sid SourceID) HTTPQueryMap() map[string]string

type SourceLocation

+ func (sl *SourceLocation) EachField(f logging.FieldReportFn)

+ func (sl SourceLocation) ShortName() (string, error)

+ type Startup struct

+ CheckReadyFailureStatuses []int

+ CheckReadyInterval int

+ CheckReadyPortIndex int

+ CheckReadyProtocol string

+ CheckReadyRetries int

+ CheckReadyURIPath string

+ CheckReadyURITimeout int

+ ConnectDelay int

+ ConnectInterval int

+ SkipCheck bool

+ Timeout int

+ func (s *Startup) Validate() []Flaw

+ func (s Startup) Equal(o Startup) bool

+ func (s Startup) MergeDefaults(base Startup) Startup

+ func (s Startup) UnmergeDefaults(base, old Startup) Startup

type State

+ func DefaultStateFixture() *State

+ func DefaultStateFixtureWithFlavorsOffsets() *State

+ func StateFixture(o StateFixtureOpts) *State

+ func (s *State) SetEtag(etag string)

+ func (s State) CheckEtag(etag string) error

+ func (s State) GetEtag() (string, error)

+ type StateFixtureOpts struct

+ ClusterCount int

+ ClusterFunc func() *Cluster

+ ClusterSuffix string

+ ManifestCount int

+ ManifestIDOpts *ManifestIDOpts

+ type StateManagerController struct

+ type StateManagerSpy struct

+ func (spy StateManagerSpy) ReadState() (*State, error)

+ func (spy StateManagerSpy) WriteState(s *State, u User) error

type StatusPoller

+ User User

+ func (sp *StatusPoller) Wait(ctx context.Context) (ResolveState, error)

+ type TraceID string

+ func (tid TraceID) EachField(fn logging.FieldReportFn)

+ type User struct

+ Email string

+ Name string

+ func (u User) Complete() bool

+ func (u User) HTTPHeaders() map[string]string

+ func (u User) String() string

v0

v0.1.8-rc

Jan 27, 2017

v0.1.7

Jan 19, 2017

Changes in this version

+ func IsTransientResolveError(err error) bool

type ResolveState

+ const ResolveFailed

+ const ResolveMAX

+ const ResolveNotIntended

+ const ResolveTERMINALS

v0.1.6

Jan 17, 2017

v0.1.5

Jan 17, 2017

v0.1.4

Jan 17, 2017

v0.1.3

Jan 17, 2017

v0.1.2

Jan 14, 2017

Changes in this version

type LogSet

+ func (ls LogSet) BeChatty()

+ func (ls LogSet) BeQuiet()

v0.1.1

Jan 12, 2017

v0.0.4

Jan 12, 2017

v0.0.3

Jan 10, 2017

Changes in this version

+ type AutoResolver struct

+ UpdateTime time.Duration

+ func NewAutoResolver(rez *Resolver, sr StateReader, ls *LogSet) *AutoResolver

+ func (ar *AutoResolver) Kickoff() TriggerChannel

+ func (ar *AutoResolver) StandardListeners()

+ func (ar *AutoResolver) Statuses() (stable, live *ResolveStatus)

type BuildArtifact

+ func GuardImage(r Registry, d *Deployment) (art *BuildArtifact, err error)

+ func NewBuildArtifact(imageName string, qstrs Strpairs) *BuildArtifact

type BuildConfig

+ func (c *BuildConfig) Resolve()

type BuildManager

+ func (m *BuildManager) OffsetFromWorkdir(workdir, offset string) error

+ func (m *BuildManager) RegisterAndWarnAdvisories(br *BuildResult, bc *BuildContext) error

type Cluster

+ func (c Cluster) Clone() *Cluster

type Clusters

+ func (cs Clusters) Clone() Clusters

+ func (cs Clusters) Names() []string

+ func (cs Clusters) String() string

+ type Comparable interface

+ EmptyReceiver func() Comparable

+ VariancesFrom func(Comparable) Variances

type Defs

+ Metadata FieldDefinitions

+ func (d Defs) Clone() Defs

type DeployConfig

+ Metadata Metadata

+ func (dc *DeployConfig) Diff(o DeployConfig) (bool, []string)

+ func (dc *DeployConfig) Repair(fs []Flaw) error

+ func (dc *DeployConfig) Validate() []Flaw

+ func (dc DeployConfig) Clone() (c DeployConfig)

+ type DeployConfigs map[string]DeployConfig

type DeploySpec

+ func (spec DeploySpec) Clone() DeploySpec

+ func (spec DeploySpec) Diff(other DeploySpec) (bool, []string)

+ func (spec DeploySpec) Repair(fs []Flaw) error

+ func (spec DeploySpec) Validate() []Flaw

+ type Deployable struct

+ type DeployableChans struct

+ Stable chan *Deployable

+ Start chan *Deployable

+ Stop chan *Deployable

+ Update chan *DeployablePair

+ func NewDeployableChans(size ...int) *DeployableChans

+ func (dc *DeployableChans) ResolveNames(r Registry, diff *DiffChans, errs chan error)

+ type DeployablePair struct

+ Post *Deployable

+ Prior *Deployable

+ func (dp *DeployablePair) ID() DeployID

type Deployment

+ func (d *Deployment) Diff(o *Deployment) (bool, []string)

+ func (d Deployment) Clone() *Deployment

type DeploymentPair

+ func (dp *DeploymentPair) ID() DeployID

type Deployments

+ func (ds *Deployments) Only() (*Deployment, error)

type DiffChans

+ func (d DiffChans) Concentrate(defs Defs) DiffConcentrator

+ type DiffConcentrator struct

+ Created chan *Manifest

+ Deleted chan *Manifest

+ Errors chan error

+ Modified chan *ManifestPair

+ Retained chan *Manifest

+ func NewConcentrator(defs Defs, s DiffChans, sizes ...int) DiffConcentrator

+ type DiffResolution struct

+ Desc string

+ Error error

+ type DummyDeployer struct

+ func NewDummyDeployer() *DummyDeployer

+ func (dd *DummyDeployer) RectifyCreates(<-chan *Deployable, chan<- DiffResolution)

+ func (dd *DummyDeployer) RectifyDeletes(<-chan *Deployable, chan<- DiffResolution)

+ func (dd *DummyDeployer) RectifyModifies(<-chan *DeployablePair, chan<- DiffResolution)

+ func (dd *DummyDeployer) RunningDeployments(reg Registry, from Clusters) (Deployments, error)

+ type DummyRectificationClient struct

+ Created []dummyRequest

+ Deleted []dummyDelete

+ Deployed []dummyDeploy

+ func NewDummyRectificationClient() *DummyRectificationClient

+ func (t *DummyRectificationClient) DeleteRequest(cluster, reqid, message string) error

+ func (t *DummyRectificationClient) Deploy(cluster, depID, reqID, imageName string, res Resources, e Env, vols Volumes) error

+ func (t *DummyRectificationClient) PostRequest(cluster, id string, count int, kind ManifestKind, owners OwnerSet) error

+ func (t *DummyRectificationClient) SetLogger(l *log.Logger)

type DummyRegistry

+ func (dc *DummyRegistry) ImageLabels(in string) (map[string]string, error)

+ type DummyStateManager struct

+ ReadCount int

+ WriteCount int

+ func (sm *DummyStateManager) ReadState() (*State, error)

+ func (sm *DummyStateManager) WriteState(s *State) error

type EnvDefs

+ func (evs EnvDefs) Clone() EnvDefs

+ type FieldDefinition struct

+ Default string

+ Name string

+ Optional bool

+ Type VarType

+ type FieldDefinitions []FieldDefinition

+ func (rdf FieldDefinitions) Clone() FieldDefinitions

+ type Flaw interface

+ AddContext func(string, interface{})

+ Repair func() error

+ func RepairAll(in []Flaw) ([]Flaw, []error)

+ type Flawed interface

+ Validate func() []Flaw

+ type GenericFlaw struct

+ Desc string

+ RepairFunc func() error

+ func NewFlaw(desc string, repair func() error) GenericFlaw

+ func (gf GenericFlaw) AddContext(name string, thing interface{})

+ func (gf GenericFlaw) Error() error

+ func (gf GenericFlaw) Repair() error

+ func (gf GenericFlaw) String() string

+ type HTTPClient struct

+ func NewClient(serverURL string) (*HTTPClient, error)

+ func (client *HTTPClient) Create(urlPath string, qParms map[string]string, qBody interface{}) error

+ func (client *HTTPClient) Delete(urlPath string, qParms map[string]string, from Comparable) error

+ func (client *HTTPClient) Retrieve(urlPath string, qParms map[string]string, rzBody interface{}) error

+ func (client *HTTPClient) Update(urlPath string, qParms map[string]string, from, qBody Comparable) error

+ type HTTPNameInserter struct

+ func NewHTTPNameInserter(server string) (*HTTPNameInserter, error)

+ func (hni *HTTPNameInserter) Insert(sid SourceID, in, etag string, qs []Quality) error

+ type HTTPStateManager struct

+ func NewHTTPStateManager(client *HTTPClient) *HTTPStateManager

+ func (hsm *HTTPStateManager) ReadState() (*State, error)

+ func (hsm *HTTPStateManager) WriteState(s *State) error

+ type Inserter interface

+ Insert func(sid SourceID, in, etag string, qs []Quality) error

type LogSet

+ func NewLogSet(warn, debug, vomit io.Writer) *LogSet

+ func SilentLogSet() *LogSet

type Manifest

+ func (m *Manifest) Diff(o *Manifest) (bool, []string)

+ func (m *Manifest) EmptyReceiver() Comparable

+ func (m *Manifest) Repair(fs []Flaw) error

+ func (m *Manifest) Validate() []Flaw

+ func (m *Manifest) VariancesFrom(c Comparable) (vs Variances)

+ func (m Manifest) Clone() (c *Manifest)

type ManifestKind

+ func (mk ManifestKind) Validate() []Flaw

+ type ManifestPair struct

+ Post *Manifest

+ Prior *Manifest

+ type ManifestPairs []*ManifestPair

type Manifests

+ func (ms *Manifests) Only() (*Manifest, error)

+ type Metadata map[string]string

+ func (e Metadata) Equal(o Metadata) bool

+ type MissingResourceFlaw struct

+ ClusterName string

+ Default string

+ Field string

+ func (f *MissingResourceFlaw) AddContext(name string, i interface{})

+ func (f *MissingResourceFlaw) Repair() error

+ func (f *MissingResourceFlaw) String() string

+ type NilVolumeFlaw struct

+ func (nvf *NilVolumeFlaw) AddContext(string, interface{})

+ func (nvf *NilVolumeFlaw) Repair() error

type OwnerSet

+ func (os OwnerSet) Clone() OwnerSet

+ func (os OwnerSet) Diff(o OwnerSet) (bool, []string)

+ func (os OwnerSet) Slice() []string

+ type ReadDebugger struct

+ func NewReadDebugger(rc io.ReadCloser, log func([]byte, int, error)) *ReadDebugger

+ func (rd *ReadDebugger) Close() error

+ func (rd *ReadDebugger) Read(p []byte) (int, error)

type Registry

+ ImageLabels func(imageName string) (labels map[string]string, err error)

+ type ResolveFilter struct

+ Cluster string

+ Flavor string

+ Offset string

+ Repo string

+ Revision string

+ Tag string

+ func (rf *ResolveFilter) All() bool

+ func (rf *ResolveFilter) FilterClusterName(name string) bool

+ func (rf *ResolveFilter) FilterDeployment(d *Deployment) bool

+ func (rf *ResolveFilter) FilterManifest(m *Manifest) bool

+ func (rf *ResolveFilter) FilterManifestID(m ManifestID) bool

+ func (rf *ResolveFilter) FilteredClusters(c Clusters) Clusters

+ func (rf *ResolveFilter) String() string

+ type ResolveRecorder struct

+ Log chan DiffResolution

+ func NewResolveRecorder(f func(*ResolveRecorder)) *ResolveRecorder

+ func (rr *ResolveRecorder) CurrentStatus() (rs ResolveStatus)

+ func (rr *ResolveRecorder) Done() bool

+ func (rr *ResolveRecorder) Phase() string

+ func (rr *ResolveRecorder) Wait() error

+ type ResolveState int

+ const ResolveComplete

+ const ResolveErred

+ const ResolveInProgress

+ const ResolveNotPolled

+ const ResolveNotStarted

+ const ResolveNotVersion

+ const ResolvePendingRequest

+ func (rs ResolveState) String() string

+ type ResolveStatus struct

+ Errs ResolveErrors

+ Log []DiffResolution

+ Phase string

+ func (rs *ResolveStatus) Err() error

type Resolver

+ func (r *Resolver) Begin(intended Deployments, clusters Clusters) *ResolveRecorder

type Resources

+ func (r Resources) Clone() Resources

+ func (r Resources) Validate() []Flaw

type SourceID

+ func (sid SourceID) QueryValues() url.Values

type State

+ func (s *State) Repair(fs []Flaw) error

+ func (s *State) UpdateDeployments(ds ...*Deployment) error

+ func (s *State) Validate() []Flaw

+ func (s State) Clone() *State

+ type StateManager interface

+ type StateReader interface

+ ReadState func() (*State, error)

+ type StateWriter interface

+ WriteState func(*State) error

+ type StatusPoller struct

+ func NewStatusPoller(cl *HTTPClient, rf *ResolveFilter) *StatusPoller

+ func (sp *StatusPoller) Start() (ResolveState, error)

+ type Strpair [2]string

+ type Strpairs []Strpair

+ type TriggerChannel chan TriggerType

+ type TriggerType struct

+ type Variances []string

type Volumes

+ func (vs Volumes) Clone() Volumes

v0.0.3-prerelease9

Jan 12, 2017

v0.0.3-prerelease8

Jan 12, 2017

v0.0.3-prerelease7

Jan 12, 2017

v0.0.3-prerelease6

Jan 12, 2017

v0.0.3-prerelease5

Jan 11, 2017

v0.0.3-prerelease4

Jan 11, 2017

v0.0.3-prerelease3

Jan 11, 2017

v0.0.3-prerelease2

Jan 11, 2017

v0.0.3-prerelease11

Jan 12, 2017

v0.0.3-prerelease10

Jan 12, 2017

v0.0.3-prerelease

Jan 11, 2017

v0.0.2

Sep 9, 2016

Changes in this version

+ const FlavorSeparator

type DeployID

+ ManifestID ManifestID

type Deployment

+ Flavor string

+ func (d *Deployment) ManifestID() ManifestID

+ type GenericHost struct

+ func (h GenericHost) CanParseSourceLocation(string) bool

+ func (h GenericHost) GetSource(id SourceID) (Source, error)

+ func (h GenericHost) Owns(SourceLocation) bool

+ func (h GenericHost) ParseSourceLocation(s string) (SourceLocation, error)

type Manifest

+ Flavor string

+ func (m *Manifest) SetID(mid ManifestID)

+ type ManifestID struct

+ Flavor string

+ Source SourceLocation

+ func MustParseManifestID(s string) ManifestID

+ func ParseManifestID(s string) (ManifestID, error)

+ func (mid *ManifestID) UnmarshalText(b []byte) error

+ func (mid *ManifestID) UnmarshalYAML(unmarshal func(interface{}) error) error

+ func (mid ManifestID) MarshalText() ([]byte, error)

+ func (mid ManifestID) MarshalYAML() (interface{}, error)

+ func (mid ManifestID) String() string

type OwnerSet

+ func NewOwnerSet(owners ...string) OwnerSet

type Resolver

+ Filter DeploymentPredicate

+ type Source struct

+ Context SourceContext

+ ID SourceID

+ LocalOffsetDir string

+ LocalRootDir string

+ type SourceHost interface

+ CanParseSourceLocation func(string) bool

+ GetSource func(SourceID) (Source, error)

+ Owns func(SourceLocation) bool

+ ParseSourceLocation func(string) (SourceLocation, error)

+ type SourceHostChooser struct

+ SourceHosts []SourceHost

+ func (e *SourceHostChooser) ParseSourceLocation(s string) (SourceLocation, error)

type SourceID

+ func MustNewSourceID(repo, offset, version string) SourceID

+ func NewSourceID(repo, offset, version string) (SourceID, error)

v0.0.2-rc

Sep 9, 2016

v0.0.1

Aug 30, 2016

Changes in this version

+ const BogusRev

+ const DefaultDelim

+ const DirtyWS

+ const EphemeralTag

+ const NoRepoAdv

+ const NotRequestedRevision

+ const TagMismatch

+ const TagNotHead

+ const UnknownRepo

+ const UnpushedRev

+ const Unversioned

+ var Log = func() LogSet { ... }()

+ func DumpDeployments(io io.Writer, ds Deployments)

+ func SetupLogging(il ILogger)

+ func TabbedDeploymentHeaders() string

+ type Advisories []AdvisoryName

+ type AdvisoryName string

+ type Annotation struct

+ RequestID string

+ type BuildArtifact struct

+ Name string

+ Qualities []Quality

+ Type string

+ type BuildConfig struct

+ Context *BuildContext

+ ForceClone bool

+ Offset string

+ Repo string

+ Revision string

+ Strict bool

+ Tag string

+ func (c *BuildConfig) Advisories(ctx *BuildContext) (advs []string)

+ func (c *BuildConfig) GuardRegister(bc *BuildContext) error

+ func (c *BuildConfig) GuardStrict(bc *BuildContext) error

+ func (c *BuildConfig) NewContext() *BuildContext

+ func (c *BuildConfig) Validate() error

+ type BuildContext struct

+ Advisories []string

+ Changes Changes

+ Machine Machine

+ Scratch ScratchContext

+ Sh shell.Shell

+ Source SourceContext

+ User user.User

+ func (bc *BuildContext) Version() SourceID

+ type BuildManager struct

+ BuildConfig *BuildConfig

+ func (m *BuildManager) Build() (*BuildResult, error)

+ type BuildResult struct

+ Advisories []string

+ Elapsed time.Duration

+ ImageID string

+ RevisionName string

+ VersionName string

+ func (br *BuildResult) String() string

+ type Buildpack interface

+ Build func(*BuildContext) (*BuildResult, error)

+ Detect func(*BuildContext) (*DetectResult, error)

+ type ChangeError struct

+ Deployments *DeploymentPair

+ Err error

+ func (e *ChangeError) Error() string

+ func (e *ChangeError) ExistingDeployment() *Deployment

+ func (e *ChangeError) IntendedDeployment() *Deployment

+ type Changes struct

+ ChangedFiles []string

+ NewCommit []string

+ NewFiles []string

+ NewTag []string

+ SousUpdated []string

+ type Cluster struct

+ AllowedAdvisories []string

+ BaseURL string

+ Env EnvDefaults

+ Kind string

+ Name string

+ type Clusters map[string]*Cluster

+ type CreateError struct

+ Deployment *Deployment

+ Err error

+ func (e *CreateError) Error() string

+ func (e *CreateError) ExistingDeployment() *Deployment

+ func (e *CreateError) IntendedDeployment() *Deployment

+ type Debug struct

+ type Defs struct

+ Clusters Clusters

+ DockerRepo string

+ EnvVars EnvDefs

+ Resources ResDefs

+ type DeleteError struct

+ Deployment *Deployment

+ Err error

+ func (e *DeleteError) Error() string

+ func (e *DeleteError) ExistingDeployment() *Deployment

+ func (e *DeleteError) IntendedDeployment() *Deployment

+ type DeployConfig struct

+ Args []string

+ NumInstances int

+ Resources Resources

+ Volumes Volumes

+ func (dc *DeployConfig) Equal(o DeployConfig) bool

+ func (dc *DeployConfig) String() string

+ type DeployID struct

+ Cluster string

+ Source SourceLocation

+ type DeploySpec struct

+ Version semv.Version

+ func (spec DeploySpec) Equal(other DeploySpec) bool

+ type DeploySpecs map[string]DeploySpec

+ type Deployer interface

+ RectifyCreates func(<-chan *Deployment, chan<- RectificationError)

+ RectifyDeletes func(<-chan *Deployment, chan<- RectificationError)

+ RectifyModifies func(<-chan *DeploymentPair, chan<- RectificationError)

+ RunningDeployments func(from Clusters) (Deployments, error)

+ type Deployment struct

+ Cluster *Cluster

+ ClusterName string

+ Kind ManifestKind

+ Owners OwnerSet

+ SourceID SourceID

+ Volumes Volumes

+ func BuildDeployment(s *State, m *Manifest, nick string, spec DeploySpec, inherit []DeploySpec) (*Deployment, error)

+ func (d *Deployment) Equal(o *Deployment) bool

+ func (d *Deployment) ID() DeployID

+ func (d *Deployment) Name() DeployID

+ func (d *Deployment) String() string

+ func (d *Deployment) Tabbed() string

+ type DeploymentPair struct

+ Post *Deployment

+ Prior *Deployment

+ type DeploymentPairs []*DeploymentPair

+ type DeploymentPredicate func(*Deployment) bool

+ type Deployments struct

+ func MakeDeployments(capacity int) Deployments

+ func NewDeployments(from ...(*Deployment)) Deployments

+ func NewDeploymentsFromMap(from ...map[DeployID](*Deployment)) Deployments

+ func (d Deployments) Diff(other Deployments) DiffChans

+ func (ds Deployments) Manifests(defs Defs) (Manifests, error)

+ func (m *Deployments) SetAll(v map[DeployID](*Deployment))

+ func (m Deployments) Add(v *Deployment) (ok bool)

+ func (m Deployments) AddAll(from Deployments) (conflicting DeployID, success bool)

+ func (m Deployments) Any(predicate func(*Deployment) bool) (*Deployment, bool)

+ func (m Deployments) Clone() Deployments

+ func (m Deployments) Filter(predicate func(*Deployment) bool) Deployments

+ func (m Deployments) FilteredSnapshot(predicate func(*Deployment) bool) map[DeployID](*Deployment)

+ func (m Deployments) Get(key DeployID) (v *Deployment, ok bool)

+ func (m Deployments) GetAll() map[DeployID](*Deployment)

+ func (m Deployments) Keys() []DeployID

+ func (m Deployments) Len() int

+ func (m Deployments) Merge(other Deployments) Deployments

+ func (m Deployments) MustAdd(v *Deployment)

+ func (m Deployments) Remove(key DeployID)

+ func (m Deployments) Set(key DeployID, value *Deployment)

+ func (m Deployments) Single(predicate func(*Deployment) bool) (*Deployment, bool)

+ func (m Deployments) Snapshot() map[DeployID](*Deployment)

+ type DetectResult struct

+ Compatible bool

+ Data interface{}

+ Description string

+ type DiffChans struct

+ Created chan *Deployment

+ Deleted chan *Deployment

+ Modified chan *DeploymentPair

+ Retained chan *Deployment

+ func NewDiffChans(sizes ...int) DiffChans

+ func (d *DiffChans) Close()

+ type DummyRegistry struct

+ func NewDummyRegistry() *DummyRegistry

+ func (dc *DummyRegistry) FeedArtifact(ba *BuildArtifact, e error)

+ func (dc *DummyRegistry) FeedSourceID(sid SourceID, e error)

+ func (dc *DummyRegistry) FeedSourceIDList(sids []SourceID, e error)

+ func (dc *DummyRegistry) GetArtifact(sid SourceID) (*BuildArtifact, error)

+ func (dc *DummyRegistry) GetSourceID(*BuildArtifact) (SourceID, error)

+ func (dc *DummyRegistry) ListSourceIDs() ([]SourceID, error)

+ func (dc *DummyRegistry) Warmup(string) error

+ type DumperEntry struct

+ func (de *DumperEntry) Tabbed() string

+ type EchoSelector struct

+ Factory func(*BuildContext) (Buildpack, error)

+ func (s *EchoSelector) SelectBuildpack(c *BuildContext) (Buildpack, error)

+ type Engine struct

+ MessageHandler func(Message)

+ func (e *Engine) GetSourceContext() (*SourceContext, error)

+ type Env map[string]string

+ func (e Env) Equal(o Env) bool

+ type EnvDef struct

+ Desc string

+ Name string

+ Scope string

+ Type VarType

+ type EnvDefaults map[string]Var

+ type EnvDefs []EnvDef

+ type Error struct

+ type ILogger interface

+ SetDebugFunc func(func(...interface{}))

+ SetLogFunc func(func(...interface{}))

+ type IncludesVersion struct

+ func (err *IncludesVersion) Error() string

+ type Info struct

+ type Labeller interface

+ ApplyMetadata func(*BuildResult, *BuildContext) error

+ type LogSet struct

+ Debug *log.Logger

+ Info *log.Logger

+ Notice *log.Logger

+ Vomit *log.Logger

+ Warn *log.Logger

+ type Machine struct

+ FullHost string

+ Host string

+ type Manifest struct

+ Deployments DeploySpecs

+ Kind ManifestKind

+ Owners []string

+ Source SourceLocation

+ func (m *Manifest) Equal(o *Manifest) bool

+ func (m *Manifest) FileLocation() string

+ func (m *Manifest) ID() SourceLocation

+ type ManifestKind string

+ const ManifestKindOnDemand

+ const ManifestKindOnce

+ const ManifestKindScheduled

+ const ManifestKindService

+ const ManifestKindWorker

+ const ScheduledJob

+ type Manifests struct

+ func MakeManifests(capacity int) Manifests

+ func NewManifests(from ...(*Manifest)) Manifests

+ func NewManifestsFromMap(from ...map[SourceLocation](*Manifest)) Manifests

+ func (m *Manifests) SetAll(v map[SourceLocation](*Manifest))

+ func (m Manifests) Add(v *Manifest) (ok bool)

+ func (m Manifests) AddAll(from Manifests) (conflicting SourceLocation, success bool)

+ func (m Manifests) Any(predicate func(*Manifest) bool) (*Manifest, bool)

+ func (m Manifests) Clone() Manifests

+ func (m Manifests) Filter(predicate func(*Manifest) bool) Manifests

+ func (m Manifests) FilteredSnapshot(predicate func(*Manifest) bool) map[SourceLocation](*Manifest)

+ func (m Manifests) Get(key SourceLocation) (v *Manifest, ok bool)

+ func (m Manifests) GetAll() map[SourceLocation](*Manifest)

+ func (m Manifests) Keys() []SourceLocation

+ func (m Manifests) Len() int

+ func (m Manifests) Merge(other Manifests) Manifests

+ func (m Manifests) MustAdd(v *Manifest)

+ func (m Manifests) Remove(key SourceLocation)

+ func (m Manifests) Set(key SourceLocation, value *Manifest)

+ func (m Manifests) Single(predicate func(*Manifest) bool) (*Manifest, bool)

+ func (m Manifests) Snapshot() map[SourceLocation](*Manifest)

+ type Message interface

+ Body func() string

+ Sender func() string

+ Time func() time.Time

+ func Messagef(from, format string, v ...interface{}) Message

+ type Messenger struct

+ Handler func(Message)

+ Owner string

+ Queue chan Message

+ func NewMessenger(owner string, handler func(Message)) *Messenger

+ func (m *Messenger) Errorf(format string, v ...interface{})

+ type MissingImageNameError struct

+ Cause error

+ func (e *MissingImageNameError) Error() string

+ type MissingPath struct

+ func (err *MissingPath) Error() string

+ type MissingRepo struct

+ func (err *MissingRepo) Error() string

+ type MissingVersion struct

+ func (err *MissingVersion) Error() string

+ type OwnerSet map[string]struct

+ func (os OwnerSet) Add(owner string)

+ func (os OwnerSet) Equal(o OwnerSet) bool

+ func (os OwnerSet) Remove(owner string)

+ type Quality struct

+ Kind string

+ Name string

+ type RectificationError interface

+ ExistingDeployment func() *Deployment

+ IntendedDeployment func() *Deployment

+ type Registrar interface

+ Register func(*BuildResult, *BuildContext) error

+ type Registry interface

+ GetArtifact func(SourceID) (*BuildArtifact, error)

+ GetSourceID func(*BuildArtifact) (SourceID, error)

+ ListSourceIDs func() ([]SourceID, error)

+ Warmup func(string) error

+ type RegistryDumper struct

+ func NewRegistryDumper(r Registry) *RegistryDumper

+ func (rd *RegistryDumper) AsTable(to io.Writer) error

+ func (rd *RegistryDumper) Entries() (de []DumperEntry, err error)

+ func (rd *RegistryDumper) TabbedHeaders() string

+ type ResDef struct

+ Name string

+ Type VarType

+ type ResDefs []ResDef

+ type ResolveErrors struct

+ Causes []error

+ func (re *ResolveErrors) Error() string

+ type Resolver struct

+ Deployer Deployer

+ Registry Registry

+ func NewResolver(d Deployer, r Registry) *Resolver

+ func (r *Resolver) Resolve(intended Deployments, clusters Clusters) error

+ type Resources map[string]string

+ func (r Resources) Cpus() float64

+ func (r Resources) Equal(o Resources) bool

+ func (r Resources) Memory() float64

+ func (r Resources) Ports() int32

+ type ScratchContext struct

+ OffsetDir string

+ RootDir string

+ Sh *shell.Sh

+ type Selector interface

+ SelectBuildpack func(*BuildContext) (Buildpack, error)

+ type SourceContext struct

+ Branch string

+ DirtyWorkingTree bool

+ Files []string

+ ModifiedFiles []string

+ NearestTagName string

+ NearestTagRevision string

+ NewFiles []string

+ OffsetDir string

+ PrimaryRemoteURL string

+ RemoteURL string

+ RemoteURLs []string

+ Revision string

+ RevisionUnpushed bool

+ RootDir string

+ Tags []Tag

+ func (sc *SourceContext) AbsDir() string

+ func (sc *SourceContext) SourceLocation() SourceLocation

+ func (sc *SourceContext) Version() SourceID

+ type SourceID struct

+ Dir string

+ Repo string

+ Version semv.Version

+ func MustParseSourceID(s string) SourceID

+ func ParseSourceID(s string) (SourceID, error)

+ func (sid SourceID) Equal(o SourceID) bool

+ func (sid SourceID) Location() SourceLocation

+ func (sid SourceID) RevID() string

+ func (sid SourceID) String() string

+ func (sid SourceID) Tag() string

+ type SourceLocation struct

+ Dir string

+ Repo string

+ func MustParseSourceLocation(s string) SourceLocation

+ func NewSourceLocation(repoURL, repoOffset string) SourceLocation

+ func ParseSourceLocation(s string) (SourceLocation, error)

+ func (sl *SourceLocation) SourceID(version semv.Version) SourceID

+ func (sl *SourceLocation) UnmarshalText(b []byte) error

+ func (sl *SourceLocation) UnmarshalYAML(unmarshal func(interface{}) error) error

+ func (sl SourceLocation) MarshalText() ([]byte, error)

+ func (sl SourceLocation) MarshalYAML() (interface{}, error)

+ func (sl SourceLocation) String() string

+ type State struct

+ Defs Defs

+ Manifests Manifests

+ func NewState() *State

+ func (s *State) BaseURLs() []string

+ func (s *State) ClusterMap() map[string]string

+ func (s *State) Deployments() (Deployments, error)

+ func (s *State) DeploymentsFromManifest(m *Manifest) (Deployments, error)

+ func (s *State) OnlyCluster(nick string)

+ type Tag struct

+ Name string

+ Revision string

+ type UnacceptableAdvisory struct

+ func (e *UnacceptableAdvisory) Error() string

+ type Var string

+ type VarType string

+ type Volume struct

+ Container string

+ Host string

+ Mode VolumeMode

+ func (v *Volume) Equal(o *Volume) bool

+ type VolumeMode string

+ const ReadOnly

+ const ReadWrite

+ type Volumes []*Volume

+ func (vs Volumes) Equal(o Volumes) bool

+ func (vs Volumes) String() string

+ type Warning struct

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL