client

package
v1.5.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 21, 2019 License: MIT Imports: 15 Imported by: 0

Documentation

Index

Constants

View Source 
const PipelineCompleteKey = "pipeline.complete"

PipelineCompleteKey for pipeline complete

View Source 
const PipelineFailedKey = "pipeline.failed"

PipelineFailedKey for pipeline failed

View Source 
const PipelineStartingKey = "pipeline.starting"

PipelineStartingKey for pipeline starting

View Source 
const StageCompleteKey = "stage.complete"

StageCompleteKey for stage complete

View Source 
const StageFailedKey = "stage.failed"

StageFailedKey for stage failed

View Source 
const StageStartingKey = "stage.starting"

StageStartingKey for pipeline starting

Variables

View Source 
var ErrCanaryConfigNotFound = errors.New("Could not find canary config")
View Source 
var ErrInvalidApplicationName = errors.New("Invalid application name")

ErrInvalidApplicationName invalid application name

View Source 
var ErrInvalidDecodeResponseParameter = errors.New("nil interface provided to decodeResponse")

ErrInvalidDecodeResponseParameter invalid parameter for decodeResponse

View Source 
var ErrInvalidNotificatoinLevel = errors.New("Invalid notification level")

ErrInvalidNotificatoinLevel invalid notification level

View Source 
var ErrParameterNotFound = errors.New("could not find parameter")

ErrParameterNotFound parameter not found

View Source 
var ErrPipelineNotFound = errors.New("Could not find pipeline")

ErrPipelineNotFound pipeline not found

View Source 
var ErrPipelineNotificationNotFound = errors.New("notification not found")

ErrPipelineNotificationNotFound notification not found

View Source 
var ErrStageNotFound = errors.New("Could not find stage")

ErrStageNotFound stage not found

View Source 
var ErrTriggerNotFound = errors.New("could not find trigger")

ErrTriggerNotFound trigger not found

Functions

This section is empty.

Types

type Application 

type Application struct {
	Accounts       string       `json:"accounts"`
	CloudProviders string       `json:"cloudProviders"`
	CreateTs       string       `json:"createTs"`
	DataSources    *DataSources `json:"dataSources"`
	DesiredCount   string       `json:"desiredCount"`
	Email          string       `json:"email"`

	EnableRestartRunningExecutions bool `json:"enableRestartRunningExecutions"`

	IamRole        string `json:"iamRole"`
	InstancePort   int    `json:"instancePort"`
	LastModifiedBy string `json:"lastModifiedBy"`
	Name           string `json:"name"`

	PlatformHealthOnly             bool              `json:"platformHealthOnly"`
	PlatformHealthOnlyShowOverride bool              `json:"platformHealthOnlyShowOverride"`
	ProviderSettings               *ProviderSettings `json:"providerSettings"`

	RepoProjectKey string   `json:"repoProjectKey"`
	RepoSlug       string   `json:"repoSlug"`
	RepoType       string   `json:"repoType"`
	TaskDefinition string   `json:"taskDefinition"`
	TrafficGuards  []string `json:"trafficGuards"`
	UpdateTs       string   `json:"updateTs"`
	User           string   `json:"user"`
}

Application Settings for Application

func NewApplication 

func NewApplication() *Application

NewApplication return Application object with default values

type ApplicationAttributes added in v1.3.0 

type ApplicationAttributes struct {
	Application *Application `json:"attributes"`
}

ApplicationAttributes mapping for `application/{appName}` endpoint

type ApplicationService 

type ApplicationService struct {
	*Client
}

ApplicationService for interacting with spinnaker applications

func (*ApplicationService) CreateApplication 

func (service *ApplicationService) CreateApplication(app *Application) error

CreateApplication create an application

func (*ApplicationService) DeleteApplication 

func (service *ApplicationService) DeleteApplication(app *Application) error

DeleteApplication delete an application

func (*ApplicationService) GetApplicationByName added in v1.3.0 

func (service *ApplicationService) GetApplicationByName(name string) (*Application, error)

GetApplicationByName return the application given a name

func (*ApplicationService) GetApplicationByNameWithRetries added in v1.3.0 

func (service *ApplicationService) GetApplicationByNameWithRetries(name string) (*Application, error)

GetApplicationByNameWithRetries return the application given a name and retries

func (*ApplicationService) GetApplications 

func (service *ApplicationService) GetApplications() (*[]*Application, error)

GetApplications get all applications

func (*ApplicationService) UpdateApplication added in v1.3.0 

func (service *ApplicationService) UpdateApplication(app *Application) error

UpdateApplication update an application

type Auth added in v1.3.0 

type Auth struct {
	Enabled   bool
	CertPath  string
	KeyPath   string
	UserEmail string
	Insecure  bool
}

Auth for login on spinnaker

func NewAuth added in v1.3.0 

func NewAuth() *Auth

type AwsProviderSettings 

type AwsProviderSettings struct {
	UseAmiBlockDeviceMappings bool `json:"useAmiBlockDeviceMappings"`
}

AwsProviderSettings Settings for AWS Provider

func NewAwsProviderSettings 

func NewAwsProviderSettings() *AwsProviderSettings

NewAwsProviderSettings return Aws provider settings with default values

type BakeStage 

type BakeStage struct {
	Notifications *[]*Notification `json:"notifications"`
	// contains filtered or unexported fields
}

BakeStage for pipeline

func NewBakeStage 

func NewBakeStage() *BakeStage

NewBakeStage for pipeline

func (*BakeStage) GetName 

func (s *BakeStage) GetName() string

GetName for Stage interface

func (*BakeStage) GetRefID 

func (s *BakeStage) GetRefID() string

