client

package
v1.8.0 Latest Latest
Warning

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

Go to latest
Published: Dec 9, 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 ErrInvalidNotificationLevel = errors.New("Invalid notification level")

ErrInvalidNotificationLevel 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"`

	Permissions                    *ApplicationPermissions `json:"permissions"`
	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 ApplicationPermissions added in v1.7.0

type ApplicationPermissions struct {
	Execute []string `json:"EXECUTE"`
	Read    []string `json:"READ"`
	Write   []string `json:"WRITE"`
}

func NewApplicationPermissions added in v1.7.0

func NewApplicationPermissions() *ApplicationPermissions

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 {
	BaseStage `mapstructure:",squash"`

	AmiName            string            `json:"amiName"`
	AmiSuffix          string            `json:"amiSuffix,omitempty"`
	BaseAMI            string            `json:"baseAmi,omitempty"`
	BaseLabel          string            `json:"baseLabel"`
	BaseName           string            `json:"baseName,omitempty"`
	BaseOS             string            `json:"baseOs"`
	CloudProviderType  string            `json:"cloudProviderType"`
	ExtendedAttributes map[string]string `json:"extendedAttributes"`
	Package            string            `json:"package"`
	Rebake             bool              `json:"rebake"`
	Region             string            `json:"region"`
	Regions            []string          `json:"regions,omitempty"`
	StoreType          string            `json:"storeType"`
	TemplateFileName   string            `json:"templateFileName"`
	User               string            `json:"user,omitempty"`
	VarFileName        string            `json:"varFileName,omitempty"`
	VMType             string            `json:"vmType"`
}

BakeStage for pipeline

func NewBakeStage

func NewBakeStage() *BakeStage

NewBakeStage for pipeline

type BasePrecondition added in v1.7.0

type BasePrecondition struct {
	FailPipeline bool             `json:"failPipeline"`
	Type         PreconditionType `json:"type"`
}

func NewBasePrecondition added in v1.7.0

func NewBasePrecondition(t PreconditionType) *BasePrecondition

func (*BasePrecondition) GetType added in v1.7.0

func (p *BasePrecondition) GetType() PreconditionType

type BaseStage added in v1.7.0

type BaseStage struct {
	Name                 string        `json:"name"`
	RefID                string        `json:"refId"`
	Type                 StageType     `json:"type"`
	RequisiteStageRefIds []string      `json:"requisiteStageRefIds"`
	SendNotifications    bool          `json:"sendNotifications"`
	StageEnabled         *StageEnabled `json:"stageEnabled"`
	Comments             string        `json:"comments,omitempty"`

	CompleteOtherBranchesThenFail     bool `json:"completeOtherBranchesThenFail"`
	ContinuePipeline                  bool `json:"continuePipeline"`
	FailOnFailedExpressions           bool `json:"failOnFailedExpressions"`
	FailPipeline                      bool `json:"failPipeline"`
	OverrideTimeout                   bool `json:"overrideTimeout"`
	StageTimeoutMS                    int  `json:"stageTimeoutMs,omitempty"`
	RestrictExecutionDuringTimeWindow bool `json:"restrictExecutionDuringTimeWindow"`

	RestrictedExecutionWindow *StageExecutionWindow `json:"restrictedExecutionWindow"`
	Notifications             *[]*Notification      `json:"notifications"`
}

BaseStage all stages should have these properties

func (*BaseStage) GetName added in v1.7.0

func (s *BaseStage) GetName() string

GetName for Stage interface

func (*BaseStage) GetRefID added in v1.7.0

func (s *BaseStage) GetRefID() string

GetRefID for Stage interface

func (*BaseStage) GetType added in v1.7.0

func (s *BaseStage) 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 `mapstructure:",squash"`

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

func NewCanaryAnalysisStage added in v1.5.0

func NewCanaryAnalysisStage() *CanaryAnalysisStage

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)

CreateCanaryConfig create an canary config

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 CheckPreconditionsStage added in v1.7.0

type CheckPreconditionsStage struct {
	BaseStage `mapstructure:",squash"`

	Preconditions []Precondition `json:"preconditions"`
}

func NewCheckPreconditionsStage added in v1.7.0

