cloudrun

package
v0.41.2 Latest Latest
Warning

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

 Go to latest Published: Jan 6, 2023 License: Apache-2.0 Imports: 24 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")
)
View Source 
var (
	TypeConditions = map[string]struct{}{
		"Active":              struct{}{},
		"Ready":               struct{}{},
		"ConfigurationsReady": struct{}{},
		"RoutesReady":         struct{}{},
		"ContainerHealthy":    struct{}{},
		"ResourcesAvailable":  struct{}{},
	}
	TypeHealthyServiceConditions = map[string]struct{}{
		"Ready":               struct{}{},
		"ConfigurationsReady": struct{}{},
		"RoutesReady":         struct{}{},
	}
	TypeHealthyRevisionConditions = map[string]struct{}{
		"Ready":              struct{}{},
		"Active":             struct{}{},
		"ContainerHealthy":   struct{}{},
		"ResourcesAvailable": struct{}{},
	}
)

Functions

func DecideRevisionName 

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

func FindArtifactVersions 

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

func FindImageTag 

func FindImageTag(sm ServiceManifest) (string, error)

func MakeManagedByPipedSelector 

func MakeManagedByPipedSelector() string

func MakeResourceStates 

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

func MakeRevisionNamesSelector 

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 

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

type DiffResult 

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

func Diff 

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

func (*DiffResult) NoChange 

func (d *DiffResult) NoChange() bool

func (*DiffResult) Render 

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

type Kind added in v0.41.0 

type Kind string

Kind represents the kind of resource. 

const (
	KindService  Kind = "Service"
	KindRevision Kind = "Revision"
)

type ListOptions 

type ListOptions struct {
	Limit         int64
	LabelSelector string
	Cursor        string
}

type ListRevisionsOptions 

type ListRevisionsOptions struct {
	Limit         int64
	LabelSelector string
	Cursor        string
}

type Registry 

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

func DefaultRegistry 

func DefaultRegistry() Registry

type Revision 

type Revision run.Revision

func (*Revision) RevisionManifest 

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

func (*Revision) StatusConditions added in v0.41.0 

func (r *Revision) StatusConditions() *StatusConditions

type RevisionManifest 

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

func ParseRevisionManifest 

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

func (RevisionManifest) RunRevision 

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

func (RevisionManifest) YamlBytes 

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 

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

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

func (*Service) ServiceManifest 

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

func (*Service) StatusConditions added in v0.41.0 

func (s *Service) StatusConditions() *StatusConditions

func (*Service) UID 

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 

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

func (ServiceManifest) AddRevisionLabels 

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

func (ServiceManifest) AppID 

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

func (ServiceManifest) Labels 

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

func (ServiceManifest) RevisionLabels 

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

func (ServiceManifest) RunService 

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)

type StatusConditions added in v0.41.0 

type StatusConditions struct {
	Kind      Kind
	TrueTypes map[string]struct{}

	// Eliminate duplicated messages with the same reason.
	FalseMessages   []string
	UnknownMessages []string
}

func (*StatusConditions) HealthStatus added in v0.41.0 

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

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.