cloudrun

package
v0.27.4 Latest Latest
Warning

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

 Go to latest Published: Apr 14, 2022 License: Apache-2.0 Imports: 25 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	LabelManagedBy    = "pipecd-dev-managed-by"    // Always be piped.
	LabelPiped        = "pipecd-dev-piped"         // The id of piped handling this application.
	LabelApplication  = "pipecd-dev-application"   // The application this resource belongs to.
	LabelCommitHash   = "pipecd-dev-commit-hash"   // Hash value of the deployed commit.
	LabelRevisionName = "pipecd-dev-revision-name" // The name of revision.
	ManagedByPiped    = "piped"
)
View Source 
const (
	DefaultServiceManifestFilename = "service.yaml"
)

Variables

View Source 
var (
	ErrServiceNotFound  = errors.New("not found")
	ErrRevisionNotFound = errors.New("not found")
)

Functions

func DecideRevisionName 

func DecideRevisionName(sm ServiceManifest, commit string) (string, error)

func FindArtifactVersions added in v0.27.0 

func FindArtifactVersions(sm ServiceManifest) ([]*model.ArtifactVersion, error)

func FindImageTag 

func FindImageTag(sm ServiceManifest) (string, error)

func MakeManagedByPipedSelector added in v0.26.0 

func MakeManagedByPipedSelector() string

func MakeResourceStates added in v0.26.0 

func MakeResourceStates(svc *Service, revs []*Revision, updatedAt time.Time) []*model.CloudRunResourceState

func MakeRevisionNamesSelector added in v0.26.0 

func MakeRevisionNamesSelector(names []string) string

Types

type Client 

type Client interface {
	Create(ctx context.Context, sm ServiceManifest) (*Service, error)
	Update(ctx context.Context, sm ServiceManifest) (*Service, error)
	List(ctx context.Context, options *ListOptions) ([]*Service, string, error)
	GetRevision(ctx context.Context, name string) (*Revision, error)
	ListRevisions(ctx context.Context, options *ListRevisionsOptions) ([]*Revision, string, error)
}

type DiffRenderOptions added in v0.24.1 

type DiffRenderOptions struct {
	// If true, use "diff" command to render.
	UseDiffCommand bool
}

type DiffResult added in v0.24.1 

type DiffResult struct {
	Diff *diff.Result
	Old  ServiceManifest
	New  ServiceManifest
}

func Diff added in v0.24.1 

func Diff(old, new ServiceManifest, opts ...diff.Option) (*DiffResult, error)

func (*DiffResult) NoChange added in v0.24.1 

func (d *DiffResult) NoChange() bool

func (*DiffResult) Render added in v0.24.1 

func (d *DiffResult) Render(opt DiffRenderOptions) string

type ListOptions added in v0.24.1 

type ListOptions struct {
	Limit         int64
	LabelSelector string
	Cursor        string
}

type ListRevisionsOptions added in v0.26.0 

type ListRevisionsOptions struct {
	Limit         int64
	LabelSelector string
	Cursor        string
}

type Registry 

type Registry interface {
	Client(ctx context.Context, name string, cfg *config.CloudProviderCloudRunConfig, logger *zap.Logger) (Client, error)
}

func DefaultRegistry 

func DefaultRegistry() Registry

type Revision 

type Revision run.Revision

func (*Revision) HealthStatus added in v0.26.0 

func (r *Revision) HealthStatus() (model.CloudRunResourceState_HealthStatus, string)

func (*Revision) RevisionManifest added in v0.26.0 

func (r *Revision) RevisionManifest() (RevisionManifest, error)

type RevisionManifest added in v0.26.0 

type RevisionManifest struct {
	Name string
	// contains filtered or unexported fields
}

func ParseRevisionManifest added in v0.26.0 

func ParseRevisionManifest(data []byte) (RevisionManifest, error)

func (RevisionManifest) RunRevision added in v0.26.0 

func (r RevisionManifest) RunRevision() (*run.Revision, error)

func (RevisionManifest) YamlBytes added in v0.26.0 

func (r RevisionManifest) YamlBytes() ([]byte, error)

type RevisionTraffic 

type RevisionTraffic struct {
	RevisionName string `json:"revisionName"`
	Percent      int    `json:"percent"`
}

type Service 

type Service run.Service

func (*Service) ActiveRevisionNames added in v0.26.0 

func (s *Service) ActiveRevisionNames() []string

ActiveRevisionNames returns all its active revisions which may handle the traffic.

func (*Service) HealthStatus added in v0.26.0 

func (s *Service) HealthStatus() (model.CloudRunResourceState_HealthStatus, string)

func (*Service) ServiceManifest added in v0.24.1 

func (s *Service) ServiceManifest() (ServiceManifest, error)

func (*Service) UID added in v0.26.0 

func (s *Service) UID() (string, bool)

type ServiceManifest 

type ServiceManifest struct {
	Name string
	// contains filtered or unexported fields
}

func LoadServiceManifest 

func LoadServiceManifest(appDir, serviceFilename string) (ServiceManifest, error)

func ParseServiceManifest 

func ParseServiceManifest(data []byte) (ServiceManifest, error)

func (ServiceManifest) AddLabels added in v0.24.1 

func (m ServiceManifest) AddLabels(labels map[string]string)

func (ServiceManifest) AddRevisionLabels added in v0.26.0 

func (m ServiceManifest) AddRevisionLabels(labels map[string]string) error

func (ServiceManifest) AppID added in v0.26.0 

func (m ServiceManifest) AppID() (string, bool)

func (ServiceManifest) Labels added in v0.24.1 

func (m ServiceManifest) Labels() map[string]string

func (ServiceManifest) RevisionLabels added in v0.26.0 

func (m ServiceManifest) RevisionLabels() map[string]string

func (ServiceManifest) RunService added in v0.26.0 

func (m ServiceManifest) RunService() (*run.Service, error)

func (ServiceManifest) SetRevision 

func (m ServiceManifest) SetRevision(name string) error

func (ServiceManifest) UpdateAllTraffic 

func (m ServiceManifest) UpdateAllTraffic(revision string) error

func (ServiceManifest) UpdateTraffic 

func (m ServiceManifest) UpdateTraffic(revisions []RevisionTraffic) error

func (ServiceManifest) YamlBytes 

func (m ServiceManifest) YamlBytes() ([]byte, error)

type ServiceManifestCache 

type ServiceManifestCache struct {
	AppID  string
	Cache  cache.Cache
	Logger *zap.Logger
}

func (ServiceManifestCache) Get 

func (c ServiceManifestCache) Get(commit string) (ServiceManifest, bool)

func (ServiceManifestCache) Put 

func (c ServiceManifestCache) Put(commit string, sm ServiceManifest)

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.