GetRefID for Stage interface

func (*BakeStage) GetType 

func (s *BakeStage) GetType() StageType

GetType for Stage interface

type CanaryAnalysisConfig added in v1.5.0 

type CanaryAnalysisConfig struct {
	CanaryAnalysisIntervalMins string `json:"canaryAnalysisIntervalMins"`
	CanaryConfigId             string `json:"canaryConfigId"`
	LifetimeDuration           string `json:"lifetimeDuration"`
	MetricsAccountName         string `json:"metricsAccountName"`

	Scopes          []*CanaryAnalysisConfigScope         `json:"scopes"`
	ScoreThresholds CanaryAnalysisConfigScoreThreadholds `json:"scoreThresholds"`

	StorageAccountName string `json:"storageAccountName"`
}

func NewCanaryAnalysisConfig added in v1.5.0 

func NewCanaryAnalysisConfig() *CanaryAnalysisConfig

type CanaryAnalysisConfigScope added in v1.5.0 

type CanaryAnalysisConfigScope struct {
	ControlLocation     string            `json:"controlLocation,omitempty"`
	ControlScope        string            `json:"controlScope,omitempty"`
	ExperimentLocation  string            `json:"experimentLocation,omitempty"`
	ExperimentScope     string            `json:"experimentScope,omitempty"`
	ExtendedScopeParams map[string]string `json:"extendedScopeParams"`
	ScopeName           string            `json:"scopeName"`
	Step                int               `json:"step"`
}

type CanaryAnalysisConfigScoreThreadholds added in v1.5.0 

type CanaryAnalysisConfigScoreThreadholds struct {
	Marginal string `json:"marginal"`
	Pass     string `json:"pass"`
}

type CanaryAnalysisStage added in v1.5.0 

type CanaryAnalysisStage struct {
	// BaseStage
	Name                              string                `json:"name"`
	RefID                             string                `json:"refId"`
	Type                              StageType             `json:"type"`
	RequisiteStageRefIds              []string              `json:"requisiteStageRefIds"`
	SendNotifications                 bool                  `json:"sendNotifications"`
	StageEnabled                      *StageEnabled         `json:"stageEnabled"`
	CompleteOtherBranchesThenFail     bool                  `json:"completeOtherBranchesThenFail"`
	ContinuePipeline                  bool                  `json:"continuePipeline"`
	FailOnFailedExpressions           bool                  `json:"failOnFailedExpressions"`
	FailPipeline                      bool                  `json:"failPipeline"`
	OverrideTimeout                   bool                  `json:"overrideTimeout"`
	RestrictExecutionDuringTimeWindow bool                  `json:"restrictExecutionDuringTimeWindow"`
	RestrictedExecutionWindow         *StageExecutionWindow `json:"restrictedExecutionWindow"`
	Notifications                     *[]*Notification      `json:"notifications"`

	AnalysisType string                 `json:"analysisType"`
	CanaryConfig *CanaryAnalysisConfig  `json:"canaryConfig"`
	Deployments  *[]*DeployStageCluster `json:"deployments,omitempty"`
}

func NewCanaryAnalysisStage added in v1.5.0 

func NewCanaryAnalysisStage() *CanaryAnalysisStage

func (*CanaryAnalysisStage) GetName added in v1.5.0 

func (s *CanaryAnalysisStage) GetName() string

GetName for Stage interface

func (*CanaryAnalysisStage) GetRefID added in v1.5.0 

func (s *CanaryAnalysisStage) GetRefID() string

GetRefID for Stage interface

func (*CanaryAnalysisStage) GetType added in v1.5.0 

func (s *CanaryAnalysisStage) GetType() StageType

GetType for Stage interface

type CanaryConfig added in v1.5.0 

type CanaryConfig struct {
	Id            string                  `json:"id,omitempty"`
	Name          string                  `json:"name"`
	Applications  []string                `json:"applications"`
	Description   string                  `json:"description"`
	Metrics       []*CanaryConfigMetric   `json:"metrics"`
	ConfigVersion string                  `json:"configVersion"`
	Templates     map[string]interface{}  `json:"templates"`
	Classifier    *CanaryConfigClassifier `json:"classifier"`
	Judge         *CanaryConfigJudge      `json:"judge"`
}

func NewCanaryConfig added in v1.5.0 

func NewCanaryConfig(judge *CanaryConfigJudge, name string, application string) *CanaryConfig

func (*CanaryConfig) AddGroup added in v1.5.0 

func (config *CanaryConfig) AddGroup(group string, weight float64)

func (*CanaryConfig) AddMetric added in v1.5.0 

func (config *CanaryConfig) AddMetric(metric *CanaryConfigMetric)

type CanaryConfigClassifier added in v1.5.0 

type CanaryConfigClassifier struct {
	GroupWeights map[string]float64 `json:"groupWeights"`
}

func NewCanaryConfigClassifier added in v1.5.0 

func NewCanaryConfigClassifier() *CanaryConfigClassifier

type CanaryConfigJudge added in v1.5.0 

type CanaryConfigJudge struct {
	Name                string                 `json:"name"`
	JudgeConfigurations map[string]interface{} `json:"judgeConfigurations"`
}

func NewCanaryConfigJudge added in v1.5.0 

func NewCanaryConfigJudge(name string) *CanaryConfigJudge

type CanaryConfigMetric added in v1.5.0 

type CanaryConfigMetric struct {
	// AnalysisConfigurations interface `json:"analysisConfigurations"`
	Name      string                   `json:"name"`
	Query     *CanaryConfigMetricQuery `json:"query"`
	Groups    []string                 `json:"groups"`
	ScopeName string                   `json:"scopeName"`
}