func NewCheckPreconditionsStage() *CheckPreconditionsStage

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 `mapstructure:",squash"`

	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

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 `mapstructure:",squash"`

	Account                  string               `json:"account"`
	NamespaceOverride        string               `json:"namespaceOverride,omitempty"`
	CloudProvider            string               `json:"cloudProvider"`
	ManifestArtifactAccount  string               `json:"manifestArtifactAccount"`
	Manifests                *Manifests           `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

type DeployStage

type DeployStage struct {
	BaseStage `mapstructure:",squash"`

	Clusters *[]*DeploymentCluster `json:"clusters"`
}

DeployStage for pipeline

func NewDeployStage

func NewDeployStage() *DeployStage

NewDeployStage for pipeline

type DeployStageCluster

type DeployStageCluster DeploymentCluster

TODO deprecated remove

type DeploymentCluster added in v1.7.0

type DeploymentCluster 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"`
	Base64UserData                      string                 `json:"base64UserData"`
}

DeploymentCluster cluster to deploy

func NewDeployStageCluster

func NewDeployStageCluster() *DeploymentCluster

func NewDeploymentCluster added in v1.7.0

func NewDeploymentCluster() *DeploymentCluster

type DestroyServerGroupStage

type DestroyServerGroupStage struct {
	BaseStage `mapstructure:",squash"`

	CloudProvider     string   `json:"cloudProvider"`
	CloudProviderType string   `json:"cloudProviderType"`
	Cluster           string   `json:"cluster"`
	Credentials       string   `json:"credentials"`
	Moniker           *Moniker `json:"moniker"`
	Regions           []string `json:"regions"`
	Target            string   `json:"target"`
}

DestroyServerGroupStage for pipeline

func NewDestroyServerGroupStage

func NewDestroyServerGroupStage() *DestroyServerGroupStage

NewDestroyServerGroupStage for pipeline

type DockerTrigger added in v1.6.0

type DockerTrigger struct {
	Account      string `json:"account"`
	Organization string `json:"organization"`
	Registry     string `json:"registry"`
	Repository   string `json:"repository"`
	Tag          string `json:"tag"`
	// contains filtered or unexported fields
}

Docker Trigger for Pipeline

func NewDockerTrigger added in v1.6.0

func NewDockerTrigger() *DockerTrigger

func (*DockerTrigger) GetID added in v1.6.0

func (t *DockerTrigger) GetID() string

func (*DockerTrigger) GetType added in v1.6.0

func (t *DockerTrigger) GetType() TriggerType

type EvaluateVariablesStage added in v1.8.0

type EvaluateVariablesStage struct {
	BaseStage `mapstructure:",squash"`

	Variables []Variable `json:"variables"`
}

EvaluateVariablesStage for pipeline

func NewEvaluateVariablesStage added in v1.8.0

func NewEvaluateVariablesStage() *EvaluateVariablesStage

NewEvaluateVariablesStage for pipeline

type FindArtifactsFromResourceStage added in v1.8.0

type FindArtifactsFromResourceStage struct {
	BaseStage `mapstructure:",squash"`

	Account       string `json:"account"`
	CloudProvider string `json:"cloudProvider"`
	Location      string `json:"location"`
	ManifestName  string `json:"manifestName"`
	Mode          string `json:"mode"`
}

FindArtifactsFromResourceStage for pipeline

func NewFindArtifactsFromResourceStage added in v1.8.0

func NewFindArtifactsFromResourceStage() *FindArtifactsFromResourceStage

NewFindArtifactsFromResourceStage for pipeline

type FindImageFromTagsStage added in v1.3.0

type FindImageFromTagsStage struct {
	BaseStage `mapstructure:",squash"`

	CloudProvider     string            `json:"cloudProvider"`
	CloudProviderType string            `json:"cloudProviderType"`
	PackageName       string            `json:"packageName"`
	Regions           []string          `json:"regions"`
	Tags              map[string]string `json:"tags"`
}

FindImageFromTagsStage for pipeline

func NewFindImageStage added in v1.3.0

func NewFindImageStage() *FindImageFromTagsStage

NewFindImageStage for pipeline

type JenkinsStage

type JenkinsStage struct {
	BaseStage `mapstructure:",squash"`

	Job                      string                 `json:"job"`
	MarkUnstableAsSuccessful bool                   `json:"markUnstableAsSuccessful"`
	Master                   string                 `json:"master"`
	Parameters               map[string]interface{} `json:"parameters,omitempty"`
	PropertyFile             string                 `json:"propertyFile,omitempty"`
}

