Documentation
¶
Index ¶
- Variables
- type Ctl
- func (c *Ctl) AddEnvironment(ctx context.Context, environment *pb.Environment) (*pb.Environment, error)
- func (c *Ctl) AddPackage(ctx context.Context, pkg *pb.JobPackage) (*pb.JobPackage, error)
- func (c *Ctl) AddTenant(ctx context.Context, tenant *pb.Tenant) (*pb.Tenant, error)
- func (c *Ctl) AllPackages(ctx context.Context) ([]*pb.JobPackage, error)
- func (c *Ctl) Close() error
- func (c *Ctl) DeletePackage(ctx context.Context, pkg *pb.JobPackage) error
- func (c *Ctl) Environment(ctx context.Context) (*pb.Environment, error)
- func (c *Ctl) ListenerForEnvironmentUpdates(ctx context.Context) (*broadcaster.Listener[*pb.UpdateToEnvironmentStrReply], error)
- func (c *Ctl) ListenerForPackageUpdates(ctx context.Context) (*broadcaster.Listener[*pb.UpdateToPackagesStrReply], error)
- func (c *Ctl) Package(ctx context.Context, tenant string, id *string) ([]*pb.JobPackage, error)
- func (c *Ctl) Packages(ctx context.Context, tenant string) ([]*pb.JobPackage, error)
- func (c *Ctl) Tenant(ctx context.Context, id *string) ([]*pb.Tenant, error)
- func (c *Ctl) Tenants(ctx context.Context) ([]*pb.Tenant, error)
- func (c *Ctl) UpdateEnvironment(ctx context.Context, environment *pb.Environment) error
- func (c *Ctl) UpdatePackage(ctx context.Context, pkg *pb.JobPackage) error
- type Metadata
- type Queue
- type Recorder
- func (c *Recorder) AddJobExecution(ctx context.Context, ex *pb.JobExecution) error
- func (c *Recorder) Close() error
- func (c *Recorder) JobExecutions(ctx context.Context, tenant string, lines int32) ([]string, error)
- func (c *Recorder) StreamJobExecutions(ctx context.Context, lines int32, resChan chan<- string) error
- type Repo
- func (c *Repo) AddFile(ctx context.Context, tenant string, name string, fileType pb.File_FileType, ...) error
- func (c *Repo) AllFilenames(ctx context.Context) ([]*pb.TenantFiles, error)
- func (c *Repo) Close() error
- func (c *Repo) File(ctx context.Context, tenant string, name string) ([]byte, error)
- func (c *Repo) ListenerForRepoUpdates(ctx context.Context) (*broadcaster.Listener[*pb.UpdateToFileStrReply], error)
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrCtlHostAddr = errors.New("the control service address was not specified in the env file using ctl.host")
Functions ¶
This section is empty.
Types ¶
type Ctl ¶
type Ctl struct {
// contains filtered or unexported fields
}
func (*Ctl) AddEnvironment ¶
func (c *Ctl) AddEnvironment(ctx context.Context, environment *pb.Environment) (*pb.Environment, error)
func (*Ctl) AddPackage ¶
func (c *Ctl) AddPackage(ctx context.Context, pkg *pb.JobPackage) (*pb.JobPackage, error)
func (*Ctl) AllPackages ¶
func (*Ctl) DeletePackage ¶
func (*Ctl) Environment ¶
func (*Ctl) ListenerForEnvironmentUpdates ¶
func (c *Ctl) ListenerForEnvironmentUpdates(ctx context.Context) (*broadcaster.Listener[*pb.UpdateToEnvironmentStrReply], error)
func (*Ctl) ListenerForPackageUpdates ¶
func (c *Ctl) ListenerForPackageUpdates(ctx context.Context) (*broadcaster.Listener[*pb.UpdateToPackagesStrReply], error)
func (*Ctl) UpdateEnvironment ¶
func (*Ctl) UpdatePackage ¶
type Queue ¶
type Queue struct {
// contains filtered or unexported fields
}
type Recorder ¶
type Recorder struct {
// contains filtered or unexported fields
}
func NewRecorder ¶
func (*Recorder) AddJobExecution ¶
func (*Recorder) JobExecutions ¶
type Repo ¶
type Repo struct {
// contains filtered or unexported fields
}
func (*Repo) AllFilenames ¶
func (*Repo) ListenerForRepoUpdates ¶
func (c *Repo) ListenerForRepoUpdates(ctx context.Context) (*broadcaster.Listener[*pb.UpdateToFileStrReply], error)
Source Files
Click to show internal directories.
Click to hide internal directories.