func NewCanaryConfigMetric added in v1.5.0 

func NewCanaryConfigMetric(
	group string, name string, metricQuery *CanaryConfigMetricQuery,
) *CanaryConfigMetric

type CanaryConfigMetricQuery added in v1.5.0 

type CanaryConfigMetricQuery struct {
	Type        string `json:"type"`
	ServiceType string `json:"serviceType"`
	MetricName  string `json:"metricName"`
}

func NewCanaryConfigMetricQuery added in v1.5.0 

func NewCanaryConfigMetricQuery(metric string, serviceType string, metricType string) *CanaryConfigMetricQuery

type CanaryConfigService added in v1.5.0 

type CanaryConfigService struct {
	*Client
}

func (*CanaryConfigService) CreateCanaryConfig added in v1.5.0 

func (service *CanaryConfigService) CreateCanaryConfig(config *CanaryConfig) (configId string, err error)

CreateApplication create an application

func (*CanaryConfigService) DeleteCanaryConfig added in v1.5.0 

func (service *CanaryConfigService) DeleteCanaryConfig(configId string) error

func (*CanaryConfigService) GetCanaryConfig added in v1.5.0 

func (service *CanaryConfigService) GetCanaryConfig(id string) (*CanaryConfig, error)

func (*CanaryConfigService) GetCanaryConfigs added in v1.5.0 

func (service *CanaryConfigService) GetCanaryConfigs() (*[]*CanaryConfig, error)

func (*CanaryConfigService) UpdateCanaryConfig added in v1.5.0 

func (service *CanaryConfigService) UpdateCanaryConfig(config *CanaryConfig) error

type Capacity 

type Capacity struct {
	Desired string `json:"desired"`
	Max     string `json:"max"`
	Min     string `json:"min"`
}

Capacity capacity for cluster

type Client 

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

Client to talk to Spinnaker

func NewClient 

func NewClient(config *Config) *Client

NewClient Return a new client with loaded configuration

func (*Client) Do 

func (client *Client) Do(req *http.Request) (*http.Response, error)

Do send http request

func (*Client) DoWithResponse 

func (client *Client) DoWithResponse(req *http.Request, v interface{}) (*http.Response, error)

DoWithResponse send http request and parse response body

func (*Client) DoWithRetry 

func (client *Client) DoWithRetry(retryOnStatus int, maxAttempts int, createReq func() (*http.Request, error)) (*http.Response, error)

DoWithRetry send http request with retry

func (*Client) NewRequest 

func (client *Client) NewRequest(method string, path string) (*http.Request, error)

NewRequest create http request

func (*Client) NewRequestWithBody 

func (client *Client) NewRequestWithBody(method string, path string, data interface{}) (*http.Request, error)

NewRequestWithBody create http request with data as body

type Config 

type Config struct {
	Address string
	Auth    *Auth
}

Config for Client

func NewConfig added in v1.2.0 

func NewConfig() *Config

type CreateCanaryConfigResponse added in v1.5.0 

type CreateCanaryConfigResponse struct {
	CanaryConfigId string `json:"canaryConfigId"`
}

type CreatePipelineRequest 

type CreatePipelineRequest struct {
	Application string `json:"application"`
	Name        string `json:"name"`
}

CreatePipelineRequest used to create pipeline

type DataSources added in v1.3.0 

type DataSources struct {
	Disabled *[]string `json:"disabled"`
	Enabled  *[]string `json:"enabled"`
}

type DeleteManifestMode added in v1.2.0 

type DeleteManifestMode int
const (
	DeleteManifestModeUnknown DeleteManifestMode = iota
	DeleteManifestModeStatic
)

func ParseDeleteManifestMode added in v1.2.0 

func ParseDeleteManifestMode(s string) (DeleteManifestMode, error)

func (DeleteManifestMode) MarshalText added in v1.2.0 

func (m DeleteManifestMode) MarshalText() ([]byte, error)

func (DeleteManifestMode) String added in v1.2.0 

func (t DeleteManifestMode) String() string

func (*DeleteManifestMode) UnmarshalText added in v1.2.0 

func (m *DeleteManifestMode) UnmarshalText(text []byte) error

type DeleteManifestOptions added in v1.2.0 

type DeleteManifestOptions struct {
	Cascading bool `json:"cascading"`
}

func NewDeleteManifestOptions added in v1.2.0 

func NewDeleteManifestOptions() *DeleteManifestOptions

type DeleteManifestStage added in v1.2.0 

type DeleteManifestStage struct {
	// BaseStage
	Name                              string                `json:"name"`
	RefID                             string                `json:"refId"`
	Type                              StageType             `json:"type"`
	RequisiteStageRefIds              []string              `json:"requisiteStageRefIds"`
	SendNotifications                 bool                  `json:"sendNotifications"`
	StageEnabled                      *StageEnabled         `json:"stageEnabled"`
	CompleteOtherBranchesThenFail     bool                  `json:"completeOtherBranchesThenFail"`
	ContinuePipeline                  bool                  `json:"continuePipeline"`
	FailOnFailedExpressions           bool                  `json:"failOnFailedExpressions"`
	FailPipeline                      bool                  `json:"failPipeline"`
	OverrideTimeout                   bool                  `json:"overrideTimeout"`
	RestrictExecutionDuringTimeWindow bool                  `json:"restrictExecutionDuringTimeWindow"`
	RestrictedExecutionWindow         *StageExecutionWindow `json:"restrictedExecutionWindow"`
	Notifications                     *[]*Notification      `json:"notifications"`

	Account       string                 `json:"account"`
	App           string                 `json:"app"`
	CloudProvider string                 `json:"cloudProvider"`
	Location      string                 `json:"location"`
	ManifestName  string                 `json:"manifestName"`
	Mode          DeleteManifestMode     `json:"mode"`
	Options       *DeleteManifestOptions `json:"options"`
}