JenkinsStage for pipeline

func NewJenkinsStage

func NewJenkinsStage() *JenkinsStage

NewJenkinsStage for pipeline

type JenkinsTrigger added in v1.6.0

type JenkinsTrigger struct {
	Job          string `json:"job"`
	Master       string `json:"master"`
	PropertyFile string `json:"propertyFile"`
	// contains filtered or unexported fields
}

Jenkins Trigger for Pipeline

func NewJenkinsTrigger added in v1.6.0

func NewJenkinsTrigger() *JenkinsTrigger

func (*JenkinsTrigger) GetID added in v1.6.0

func (t *JenkinsTrigger) GetID() string

func (*JenkinsTrigger) GetType added in v1.6.0

func (t *JenkinsTrigger) GetType() TriggerType

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 Locked added in v1.7.0

type Locked struct {
	UI            bool   `json:"ui"`
	Description   string `json:"description"`
	AllowUnlockUI bool   `json:"allowUnlockUi"`
}

Locked enable/disable to edit Pipeline over the UI

type Manifest added in v1.7.0

type Manifest string

func ParseManifest added in v1.7.0

func ParseManifest(manifestInterface interface{}) (Manifest, error)

func (Manifest) MarshalJSON added in v1.7.0

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

type Manifests added in v1.7.0

type Manifests []Manifest

func NewManifests added in v1.7.0

func NewManifests() *Manifests

func ParseManifests added in v1.7.0

func ParseManifests(manifestInterface []interface{}) (*Manifests, error)

func (Manifests) MarshalJSON added in v1.7.0

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

type ManualJudgmentStage added in v1.3.0

type ManualJudgmentStage struct {
	BaseStage `mapstructure:",squash"`

	Instructions   string           `json:"instructions"`
	JudgmentInputs []JudgmentInputs `json:"judgmentInputs"`
}

func NewManualJudgmentStage added in v1.3.0

func NewManualJudgmentStage() *ManualJudgmentStage

NewManualJudgmentStage for pipeline

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 {
	ID      string            `json:"id,omitempty"`
	Address string            `json:"address"`
	Level   NotificationLevel `json:"level"`
	Type    string            `json:"type"`
	When    []string          `json:"when"`
	Message Message           `json:"message"`
}

Notification for pipeline

func NewNotification added in v1.7.0

