service

Documentation

Index

• Constants
• type PodWatcher
  • func NewPodWatcher(podsClient typedcorev1.PodInterface, listOpts metav1.ListOptions) PodWatcher
  • func (w PodWatcher) Watch(podsToWatchCh chan corev1.Pod, cancelCh chan struct{}) error
• type RevisionPodWatcher
  • func NewRevisionPodWatcher(revision *v1alpha1.Revision, servingClient servingclientset.Interface, ...) RevisionPodWatcher
  • func (w RevisionPodWatcher) Watch(podsToWatchCh chan corev1.Pod, cancelCh chan struct{}) error
• type RevisionWatcher
  • func NewRevisionWatcher(revisionsClient typedv1alpha1.RevisionInterface, listOpts metav1.ListOptions) RevisionWatcher
  • func (w RevisionWatcher) Watch(revisionsToWatchCh chan v1alpha1.Revision, cancelCh chan struct{}) error
• type Service
  • func NewService(serviceSpec ServiceSpec, servingClient servingclientset.Interface, ...) *Service
  • func (s *Service) CreateOrUpdate() (*v1alpha1.Service, error)
  • func (l *Service) CreatedBuildSinceRevision(lastRevision *v1alpha1.Revision) (ctlbuild.Build, error)
  • func (l *Service) CreatedRevisionSinceRevision(lastRevision *v1alpha1.Revision) (*v1alpha1.Revision, error)
  • func (l *Service) LastRevision() (*v1alpha1.Revision, error)
• type ServicePodWatcher
  • func NewServicePodWatcher(service *v1alpha1.Service, servingClient servingclientset.Interface, ...) ServicePodWatcher
  • func (w ServicePodWatcher) Watch(podsToWatchCh chan corev1.Pod, cancelCh chan struct{}) error
• type ServiceSpec
• type Tags
  • func NewTags(servingClient servingclientset.Interface) Tags
  • func (t Tags) Find(context TagsFindContext, tag string) (*v1alpha1.Revision, error)
  • func (t Tags) List(revision v1alpha1.Revision) []string
  • func (t Tags) Repoint(revision *v1alpha1.Revision, tag string) error
  • func (t Tags) Tag(revision *v1alpha1.Revision, tag string) error
  • func (t Tags) Untag(revision v1alpha1.Revision, tag string) error
• type TagsFindContext

Constants

const (
	TagsLatest   = "latest"
	TagsPrevious = "previous"
)

Types

type PodWatcher

type PodWatcher struct {
	// contains filtered or unexported fields
}

func NewPodWatcher

func NewPodWatcher(
	podsClient typedcorev1.PodInterface,
	listOpts metav1.ListOptions,
) PodWatcher

func (PodWatcher) Watch

func (w PodWatcher) Watch(podsToWatchCh chan corev1.Pod, cancelCh chan struct{}) error

type RevisionPodWatcher

type RevisionPodWatcher struct {
	// contains filtered or unexported fields
}

func NewRevisionPodWatcher

func NewRevisionPodWatcher(
	revision *v1alpha1.Revision,
	servingClient servingclientset.Interface,
	coreClient kubernetes.Interface,
	ui ui.UI,
) RevisionPodWatcher

func (RevisionPodWatcher) Watch

func (w RevisionPodWatcher) Watch(podsToWatchCh chan corev1.Pod, cancelCh chan struct{}) error

type RevisionWatcher

type RevisionWatcher struct {
	// contains filtered or unexported fields
}

func NewRevisionWatcher

func NewRevisionWatcher(
	revisionsClient typedv1alpha1.RevisionInterface,
	listOpts metav1.ListOptions,
) RevisionWatcher

func (RevisionWatcher) Watch

func (w RevisionWatcher) Watch(revisionsToWatchCh chan v1alpha1.Revision, cancelCh chan struct{}) error

type Service

type Service struct {
	// contains filtered or unexported fields
}

func NewService

func NewService(
	serviceSpec ServiceSpec,
	servingClient servingclientset.Interface,
	buildClient buildclientset.Interface,
	coreClient kubernetes.Interface,
	buildObjFactory ctlbuild.Factory,
) *Service

func (*Service) CreateOrUpdate

func (s *Service) CreateOrUpdate() (*v1alpha1.Service, error)

func (*Service) CreatedBuildSinceRevision

func (l *Service) CreatedBuildSinceRevision(lastRevision *v1alpha1.Revision) (ctlbuild.Build, error)

func (*Service) CreatedRevisionSinceRevision

func (l *Service) CreatedRevisionSinceRevision(lastRevision *v1alpha1.Revision) (*v1alpha1.Revision, error)

func (*Service) LastRevision

func (l *Service) LastRevision() (*v1alpha1.Revision, error)

type ServicePodWatcher

type ServicePodWatcher struct {
	// contains filtered or unexported fields
}

func NewServicePodWatcher

func NewServicePodWatcher(
	service *v1alpha1.Service,
	servingClient servingclientset.Interface,
	coreClient kubernetes.Interface,
	ui ui.UI,
) ServicePodWatcher

func (ServicePodWatcher) Watch

func (w ServicePodWatcher) Watch(podsToWatchCh chan corev1.Pod, cancelCh chan struct{}) error

type ServiceSpec

type ServiceSpec interface {
	Namespace() string
	Name() string
	Service() (v1alpha1.Service, error)
	NeedsConfigurationUpdate() bool
	Configuration() (v1alpha1.Configuration, error)
}

type Tags

type Tags struct {
	// contains filtered or unexported fields
}

func NewTags

func NewTags(servingClient servingclientset.Interface) Tags

func (Tags) Find

func (t Tags) Find(context TagsFindContext, tag string) (*v1alpha1.Revision, error)

TODO instead of context, pass in v1alpha1.Service?

func (Tags) List

func (t Tags) List(revision v1alpha1.Revision) []string

func (Tags) Repoint

func (t Tags) Repoint(revision *v1alpha1.Revision, tag string) error

func (Tags) Tag

func (t Tags) Tag(revision *v1alpha1.Revision, tag string) error

func (Tags) Untag

func (t Tags) Untag(revision v1alpha1.Revision, tag string) error

type TagsFindContext

type TagsFindContext struct {
	Namespace string
	Service   string
}