func NewDeleteManifestStage added in v1.2.0 

func NewDeleteManifestStage() *DeleteManifestStage

func (*DeleteManifestStage) GetName added in v1.2.0 

func (s *DeleteManifestStage) GetName() string

GetName for Stage interface

func (*DeleteManifestStage) GetRefID added in v1.2.0 

func (s *DeleteManifestStage) GetRefID() string

GetRefID for Stage interface

func (*DeleteManifestStage) GetType added in v1.2.0 

func (s *DeleteManifestStage) GetType() StageType

GetType for Stage interface

type DeployManifestSource added in v1.2.0 

type DeployManifestSource int
const (
	DeployManifestSourceUnknown DeployManifestSource = iota
	DeployManifestSourceText
)

func ParseDeployManifestSource added in v1.2.0 

func ParseDeployManifestSource(s string) (DeployManifestSource, error)

func (DeployManifestSource) MarshalText added in v1.2.0 

func (t DeployManifestSource) MarshalText() ([]byte, error)

func (DeployManifestSource) String added in v1.2.0 

func (t DeployManifestSource) String() string

func (*DeployManifestSource) UnmarshalText added in v1.2.0 

func (t *DeployManifestSource) UnmarshalText(text []byte) error

type DeployManifestStage added in v1.2.0 

type DeployManifestStage struct {
	// BaseStage
	Name                              string                `json:"name"`
	RefID                             string                `json:"refId"`
	Type                              StageType             `json:"type"`
	RequisiteStageRefIds              []string              `json:"requisiteStageRefIds"`
	SendNotifications                 bool                  `json:"sendNotifications"`
	StageEnabled                      *StageEnabled         `json:"stageEnabled"`
	CompleteOtherBranchesThenFail     bool                  `json:"completeOtherBranchesThenFail"`
	ContinuePipeline                  bool                  `json:"continuePipeline"`
	FailOnFailedExpressions           bool                  `json:"failOnFailedExpressions"`
	FailPipeline                      bool                  `json:"failPipeline"`
	OverrideTimeout                   bool                  `json:"overrideTimeout"`
	RestrictExecutionDuringTimeWindow bool                  `json:"restrictExecutionDuringTimeWindow"`
	RestrictedExecutionWindow         *StageExecutionWindow `json:"restrictedExecutionWindow"`
	Notifications                     *[]*Notification      `json:"notifications"`

	Account                  string               `json:"account"`
	CloudProvider            string               `json:"cloudProvider"`
	ManifestArtifactAccount  string               `json:"manifestArtifactAccount"`
	Manifests                *DeployManifests     `json:"manifests"`
	Moniker                  *Moniker             `json:"moniker"`
	Relationships            *Relationships       `json:"relationships"`
	SkipExpressionEvaluation bool                 `json:"skipExpressionEvaluation"`
	Source                   DeployManifestSource `json:"source"`
	TrafficManagement        *TrafficManagement   `json:"trafficManagement"`
}

func NewDeployManifestStage added in v1.2.0 

func NewDeployManifestStage() *DeployManifestStage

func (*DeployManifestStage) GetName added in v1.2.0 

func (s *DeployManifestStage) GetName() string

GetName for Stage interface

func (*DeployManifestStage) GetRefID added in v1.2.0 

func (s *DeployManifestStage) GetRefID() string

GetRefID for Stage interface

func (*DeployManifestStage) GetType added in v1.2.0 

func (s *DeployManifestStage) GetType() StageType

GetType for Stage interface

type DeployManifests added in v1.2.0 

type DeployManifests []string

func NewDeployManifests added in v1.2.0 

func NewDeployManifests() *DeployManifests

func ParseDeployManifests added in v1.2.0 

func ParseDeployManifests(manifestInterface []interface{}) (*DeployManifests, error)

func (DeployManifests) MarshalJSON added in v1.2.0 

func (s DeployManifests) MarshalJSON() ([]byte, error)

type DeployStage 

type DeployStage struct {
	Notifications *[]*Notification `json:"notifications"`
	// contains filtered or unexported fields
}

DeployStage for pipeline

func NewDeployStage 

func NewDeployStage() *DeployStage

NewDeployStage for pipeline

func (*DeployStage) GetName 

func (s *DeployStage) GetName() string

GetName for Stage interface

func (*DeployStage) GetRefID 

func (s *DeployStage) GetRefID() string

GetRefID for Stage interface

func (*DeployStage) GetType 

func (s *DeployStage) GetType() StageType

GetType for Stage interface

type DeployStageCluster 