func NewNotification() *Notification

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 {
	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"`
	Locked               *Locked                `json:"locked,omitempty"`
	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 {
	BaseStage `mapstructure:",squash"`

	Application        string                 `json:"application"`
	Pipeline           string                 `json:"pipeline"`
	PipelineParameters map[string]interface{} `json:"pipelineParameters"`
	WaitForCompletion  bool                   `json:"waitForCompletion"`
}

PipelineStage for pipeline

func NewPipelineStage

func NewPipelineStage() *PipelineStage

NewPipelineStage for pipeline

type PipelineTrigger added in v1.6.0

type PipelineTrigger struct {
	Application string   `json:"application"`
	Pipeline    string   `json:"pipeline"`
	Status      []string `json:"status"`
	// contains filtered or unexported fields
}

Pipeline Trigger for Pipeline

func NewPipelineTrigger added in v1.6.0

func NewPipelineTrigger() *PipelineTrigger

func (*PipelineTrigger) GetID added in v1.6.0

func (t *PipelineTrigger) GetID() string

func (*PipelineTrigger) GetType added in v1.6.0

func (t *PipelineTrigger) GetType() TriggerType

type Precondition added in v1.7.0

type Precondition interface {
	GetType() PreconditionType
}

func ParsePrecondition added in v1.7.0

func ParsePrecondition(i map[string]interface{}, t PreconditionType) (Precondition, error)

func ParsePreconditions added in v1.7.0

func ParsePreconditions(toParse []interface{}) ([]Precondition, error)

type PreconditionClusterSize added in v1.7.0

type PreconditionClusterSize struct {
	BasePrecondition `mapstructure:",squash"`

	Context PreconditionClusterSizeContext `json:"context"`
}

func NewPreconditionClusterSize added in v1.7.0

func NewPreconditionClusterSize() *PreconditionClusterSize

type PreconditionClusterSizeContext added in v1.7.0

type PreconditionClusterSizeContext struct {
	Credentials string   `json:"credentials"`
	Expected    int      `json:"expected"`
	Regions     []string `json:"regions"`
}

type PreconditionExpression added in v1.7.0

type PreconditionExpression struct {
	BasePrecondition `mapstructure:",squash"`

	Context PreconditionExpressionContext `json:"context"`
}

func NewPreconditionExpression added in v1.7.0

func NewPreconditionExpression() *PreconditionExpression

type PreconditionExpressionContext added in v1.7.0

type PreconditionExpressionContext struct {
	Expression string `json:"expression"`
}

type PreconditionStageStatus added in v1.7.0

type PreconditionStageStatus struct {
	BasePrecondition `mapstructure:",squash"`

	Context PreconditionStageStatusContext `json:"context"`
}

func NewPreconditionStageStatus added in v1.7.0

func NewPreconditionStageStatus() *PreconditionStageStatus

type PreconditionStageStatusContext added in v1.7.0

type PreconditionStageStatusContext struct {
	StageName   string `json:"stageName"`
	StageStatus string `json:"stageStatus"`
}

type PreconditionType added in v1.7.0

type PreconditionType string

PreconditionType type of precondition

var PreconditionClusterSizeType PreconditionType = "clusterSize"

PreconditionClusterSizeType

var PreconditionExpressionType PreconditionType = "expression"

PreconditionExpressionType

var PreconditionStageStatusType PreconditionType = "stageStatus"

PreconditionStageStatusType

func (PreconditionType) String added in v1.7.0

func (st PreconditionType) String() string

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 {
	BaseStage `mapstructure:",squash"`

	Action            string    `json:"action"`
	Capacity          *Capacity `json:"capacity"`
	CloudProvider     string    `json:"cloudProvider"`
	CloudProviderType string    `json:"cloudProviderType"`
	Cluster           string    `json:"cluster"`
	Credentials       string    `json:"credentials"`
	Moniker           *Moniker  `json:"moniker"`
	Regions           []string  `json:"regions"`
	ResizeType        string    `json:"resizeType"`
	Target            string    `json:"target"`

	TargetHealthyDeployPercentage int `json:"targetHealthyDeployPercentage"`
}

ResizeServerGroupStage for pipeline

func NewResizeServerGroupStage

func NewResizeServerGroupStage() *ResizeServerGroupStage

NewResizeServerGroupStage for pipeline

type Rollback

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

func NewRollback

func NewRollback() *Rollback

type RollbackClusterStage

type RollbackClusterStage struct {
	BaseStage `mapstructure:",squash"`

	CloudProvider     string   `json:"cloudProvider"`
	CloudProviderType string   `json:"cloudProviderType"`
	Cluster           string   `json:"cluster"`
	Credentials       string   `json:"credentials"`
	Moniker           *Moniker `json:"moniker"`
	Regions           []string `json:"regions"`

	TargetHealthyRollbackPercentage int `json:"targetHealthyRollbackPercentage"`
}

RollbackClusterStage for pipeline

func NewRollbackClusterStage

func NewRollbackClusterStage() *RollbackClusterStage

NewRollbackClusterStage for pipeline

type RunJobManifestStage added in v1.7.0

type RunJobManifestStage struct {
	BaseStage `mapstructure:",squash"`

	Account               string   `json:"account"`
	Alias                 string   `json:"alias"`
	Application           string   `json:"application"`
	CloudProvider         string   `json:"cloudProvider"`
	ConsumeArtifactSource string   `json:"consumeArtifactSource"`
	Credentials           string   `json:"credentials"`
	Manifest              Manifest `json:"manifest"`
	PropertyFile          string   `json:"propertyFile"`
	Source                string   `json:"source"`
}

func NewRunJobManifestStage added in v1.7.0

func NewRunJobManifestStage() *RunJobManifestStage

type ScaleManifestSource added in v1.7.0

type ScaleManifestSource int
const (
	ScaleManifestSourceUnknown ScaleManifestSource = iota
	ScaleManifestSourceText
)

func ParseScaleManifestSource added in v1.7.0

func ParseScaleManifestSource(s string) (ScaleManifestSource, error)

func (ScaleManifestSource) MarshalText added in v1.7.0

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

func (ScaleManifestSource) String added in v1.7.0

func (t ScaleManifestSource) String() string

func (*ScaleManifestSource) UnmarshalText added in v1.7.0

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

type ScaleManifestStage added in v1.7.0

type ScaleManifestStage struct {
	BaseStage `mapstructure:",squash"`

	Account        string                 `json:"account"`
	Application    string                 `json:"app"`
	CloudProvider  string                 `json:"cloudProvider"`
	Cluster        string                 `json:"cluster"`
	Criteria       string                 `json:"criteria"`
	Kind           string                 `json:"kind"`
	Kinds          []string               `json:"kinds,omitempty"`
	LabelSelectors map[string]interface{} `json:"labelSelectors,omitempty"`
	Location       string                 `json:"location"`
	ManifestName   string                 `json:"manifestName,omitempty"`
	Mode           string                 `json:"mode"`
	Replicas       string                 `json:"replicas"`
}

func NewScaleManifestStage added in v1.7.0

func NewScaleManifestStage() *ScaleManifestStage

type ScaleManifests added in v1.7.0

type ScaleManifests []string

func NewScaleManifests added in v1.7.0

func NewScaleManifests() *ScaleManifests

func ParseScaleManifests added in v1.7.0

func ParseScaleManifests(manifestInterface []interface{}) (*ScaleManifests, error)

func (ScaleManifests) MarshalJSON added in v1.7.0

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

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 CheckPreconditionsStageType StageType = "checkPreconditions"

CheckPreconditionsStageType check preconditions stage

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 EvaluateVariablesStageType StageType = "evaluateVariables"

EvaluateVariablesStageType bake stage

var FindArtifactsFromResourceStageType StageType = "findArtifactsFromResource"

FindArtifactsFromResourceStageType bake 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 RunJobManifestStageType StageType = "runJobManifest"

RunJobManifestStageType run job manifest stage

var ScaleManifestStageType StageType = "scaleManifest"

ScaleManifestStageType scale manifest 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"`
	Namespace     string   `json:"namespace,omitempty"`
	Services      []string `json:"services,omitempty"`
	Strategy      string   `json:"strategy,omitempty"`
}

