cloudrun

Documentation

Index

• Constants
• Variables
• func DecideRevisionName(sm ServiceManifest, commit string) (string, error)
• func FindImageTag(sm ServiceManifest) (string, error)
• func MakeManagedByPipedLabel() string
• type Client
• type DiffRenderOptions
• type DiffResult
  • func Diff(old, new ServiceManifest, opts ...diff.Option) (*DiffResult, error)
  • func (d *DiffResult) NoChange() bool
  • func (d *DiffResult) Render(opt DiffRenderOptions) string
• type ListOptions
• type Registry
  • func DefaultRegistry() Registry
• type Revision
• type RevisionTraffic
• type Service
  • func (s *Service) ServiceManifest() (ServiceManifest, error)
• type ServiceManifest
  • func LoadServiceManifest(appDir, serviceFilename string) (ServiceManifest, error)
  • func ParseServiceManifest(data []byte) (ServiceManifest, error)
  • func (m ServiceManifest) AddLabels(labels map[string]string)
  • func (m ServiceManifest) Labels() map[string]string
  • func (m ServiceManifest) SetRevision(name string) error
  • func (m ServiceManifest) UpdateAllTraffic(revision string) error
  • func (m ServiceManifest) UpdateTraffic(revisions []RevisionTraffic) error
  • func (m ServiceManifest) YamlBytes() ([]byte, error)
• type ServiceManifestCache
  • func (c ServiceManifestCache) Get(commit string) (ServiceManifest, bool)
  • func (c ServiceManifestCache) Put(commit string, sm ServiceManifest)

Constants

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.
	ManagedByPiped   = "piped"
)

const (
	DefaultServiceManifestFilename = "service.yaml"
)

Variables

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

Functions

func DecideRevisionName

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

func FindImageTag

func FindImageTag(sm ServiceManifest) (string, error)

func MakeManagedByPipedLabel

func MakeManagedByPipedLabel() 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)
}

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 ListOptions

type ListOptions 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

type RevisionTraffic

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

type Service

type Service run.Service

func (*Service) ServiceManifest

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

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) Labels

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

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)