type DeployStageCluster struct {
	Account                             string                 `json:"account"`
	Application                         string                 `json:"application"`
	AvailabilityZones                   map[string][]string    `json:"availabilityZones"`
	Capacity                            *Capacity              `json:"capacity"`
	CloudProvider                       string                 `json:"cloudProvider"`
	Cooldown                            int                    `json:"cooldown"`
	CopySourceCustomBlockDeviceMappings bool                   `json:"copySourceCustomBlockDeviceMappings"`
	DelayBeforeDisableSec               int                    `json:"delayBeforeDisableSec"`
	DelayBeforeScaleDownSec             int                    `json:"delayBeforeScaleDownSec"`
	Dirty                               map[string]interface{} `json:"dirty"`
	EBSOptimized                        bool                   `json:"ebsOptimized"`
	EnabledMetrics                      []string               `json:"enabledMetrics"`
	FreeFormDetails                     string                 `json:"freeFormDetails"`
	HealthCheckGracePeriod              string                 `json:"healthCheckGracePeriod"`
	HealthCheckType                     string                 `json:"healthCheckType"`
	IAMRole                             string                 `json:"iamRole"`
	InstanceMonitoring                  bool                   `json:"instanceMonitoring"`
	InstanceType                        string                 `json:"instanceType"`
	KeyPair                             string                 `json:"keyPair"`
	LoadBalancers                       []string               `json:"loadBalancers"`
	MaxRemainingAsgs                    int                    `json:"maxRemainingAsgs"`
	Moniker                             *Moniker               `json:"moniker"`
	Provider                            string                 `json:"provider"`
	Rollback                            *Rollback              `json:"rollback"`
	ScaleDown                           bool                   `json:"scaleDown"`
	SecurityGroups                      interface{}            `json:"securityGroups"`
	SpelLoadBalancers                   []string               `json:"spelLoadBalancers"`
	SpelTargetGroups                    []string               `json:"spelTargetGroups"`
	SpotPrice                           string                 `json:"spotPrice"`
	Stack                               string                 `json:"stack"`
	Strategy                            string                 `json:"strategy"`
	SubnetType                          string                 `json:"subnetType"`
	SuspendedProcesses                  []string               `json:"suspendedProcesses"`
	Tags                                map[string]string      `json:"tags"`
	TargetGroups                        []string               `json:"targetGroups"`
	TargetHealthyDeployPercentage       int                    `json:"targetHealthyDeployPercentage"`
	TerminationPolicies                 []string               `json:"terminationPolicies"`
	UseAmiBlockDeviceMappings           bool                   `json:"useAmiBlockDeviceMappings"`
	UseSourceCapacity                   bool                   `json:"useSourceCapacity"`
	UserData                            string                 `json:"base64UserData"`
}

TODO rename to more generic DeployStageCluster cluster to deploy

func NewDeployStageCluster 

func NewDeployStageCluster() *DeployStageCluster

type DestroyServerGroupStage 

type DestroyServerGroupStage struct {
	Notifications *[]*Notification `json:"notifications"`
	// contains filtered or unexported fields
}

DestroyServerGroupStage for pipeline

func NewDestroyServerGroupStage 

func NewDestroyServerGroupStage() *DestroyServerGroupStage

NewDestroyServerGroupStage for pipeline

func (*DestroyServerGroupStage) GetName 

func (s *DestroyServerGroupStage) GetName() string

GetName for Stage interface

func (*DestroyServerGroupStage) GetRefID 

func (s *DestroyServerGroupStage) GetRefID() string

GetRefID for Stage interface

func (*DestroyServerGroupStage) GetType 

func (s *DestroyServerGroupStage) GetType() StageType

GetType for Stage interface

type FindImageFromTagsStage added in v1.3.0 

type FindImageFromTagsStage struct {
	Notifications *[]*Notification `json:"notifications"`
	// contains filtered or unexported fields
}

FindImageFromTagsStage for pipeline

func NewFindImageStage added in v1.3.0 

func NewFindImageStage() *FindImageFromTagsStage

NewFindImageStage for pipeline

func (*FindImageFromTagsStage) GetName added in v1.3.0 

func (s *FindImageFromTagsStage) GetName() string

GetName for Stage interface

func (*FindImageFromTagsStage) GetRefID added in v1.3.0 

func (s *FindImageFromTagsStage) GetRefID() string

GetRefID for Stage interface

func (*FindImageFromTagsStage) GetType added in v1.3.0 

func (s *FindImageFromTagsStage) GetType() StageType

GetType for Stage interface

type JenkinsStage 

type JenkinsStage struct {
	Notifications *[]*Notification `json:"notifications"`
	// contains filtered or unexported fields
}

JenkinsStage for pipeline

func NewJenkinsStage 

func NewJenkinsStage() *JenkinsStage

NewJenkinsStage for pipeline

func (*JenkinsStage) GetName 

func (s *JenkinsStage) GetName() string

GetName for Stage interface

func (*JenkinsStage) GetRefID 

func (s *JenkinsStage) GetRefID() string

GetRefID for Stage interface

func (*JenkinsStage) GetType 

func (s *JenkinsStage) GetType() StageType

GetType for Stage interface

type Job 

type Job struct {
	Type        string       `json:"type"`
	Application *Application `json:"application"`
	User        string       `json:"user"`
}

Job a job to run

type JudgmentInputs added in v1.3.0 

type JudgmentInputs struct {
	Value string `json:"value"`
}

JudgmentInputs inputs for judgment

type ManualJudgmentStage added in v1.3.0 

type ManualJudgmentStage struct {
	Notifications *[]*Notification `json:"notifications"`
	// contains filtered or unexported fields
}

ManualJudgmentStage for pipeline

func NewManualJudgmentStage added in v1.3.0 

func NewManualJudgmentStage() *ManualJudgmentStage

NewManualJudgmentStage for pipeline

func (*ManualJudgmentStage) GetName added in v1.3.0 

func (s *ManualJudgmentStage) GetName() string

GetName for Stage interface

func (*ManualJudgmentStage) GetRefID added in v1.3.0 

func (s *ManualJudgmentStage) GetRefID() string

GetRefID for Stage interface

func (*ManualJudgmentStage) GetType added in v1.3.0 

func (s *ManualJudgmentStage) GetType() StageType

GetType for Stage interface

type Message 

type Message interface {
	SetCompleteText(string)
	CompleteText() string

	SetFailedText(string)
	FailedText() string

	SetStartingText(string)
	StartingText() string
}