func NewTrafficManagementOptions added in v1.2.0

func NewTrafficManagementOptions() *TrafficManagementOptions

type Trigger

type Trigger interface {
	GetID() string
	GetType() TriggerType
}

Trigger interface for Pipeline triggers

type TriggerType added in v1.6.0

type TriggerType string

TriggerType type of trigger

var DockerTriggerType TriggerType = "docker"

DockerTriggerType docker trigger

var JenkinsTriggerType TriggerType = "jenkins"

JenkinsTriggerType jenkins trigger

var PipelineTriggerType TriggerType = "pipeline"

PipelineTriggerType pipeline trigger

func (TriggerType) String added in v1.6.0

func (st TriggerType) String() string

type Variable added in v1.8.0

type Variable struct {
	Key   string `json:"key"`
	Value string `json:"value"`
}

Variable for evaluation

type WebhookStage added in v1.3.0

type WebhookStage struct {
	BaseStage `mapstructure:",squash"`

	CanceledStatuses    string                 `json:"canceledStatuses"`
	CustomHeaders       map[string]string      `json:"customHeaders"`
	FailFastStatusCodes []string               `json:"failFastStatusCodes"`
	Method              string                 `json:"method"`
	Payload             map[string]interface{} `json:"payload"`
	ProgressJSONPath    string                 `json:"progressJsonPath"`
	StatusJSONPath      string                 `json:"statusJsonPath"`
	StatusURLJSONPath   string                 `json:"statusUrlJsonPath"`
	StatusURLResolution string                 `json:"statusUrlResolution"`
	SuccessStatuses     string                 `json:"successStatuses"`
	TerminalStatuses    string                 `json:"terminalStatuses"`
	URL                 string                 `json:"url"`
	WaitForCompletion   bool                   `json:"waitForCompletion"`
}

WebhookStage for pipeline

func NewWebhookStage added in v1.3.0

func NewWebhookStage() *WebhookStage

NewWebhookStage for pipeline

Source Files

Jump to

Keyboard shortcuts

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