Versions in this module Expand all Collapse all v1 v1.0.0 Apr 28, 2022 Changes in this version + const PathPiroConfig + type CompositeContentProvider []ContentProvider + func (c CompositeContentProvider) InitContainer() ([]corev1.Container, error) + func (c CompositeContentProvider) Serve(jobName string) error + type Config struct + BaseURL string + CleanupJobSpec *configPodSpec + DebugProxy string + GCOlderThan *executor.Duration + WorkspaceNodePathPrefix string + type ContentProvider interface + InitContainer func() ([]corev1.Container, error) + Serve func(jobName string) error + type FileProvider interface + Download func(ctx context.Context, path string) (io.ReadCloser, error) + ListFiles func(ctx context.Context, path string) (paths []string, err error) + type LocalContentProvider struct + Clientset kubernetes.Interface + Kubeconfig *rest.Config + Namespace string + TarStream io.Reader + func (lcp *LocalContentProvider) InitContainer() ([]corev1.Container, error) + func (lcp *LocalContentProvider) Serve(jobName string) error + type NoopRepositoryProvider struct + func (NoopRepositoryProvider) ContentProvider(ctx context.Context, repo *v1.Repository, paths ...string) (ContentProvider, error) + func (NoopRepositoryProvider) FileProvider(ctx context.Context, repo *v1.Repository) (FileProvider, error) + func (NoopRepositoryProvider) RemoteAnnotations(ctx context.Context, repo *v1.Repository) (annotations map[string]string, err error) + func (NoopRepositoryProvider) Resolve(ctx context.Context, repo *v1.Repository) error + type RepositoryProvider interface + ContentProvider func(ctx context.Context, repo *v1.Repository, path ...string) (ContentProvider, error) + FileProvider func(ctx context.Context, repo *v1.Repository) (FileProvider, error) + RemoteAnnotations func(ctx context.Context, repo *v1.Repository) (annotations map[string]string, err error) + Resolve func(ctx context.Context, repo *v1.Repository) error + type Service struct + Config Config + Cutter logcutter.Cutter + Executor *executor.Executor + Groups store.NumberGroup + Jobs store.Jobs + Logs store.Logs + RepositoryProvider RepositoryProvider + func (srv *Service) GetJob(ctx context.Context, req *v1.GetJobRequest) (resp *v1.GetJobResponse, err error) + func (srv *Service) ListJobs(ctx context.Context, req *v1.ListJobsRequest) (resp *v1.ListJobsResponse, err error) + func (srv *Service) Listen(req *v1.ListenRequest, ls v1.PiroService_ListenServer) error + func (srv *Service) RegisterPrometheusMetrics(reg prometheus.Registerer) + func (srv *Service) RunJob(ctx context.Context, name string, metadata v1.JobMetadata, spec v1.JobSpec, ...) (status *v1.JobStatus, err error) + func (srv *Service) Start() error + func (srv *Service) StartFromPreviousJob(ctx context.Context, req *v1.StartFromPreviousJobRequest) (*v1.StartJobResponse, error) + func (srv *Service) StartGitHubJob(ctx context.Context, req *v1.StartGitHubJobRequest) (resp *v1.StartJobResponse, err error) + func (srv *Service) StartJob(ctx context.Context, req *v1.StartJobRequest) (resp *v1.StartJobResponse, err error) + func (srv *Service) StartJob2(ctx context.Context, req *v1.StartJobRequest2) (resp *v1.StartJobResponse, err error) + func (srv *Service) StartLocalJob(inc v1.PiroService_StartLocalJobServer) error + func (srv *Service) StopJob(ctx context.Context, req *v1.StopJobRequest) (*v1.StopJobResponse, error) + func (srv *Service) Subscribe(req *v1.SubscribeRequest, resp v1.PiroService_SubscribeServer) (err error) + type SideloadingContentProvider struct + Clientset kubernetes.Interface + Kubeconfig *rest.Config + Namespace string + TarStream io.Reader + func (s *SideloadingContentProvider) InitContainer() ([]corev1.Container, error) + func (s *SideloadingContentProvider) Serve(jobName string) error + type UIService struct + Readonly bool + Repos []string + RepositoryProvider RepositoryProvider + func NewUIService(repoprov RepositoryProvider, repos []string, readonly bool, ...) (*UIService, error) + func (uis *UIService) IsReadOnly(context.Context, *v1.IsReadOnlyRequest) (*v1.IsReadOnlyResponse, error) + func (uis *UIService) ListJobSpecs(req *v1.ListJobSpecsRequest, srv v1.PiroUI_ListJobSpecsServer) error