Message for Notification

func NewMessage 

func NewMessage(level NotificationLevel) (Message, error)

NewMessage new message

type MessageText 

type MessageText struct {
	Text string `json:"text"`
}

MessageText for Pipeline Notification

type Moniker 

type Moniker struct {
	App      string `json:"app,omitempty"`
	Cluster  string `json:"cluster,omitempty"`
	Detail   string `json:"detail,omitempty"`
	Stack    string `json:"stack,omitempty"`
	Sequence string `json:"sequence,omitempty"`
}

Moniker for cluster

type Notification 

type Notification struct {
	SerializableNotification
	Message Message `json:"message"`
}

Notification for pipeline

type NotificationLevel 

type NotificationLevel string

NotificationLevel level of notification 

const NotificationLevelPipeline NotificationLevel = "pipeline"

NotificationLevelPipeline pipeline level notifaction 

const NotificationLevelStage NotificationLevel = "stage"

NotificationLevelStage stage level notifaction

type Pipeline 

type Pipeline struct {
	SerializablePipeline

	Notifications *[]*Notification `json:"notifications"`
	Stages        *[]Stage         `json:"stages"`
}

Pipeline deploy pipeline in application

func NewPipeline 

func NewPipeline() *Pipeline

NewPipeline Pipeline with default values

func (*Pipeline) AppendNotification 

func (pipeline *Pipeline) AppendNotification(notification *Notification)

AppendNotification append notification

func (*Pipeline) AppendParameter 

func (p *Pipeline) AppendParameter(parameter *PipelineParameter)

AppendParameter append parameter

func (*Pipeline) AppendStage 

func (pipeline *Pipeline) AppendStage(stage Stage)

AppendStage append stage

func (*Pipeline) AppendTrigger 

func (pipeline *Pipeline) AppendTrigger(trigger *Trigger)

AppendTrigger append trigger

func (*Pipeline) DeleteNotification 

func (pipeline *Pipeline) DeleteNotification(notificationID string) error

DeleteNotification delete notification

func (*Pipeline) DeleteParameter 

func (p *Pipeline) DeleteParameter(parameterID string) error

DeleteParameter in pipeline

func (*Pipeline) DeleteStage 

func (pipeline *Pipeline) DeleteStage(stageID string) error

DeleteStage delete stage

func (*Pipeline) DeleteTrigger 

func (p *Pipeline) DeleteTrigger(triggerID string) error

DeleteTrigger in pipeline

func (*Pipeline) GetNotification 

func (pipeline *Pipeline) GetNotification(notificationID string) (*Notification, error)

GetNotification Get notification by id

func (*Pipeline) GetParameter 

func (p *Pipeline) GetParameter(parameterID string) (*PipelineParameter, error)

GetParameter by ID

func (*Pipeline) GetStage 

func (pipeline *Pipeline) GetStage(stageID string) (Stage, error)

GetStage get stage

func (*Pipeline) GetTrigger 

func (p *Pipeline) GetTrigger(triggerID string) (*Trigger, error)

GetTrigger by ID

func (*Pipeline) UpdateNotification 

func (pipeline *Pipeline) UpdateNotification(notification *Notification) error

UpdateNotification update notification

func (*Pipeline) UpdateParameter 

func (p *Pipeline) UpdateParameter(parameter *PipelineParameter) error

UpdateParameter in pipeline

func (*Pipeline) UpdateStage 

func (pipeline *Pipeline) UpdateStage(stage Stage) error

UpdateStage update stage

func (*Pipeline) UpdateTrigger 

func (p *Pipeline) UpdateTrigger(trigger *Trigger) error

UpdateTrigger in pipeline

type PipelineMessage 

type PipelineMessage struct {
	Complete *MessageText `json:"pipeline.complete" mapstructure:"pipeline.complete"`
	Failed   *MessageText `json:"pipeline.failed" mapstructure:"pipeline.failed"`
	Starting *MessageText `json:"pipeline.starting" mapstructure:"pipeline.starting"`
}

PipelineMessage for Pipeline Notification

func (*PipelineMessage) CompleteText 

func (m *PipelineMessage) CompleteText() string

CompleteText for Message interface

func (*PipelineMessage) FailedText 

func (m *PipelineMessage) FailedText() string

FailedText for Message interface

func (*PipelineMessage) SetCompleteText 

func (m *PipelineMessage) SetCompleteText(text string)

SetCompleteText for Message interface

func (*PipelineMessage) SetFailedText 

func (m *PipelineMessage) SetFailedText(text string)

SetFailedText for Message interface

func (*PipelineMessage) SetStartingText 

func (m *PipelineMessage) SetStartingText(text string)

SetStartingText for Message interface

func (*PipelineMessage) StartingText 

func (m *PipelineMessage) StartingText() string

StartingText for Message interface

type PipelineParameter 

type PipelineParameter struct {
	ID          string                      `json:"id"`
	Default     string                      `json:"default"`
	Description string                      `json:"description"`
	HasOptions  bool                        `json:"hasOptions"`
	Label       string                      `json:"label"`
	Name        string                      `json:"name"`
	Options     *[]*PipelineParameterOption `json:"options"`
	Required    bool                        `json:"required"`
}

type PipelineParameterOption 

type PipelineParameterOption struct {
	Value string `json:"value"`
}

type PipelineService 

type PipelineService struct {
	*Client
}

PipelineService used to manage pipelines

func (*PipelineService) CreatePipeline 

func (service *PipelineService) CreatePipeline(pipeline *CreatePipelineRequest) error

CreatePipeline in application

func (*PipelineService) DeletePipeline 

func (service *PipelineService) DeletePipeline(pipeline *Pipeline) error

DeletePipeline in application

func (*PipelineService) GetApplicationPipelines 

func (service *PipelineService) GetApplicationPipelines(applicationName string) (*[]*Pipeline, error)

GetApplicationPipelines get all pipelines for an application

func (*PipelineService) GetPipeline 

func (service *PipelineService) GetPipeline(applicationName string, pipelineName string) (*Pipeline, error)

GetPipeline get pipeline by name and application

func (*PipelineService) GetPipelineByID 

func (service *PipelineService) GetPipelineByID(id string) (*Pipeline, error)

GetPipelineByID get pipeline by id

func (*PipelineService) UpdatePipeline 

func (service *PipelineService) UpdatePipeline(pipeline *Pipeline) error

UpdatePipeline in application

type PipelineStage 

type PipelineStage struct {
	Notifications *[]*Notification `json:"notifications"`
	// contains filtered or unexported fields
}

PipelineStage for pipeline

func NewPipelineStage 

func NewPipelineStage() *PipelineStage

NewPipelineStage for pipeline

func (*PipelineStage) GetName 

func (s *PipelineStage) GetName() string

GetName for Stage interface

func (*PipelineStage) GetRefID 

func (s *PipelineStage) GetRefID() string

GetRefID for Stage interface

func (*PipelineStage) GetType 

func (s *PipelineStage) GetType() StageType

GetType for Stage interface

type ProviderSettings 

type ProviderSettings struct {
	AWS *AwsProviderSettings `json:"aws"`
}

ProviderSettings Settings for Provider

type Relationships added in v1.2.0 

type Relationships struct {
	LoadBalancers  *[]string `json:"loadBalancers"`
	SecurityGroups *[]string `json:"securityGroups"`
}

func NewRelationships added in v1.2.0 

func NewRelationships() *Relationships

type ResizeServerGroupStage 

type ResizeServerGroupStage struct {
	Notifications *[]*Notification `json:"notifications"`
	// contains filtered or unexported fields
}

ResizeServerGroupStage for pipeline

func NewResizeServerGroupStage 

func NewResizeServerGroupStage() *ResizeServerGroupStage

NewResizeServerGroupStage for pipeline

func (*ResizeServerGroupStage) GetName 

func (s *ResizeServerGroupStage) GetName() string

GetName for Stage interface

func (*ResizeServerGroupStage) GetRefID 

func (s *ResizeServerGroupStage) GetRefID() string

GetRefID for Stage interface

func (*ResizeServerGroupStage) GetType 

func (s *ResizeServerGroupStage) GetType() StageType

GetType for Stage interface

type Rollback 

type Rollback struct {
	OnFailure bool `json:"onFailure"`
}

func NewRollback 

func NewRollback() *Rollback

type RollbackClusterStage 

type RollbackClusterStage struct {
	Notifications *[]*Notification `json:"notifications"`
	// contains filtered or unexported fields
}

RollbackClusterStage for pipeline

func NewRollbackClusterStage 

func NewRollbackClusterStage() *RollbackClusterStage

NewRollbackClusterStage for pipeline

func (*RollbackClusterStage) GetName 

func (s *RollbackClusterStage) GetName() string

GetName for Stage interface

func (*RollbackClusterStage) GetRefID 

func (s *RollbackClusterStage) GetRefID() string

GetRefID for Stage interface

func (*RollbackClusterStage) GetType 

func (s *RollbackClusterStage) GetType() StageType

GetType for Stage interface

type SerializableNotification 

type SerializableNotification struct {
	ID      string            `json:"id,omitempty"`
	Address string            `json:"address"`
	Level   NotificationLevel `json:"level"`
	Type    string            `json:"type"`
	When    []string          `json:"when"`
}

SerializableNotification for pipeline

type SerializablePipeline 

type SerializablePipeline struct {
	Application          string                 `json:"application"`
	AppConfig            map[string]interface{} `json:"appConfig"`
	Disabled             bool                   `json:"disabled"`
	ID                   string                 `json:"id"`
	Index                int                    `json:"index"`
	KeepWaitingPipelines bool                   `json:"keepWaitingPipelines"`
	LimitConcurrent      bool                   `json:"limitConcurrent"`
	Name                 string                 `json:"name"`
	ParameterConfig      *[]*PipelineParameter  `json:"parameterConfig"`
	Roles                *[]string              `json:"roles"`
	ServiceAccount       string                 `json:"serviceAccount,omitempty"`
	Triggers             []*Trigger             `json:"triggers"`
}

SerializablePipeline deploy pipeline in application

func NewSerializablePipeline 

func NewSerializablePipeline() SerializablePipeline

NewSerializablePipeline Pipeline with default values

type SpinnakerError 

type SpinnakerError struct {
	ErrorMsg  string `json:"error"`
	Exception string `json:"exception"`
	Message   string `json:"message"`
	Status    int    `json:"status"`
	Timestamp string `json:"timestamp"`
	Body      string `json:"body"`
}

SpinnakerError Error response from spinnaker

func (*SpinnakerError) Error 

func (r *SpinnakerError) Error() string

For error interface

func (*SpinnakerError) UnmarshalJSON added in v1.2.0 

func (e *SpinnakerError) UnmarshalJSON(bytes []byte) error

type Stage 

type Stage interface {
	GetName() string
	GetRefID() string
	GetType() StageType
}

Stage interface for Pipeline stages

type StageEnabled 

type StageEnabled struct {
	Expression string `json:"expression"`
	Type       string `json:"type"`
}

StageEnabled when stage is enabled

type StageExecutionWindow 

type StageExecutionWindow struct {
	Days      []int                             `json:"days"`
	Jitter    *StageExecutionWindowJitter       `json:"jitter"`
	Whitelist *[]*StageExecutionWindowWhitelist `json:"whitelist"`
}

StageExecutionWindow when to execute pipeline stage

type StageExecutionWindowJitter 

type StageExecutionWindowJitter struct {
	Enabled    bool `json:"enabled"`
	MaxDelay   int  `json:"maxDelay"`
	MinDelay   int  `json:"minDelay"`
	SkipManual bool `json:"skipManual"`
}

StageExecutionWindowJitter random jitter to add to execution window

type StageExecutionWindowWhitelist 

type StageExecutionWindowWhitelist struct {
	EndHour   int `json:"endHour"`
	EndMin    int `json:"endMin"`
	StartHour int `json:"startHour"`
	StartMin  int `json:"startMin"`
}

StageExecutionWindowWhitelist which hours to deploy

type StageMessage 

type StageMessage struct {
	Complete *MessageText `json:"stage.complete" mapstructure:"stage.complete"`
	Failed   *MessageText `json:"stage.failed" mapstructure:"stage.failed"`
	Starting *MessageText `json:"stage.starting" mapstructure:"stage.starting"`
}

StageMessage for Stage Notification

func (*StageMessage) CompleteText 

func (m *StageMessage) CompleteText() string

CompleteText for Message interface

func (*StageMessage) FailedText 

func (m *StageMessage) FailedText() string

FailedText for Message interface

func (*StageMessage) SetCompleteText 

func (m *StageMessage) SetCompleteText(text string)

SetCompleteText for Message interface

func (*StageMessage) SetFailedText 

func (m *StageMessage) SetFailedText(text string)

SetFailedText for Message interface

func (*StageMessage) SetStartingText 

func (m *StageMessage) SetStartingText(text string)

SetStartingText for Message interface

func (*StageMessage) StartingText 

func (m *StageMessage) StartingText() string

StartingText for Message interface

type StageType 

type StageType string

StageType type of stage 

var BakeStageType StageType = "bake"

BakeStageType bake stage 

var CanaryAnalysisStageType StageType = "kayentaCanary"
var DeleteManifestStageType StageType = "deleteManifest"

DeleteManifestStageType delete manifest stage 

var DeployManifestStageType StageType = "deployManifest"

DeployManifestStageType deploy manifest stage 

var DeployStageType StageType = "deploy"

DeployStageType deploy stage 

var DestroyServerGroupStageType StageType = "destroyServerGroup"

DestroyServerGroupStageType destroy server group stage 

var FindImageFromTagsStageType StageType = "findImageFromTags"

FindImageFromTagsStageType bake stage 

var JenkinsStageType StageType = "jenkins"

JenkinsStageType jenkins stage 

var ManualJudgmentStageType StageType = "manualJudgment"

ManualJudgmentStageType deploy stage 

var PipelineStageType StageType = "pipeline"

PipelineStageType pipeline stage 

var ResizeServerGroupStageType StageType = "resizeServerGroup"

ResizeServerGroupStageType resize server group stage 

var RollbackClusterStageType StageType = "rollbackCluster"

RollbackClusterStageType rollback cluster stage 

var WebhookStageType StageType = "webhook"

WebhookStageType bake stage

func (StageType) String 

func (st StageType) String() string

type Task 

type Task struct {
	Job         *[]*Job `json:"job"`
	Application string  `json:"application"`
	Description string  `json:"description"`
}

Task a job within an application

type TaskExecution added in v1.3.0 

type TaskExecution struct {
	ID          string `json:"id"`
	Name        string `json:"name"`
	Application string `json:"application"`
	StartTime   int    `json:"startTime"`
	EndTime     int    `json:"endTime"`
	BuildTime   int    `json:"buildTime"`
	Status      string `json:"status"`
}

TaskExecution get status of task

type TaskResponse added in v1.3.0 

type TaskResponse struct {
	Ref string `json:"ref"`
}

TaskResponse ref for task execution

type TrafficManagement added in v1.2.0 

type TrafficManagement struct {
	Enabled bool                      `json:"enabled"`
	Options *TrafficManagementOptions `json:"options"`
}

func NewTrafficManagement added in v1.2.0 

func NewTrafficManagement() *TrafficManagement

type TrafficManagementOptions added in v1.2.0 

type TrafficManagementOptions struct {
	EnableTraffic bool `json:"enableTraffic"`
}

func NewTrafficManagementOptions added in v1.2.0 

func NewTrafficManagementOptions() *TrafficManagementOptions

type Trigger 

type Trigger struct {
	ID           string `json:"id"`
	Enabled      bool   `json:"enabled"`
	Job          string `json:"job"`
	Master       string `json:"master"`
	PropertyFile string `json:"propertyFile"`
	RunAsUser    string `json:"runAsUser,omitempty"`
	Type         string `json:"type"`
}

Trigger for Pipeline

type WebhookStage added in v1.3.0 

type WebhookStage struct {
	Notifications *[]*Notification `json:"notifications"`
	// contains filtered or unexported fields
}

WebhookStage for pipeline

func NewWebhookStage added in v1.3.0 

func NewWebhookStage() *WebhookStage

NewWebhookStage for pipeline

func (*WebhookStage) GetName added in v1.3.0 

func (s *WebhookStage) GetName() string

GetName for Stage interface

func (*WebhookStage) GetRefID added in v1.3.0 

func (s *WebhookStage) GetRefID() string

GetRefID for Stage interface

func (*WebhookStage) GetType added in v1.3.0 

func (s *WebhookStage) GetType() StageType

GetType for Stage interface

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.