kdeploypb

package
v0.0.4 Latest Latest
Warning

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

 Go to latest Published: Jan 17, 2021 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_kdeploy_proto protoreflect.FileDescriptor

Functions

func RegisterKdeployServiceServer 

func RegisterKdeployServiceServer(s *grpc.Server, srv KdeployServiceServer)

Types

type App 

type App struct {

	// name of the application
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// application namespace
	Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// docker image of application
	Image string `protobuf:"bytes,3,opt,name=image,proto3" json:"image,omitempty"`
	// args are arguments given to the docker image at startup
	Args []string `protobuf:"bytes,5,rep,name=args,proto3" json:"args,omitempty"`
	// k/v map of environmental variables
	Env map[string]string `` /* 147-byte string literal not displayed */
	// k/v map of ports to expose ex: http: 80 https: 443
	Ports map[string]uint32 `` /* 152-byte string literal not displayed */
	// number of deployment replicas
	Replicas uint32 `protobuf:"varint,8,opt,name=replicas,proto3" json:"replicas,omitempty"`
	// status tracks the state of the application during it's lifecycle
	Status *AppStatus `protobuf:"bytes,9,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

App is a stateless application

func (*App) Descriptor deprecated 

func (*App) Descriptor() ([]byte, []int)

Deprecated: Use App.ProtoReflect.Descriptor instead.

func (*App) GetArgs added in v0.0.1 

func (x *App) GetArgs() []string

func (*App) GetEnv 

func (x *App) GetEnv() map[string]string

func (*App) GetImage 

func (x *App) GetImage() string

func (*App) GetName 

func (x *App) GetName() string

func (*App) GetNamespace 

func (x *App) GetNamespace() string

func (*App) GetPorts 

func (x *App) GetPorts() map[string]uint32

func (*App) GetReplicas 

func (x *App) GetReplicas() uint32

func (*App) GetStatus 

func (x *App) GetStatus() *AppStatus

func (*App) ProtoMessage 

func (*App) ProtoMessage()

func (*App) ProtoReflect 

func (x *App) ProtoReflect() protoreflect.Message

func (*App) Reset 

func (x *App) Reset()

func (*App) String 

func (x *App) String() string

func (*App) Validate 

func (this *App) Validate() error

type AppConstructor 

type AppConstructor struct {

	// name of the application
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// application namespace
	Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// docker image of application
	Image string `protobuf:"bytes,3,opt,name=image,proto3" json:"image,omitempty"`
	// args are arguments given to the docker image at startup
	Args []string `protobuf:"bytes,4,rep,name=args,proto3" json:"args,omitempty"`
	// k/v map of environmental variables
	Env map[string]string `` /* 147-byte string literal not displayed */
	// k/v map of ports to expose ex: http: 80 https: 443
	Ports map[string]uint32 `` /* 152-byte string literal not displayed */
	// number of deployment replicas
	Replicas uint32 `protobuf:"varint,7,opt,name=replicas,proto3" json:"replicas,omitempty"`
	// contains filtered or unexported fields
}

AppConstructor creates a new app

func (*AppConstructor) Descriptor deprecated 

func (*AppConstructor) Descriptor() ([]byte, []int)

Deprecated: Use AppConstructor.ProtoReflect.Descriptor instead.

func (*AppConstructor) GetArgs added in v0.0.1 

func (x *AppConstructor) GetArgs() []string

func (*AppConstructor) GetEnv 

func (x *AppConstructor) GetEnv() map[string]string

func (*AppConstructor) GetImage 

func (x *AppConstructor) GetImage() string

func (*AppConstructor) GetName 

func (x *AppConstructor) GetName() string

func (*AppConstructor) GetNamespace 

func (x *AppConstructor) GetNamespace() string

func (*AppConstructor) GetPorts 

func (x *AppConstructor) GetPorts() map[string]uint32

func (*AppConstructor) GetReplicas 

func (x *AppConstructor) GetReplicas() uint32

func (*AppConstructor) ProtoMessage 

func (*AppConstructor) ProtoMessage()

func (*AppConstructor) ProtoReflect 

func (x *AppConstructor) ProtoReflect() protoreflect.Message

func (*AppConstructor) Reset 

func (x *AppConstructor) Reset()

func (*AppConstructor) String 

func (x *AppConstructor) String() string

func (*AppConstructor) Validate 

func (this *AppConstructor) Validate() error

type AppStatus added in v0.0.1 

type AppStatus struct {
	Replicas []*Replica `protobuf:"bytes,1,rep,name=replicas,proto3" json:"replicas,omitempty"`
	// contains filtered or unexported fields
}

func (*AppStatus) Descriptor deprecated added in v0.0.1 

func (*AppStatus) Descriptor() ([]byte, []int)

Deprecated: Use AppStatus.ProtoReflect.Descriptor instead.

func (*AppStatus) GetReplicas added in v0.0.1 

func (x *AppStatus) GetReplicas() []*Replica

func (*AppStatus) ProtoMessage added in v0.0.1 

func (*AppStatus) ProtoMessage()

func (*AppStatus) ProtoReflect added in v0.0.1 

func (x *AppStatus) ProtoReflect() protoreflect.Message

func (*AppStatus) Reset added in v0.0.1 

func (x *AppStatus) Reset()

func (*AppStatus) String added in v0.0.1 

func (x *AppStatus) String() string

func (*AppStatus) Validate added in v0.0.1 

func (this *AppStatus) Validate() error

type AppUpdate 

type AppUpdate struct {

	// name of the application
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// application namespace
	Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// docker image of application
	Image string `protobuf:"bytes,3,opt,name=image,proto3" json:"image,omitempty"`
	// args are arguments given to the docker image at startup
	Args []string `protobuf:"bytes,4,rep,name=args,proto3" json:"args,omitempty"`
	// k/v map of environmental variables
	Env map[string]string `` /* 147-byte string literal not displayed */
	// k/v map of ports to expose ex: http: 80 https: 443
	Ports map[string]uint32 `` /* 152-byte string literal not displayed */
	// number of deployment replicas
	Replicas uint32 `protobuf:"varint,7,opt,name=replicas,proto3" json:"replicas,omitempty"`
	// contains filtered or unexported fields
}

AppUpdate updates an App

func (*AppUpdate) Descriptor deprecated 

func (*AppUpdate) Descriptor() ([]byte, []int)

Deprecated: Use AppUpdate.ProtoReflect.Descriptor instead.

func (*AppUpdate) GetArgs added in v0.0.1 

func (x *AppUpdate) GetArgs() []string

func (*AppUpdate) GetEnv 

func (x *AppUpdate) GetEnv() map[string]string

func (*AppUpdate) GetImage 

func (x *AppUpdate) GetImage() string

func (*AppUpdate) GetName 

func (x *AppUpdate) GetName() string

func (*AppUpdate) GetNamespace 

func (x *AppUpdate) GetNamespace() string

func (*AppUpdate) GetPorts 

func (x *AppUpdate) GetPorts() map[string]uint32

func (*AppUpdate) GetReplicas 

func (x *AppUpdate) GetReplicas() uint32

func (*AppUpdate) ProtoMessage 

func (*AppUpdate) ProtoMessage()

func (*AppUpdate) ProtoReflect 

func (x *AppUpdate) ProtoReflect() protoreflect.Message

func (*AppUpdate) Reset 

func (x *AppUpdate) Reset()

func (*AppUpdate) String 

func (x *AppUpdate) String() string

func (*AppUpdate) Validate 

func (this *AppUpdate) Validate() error

type Apps 

type Apps struct {
	Applications []*App `protobuf:"bytes,1,rep,name=applications,proto3" json:"applications,omitempty"`
	// contains filtered or unexported fields
}

func (*Apps) Descriptor deprecated 

func (*Apps) Descriptor() ([]byte, []int)

Deprecated: Use Apps.ProtoReflect.Descriptor instead.

func (*Apps) GetApplications 

func (x *Apps) GetApplications() []*App

func (*Apps) ProtoMessage 

func (*Apps) ProtoMessage()

func (*Apps) ProtoReflect 

func (x *Apps) ProtoReflect() protoreflect.Message

func (*Apps) Reset 

func (x *Apps) Reset()

func (*Apps) String 

func (x *Apps) String() string

func (*Apps) Validate 

func (this *Apps) Validate() error

type KdeployServiceClient 

type KdeployServiceClient interface {
	// CreateApp creates a new stateless application(k8s deployment & service) within a single namespace(k8s namespace)
	// the namespace will automatically be created if one does not already exist
	CreateApp(ctx context.Context, in *AppConstructor, opts ...grpc.CallOption) (*App, error)
	// UpdateApp edits/patches an existing stateless application(k8s deployment & service) within an existing namespace(k8s namespace)
	UpdateApp(ctx context.Context, in *AppUpdate, opts ...grpc.CallOption) (*App, error)
	// DeleteApp deletes a single stateless application(k8s deployment & service) within an existing namespace
	DeleteApp(ctx context.Context, in *Ref, opts ...grpc.CallOption) (*empty.Empty, error)
	// GetApp gets an app by name within an existing namespace
	GetApp(ctx context.Context, in *Ref, opts ...grpc.CallOption) (*App, error)
	// ListApps lists all apps within an existing namespace
	ListApps(ctx context.Context, in *Namespace, opts ...grpc.CallOption) (*Apps, error)
	// ListNamespaces lists all namespaces created by kdeploy
	ListNamespaces(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*Namespaces, error)
	// DeleteAll deletes all apps/tasks within an existing namespace
	DeleteAll(ctx context.Context, in *Namespace, opts ...grpc.CallOption) (*empty.Empty, error)
	// CreateTask creates a new task(k8s cron job) within a single namespace(k8s namespace)
	// the namespace will automatically be created if one does not already exist
	CreateTask(ctx context.Context, in *TaskConstructor, opts ...grpc.CallOption) (*Task, error)
	// UpdateTask edits/patches an existing task(k8s cron job) within an existing namespace(k8s namespace)
	UpdateTask(ctx context.Context, in *TaskUpdate, opts ...grpc.CallOption) (*Task, error)
	// DeleteTask deletes a single task(k8s cron job) within an existing namespace
	DeleteTask(ctx context.Context, in *Ref, opts ...grpc.CallOption) (*empty.Empty, error)
	// GetTask gets a task(k8s cron job) by name within an existing namespace
	GetTask(ctx context.Context, in *Ref, opts ...grpc.CallOption) (*Task, error)
	// ListTasks lists all tasks(k8s cron jobs) within an existing namespace
	ListTasks(ctx context.Context, in *Namespace, opts ...grpc.CallOption) (*Tasks, error)
	// StreamLogs streams logs from an app/task within an existing namespace.
	// Streams are opened to all replicas & converted into a single stream
	StreamLogs(ctx context.Context, in *Ref, opts ...grpc.CallOption) (KdeployService_StreamLogsClient, error)
}

KdeployServiceClient is the client API for KdeployService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewKdeployServiceClient 

func NewKdeployServiceClient(cc grpc.ClientConnInterface) KdeployServiceClient

type KdeployServiceServer 

type KdeployServiceServer interface {
	// CreateApp creates a new stateless application(k8s deployment & service) within a single namespace(k8s namespace)
	// the namespace will automatically be created if one does not already exist
	CreateApp(context.Context, *AppConstructor) (*App, error)
	// UpdateApp edits/patches an existing stateless application(k8s deployment & service) within an existing namespace(k8s namespace)
	UpdateApp(context.Context, *AppUpdate) (*App, error)
	// DeleteApp deletes a single stateless application(k8s deployment & service) within an existing namespace
	DeleteApp(context.Context, *Ref) (*empty.Empty, error)
	// GetApp gets an app by name within an existing namespace
	GetApp(context.Context, *Ref) (*App, error)
	// ListApps lists all apps within an existing namespace
	ListApps(context.Context, *Namespace) (*Apps, error)
	// ListNamespaces lists all namespaces created by kdeploy
	ListNamespaces(context.Context, *empty.Empty) (*Namespaces, error)
	// DeleteAll deletes all apps/tasks within an existing namespace
	DeleteAll(context.Context, *Namespace) (*empty.Empty, error)
	// CreateTask creates a new task(k8s cron job) within a single namespace(k8s namespace)
	// the namespace will automatically be created if one does not already exist
	CreateTask(context.Context, *TaskConstructor) (*Task, error)
	// UpdateTask edits/patches an existing task(k8s cron job) within an existing namespace(k8s namespace)
	UpdateTask(context.Context, *TaskUpdate) (*Task, error)
	// DeleteTask deletes a single task(k8s cron job) within an existing namespace
	DeleteTask(context.Context, *Ref) (*empty.Empty, error)
	// GetTask gets a task(k8s cron job) by name within an existing namespace
	GetTask(context.Context, *Ref) (*Task, error)
	// ListTasks lists all tasks(k8s cron jobs) within an existing namespace
	ListTasks(context.Context, *Namespace) (*Tasks, error)
	// StreamLogs streams logs from an app/task within an existing namespace.
	// Streams are opened to all replicas & converted into a single stream
	StreamLogs(*Ref, KdeployService_StreamLogsServer) error
}

KdeployServiceServer is the server API for KdeployService service.

type KdeployService_StreamLogsClient added in v0.0.4 

type KdeployService_StreamLogsClient interface {
	Recv() (*Log, error)
	grpc.ClientStream
}

type KdeployService_StreamLogsServer added in v0.0.4 

type KdeployService_StreamLogsServer interface {
	Send(*Log) error
	grpc.ServerStream
}

type Log 

type Log struct {
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*Log) Descriptor deprecated 

func (*Log) Descriptor() ([]byte, []int)

Deprecated: Use Log.ProtoReflect.Descriptor instead.

func (*Log) GetMessage 

func (x *Log) GetMessage() string

func (*Log) ProtoMessage 

func (*Log) ProtoMessage()

func (*Log) ProtoReflect 

func (x *Log) ProtoReflect() protoreflect.Message

func (*Log) Reset 

func (x *Log) Reset()

func (*Log) String 

func (x *Log) String() string

func (*Log) Validate 

func (this *Log) Validate() error

type Namespace 

type Namespace struct {
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// contains filtered or unexported fields
}

func (*Namespace) Descriptor deprecated 

func (*Namespace) Descriptor() ([]byte, []int)

Deprecated: Use Namespace.ProtoReflect.Descriptor instead.

func (*Namespace) GetNamespace 

func (x *Namespace) GetNamespace() string

func (*Namespace) ProtoMessage 

func (*Namespace) ProtoMessage()

func (*Namespace) ProtoReflect 

func (x *Namespace) ProtoReflect() protoreflect.Message

func (*Namespace) Reset 

func (x *Namespace) Reset()

func (*Namespace) String 

func (x *Namespace) String() string

func (*Namespace) Validate 

func (this *Namespace) Validate() error

type Namespaces 

type Namespaces struct {
	Namespaces []string `protobuf:"bytes,1,rep,name=namespaces,proto3" json:"namespaces,omitempty"`
	// contains filtered or unexported fields
}

func (*Namespaces) Descriptor deprecated 

func (*Namespaces) Descriptor() ([]byte, []int)

Deprecated: Use Namespaces.ProtoReflect.Descriptor instead.

func (*Namespaces) GetNamespaces 

func (x *Namespaces) GetNamespaces() []string

func (*Namespaces) ProtoMessage 

func (*Namespaces) ProtoMessage()

func (*Namespaces) ProtoReflect 

func (x *Namespaces) ProtoReflect() protoreflect.Message

func (*Namespaces) Reset 

func (x *Namespaces) Reset()

func (*Namespaces) String 

func (x *Namespaces) String() string

func (*Namespaces) Validate 

func (this *Namespaces) Validate() error

type Ref added in v0.0.1 

type Ref struct {

	// name of the application
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// application namespace
	Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// contains filtered or unexported fields
}

func (*Ref) Descriptor deprecated added in v0.0.1 

func (*Ref) Descriptor() ([]byte, []int)

Deprecated: Use Ref.ProtoReflect.Descriptor instead.

func (*Ref) GetName added in v0.0.1 

func (x *Ref) GetName() string

func (*Ref) GetNamespace added in v0.0.1 

func (x *Ref) GetNamespace() string

func (*Ref) ProtoMessage added in v0.0.1 

func (*Ref) ProtoMessage()

func (*Ref) ProtoReflect added in v0.0.1 

func (x *Ref) ProtoReflect() protoreflect.Message

func (*Ref) Reset added in v0.0.1 

func (x *Ref) Reset()

func (*Ref) String added in v0.0.1 

func (x *Ref) String() string

func (*Ref) Validate added in v0.0.1 

func (this *Ref) Validate() error

type Replica 

type Replica struct {
	Phase     string `protobuf:"bytes,1,opt,name=phase,proto3" json:"phase,omitempty"`
	Condition string `protobuf:"bytes,2,opt,name=condition,proto3" json:"condition,omitempty"`
	Reason    string `protobuf:"bytes,3,opt,name=reason,proto3" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

func (*Replica) Descriptor deprecated 

func (*Replica) Descriptor() ([]byte, []int)

Deprecated: Use Replica.ProtoReflect.Descriptor instead.

func (*Replica) GetCondition 

func (x *Replica) GetCondition() string

func (*Replica) GetPhase 

func (x *Replica) GetPhase() string

func (*Replica) GetReason 

func (x *Replica) GetReason() string

func (*Replica) ProtoMessage 

func (*Replica) ProtoMessage()

func (*Replica) ProtoReflect 

func (x *Replica) ProtoReflect() protoreflect.Message

func (*Replica) Reset 

func (x *Replica) Reset()

func (*Replica) String 

func (x *Replica) String() string

func (*Replica) Validate 

func (this *Replica) Validate() error

type Task added in v0.0.1 

type Task struct {

	// name of the task
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// task namespace
	Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// docker image of task
	Image string `protobuf:"bytes,3,opt,name=image,proto3" json:"image,omitempty"`
	// args are arguments given to docker image at startup
	Args []string `protobuf:"bytes,5,rep,name=args,proto3" json:"args,omitempty"`
	// k/v map of environmental variables
	Env map[string]string `` /* 147-byte string literal not displayed */
	// schedule is the cron schedule: https://kubernetes.io/docs/concepts/workloads/controllers/cron-jobs/
	Schedule string `protobuf:"bytes,7,opt,name=schedule,proto3" json:"schedule,omitempty"`
	// completions is the number of times to execute the task. If completions = 0, the task will run forever
	Completions uint32 `protobuf:"varint,8,opt,name=completions,proto3" json:"completions,omitempty"`
	// contains filtered or unexported fields
}

Task is scheduled cron job

func (*Task) Descriptor deprecated added in v0.0.1 

func (*Task) Descriptor() ([]byte, []int)

Deprecated: Use Task.ProtoReflect.Descriptor instead.

func (*Task) GetArgs added in v0.0.1 

func (x *Task) GetArgs() []string

func (*Task) GetCompletions added in v0.0.1 

func (x *Task) GetCompletions() uint32

func (*Task) GetEnv added in v0.0.1 

func (x *Task) GetEnv() map[string]string

func (*Task) GetImage added in v0.0.1 

func (x *Task) GetImage() string

func (*Task) GetName added in v0.0.1 

func (x *Task) GetName() string

func (*Task) GetNamespace added in v0.0.1 

func (x *Task) GetNamespace() string

func (*Task) GetSchedule added in v0.0.1 

func (x *Task) GetSchedule() string

func (*Task) ProtoMessage added in v0.0.1 

func (*Task) ProtoMessage()

func (*Task) ProtoReflect added in v0.0.1 

func (x *Task) ProtoReflect() protoreflect.Message

func (*Task) Reset added in v0.0.1 

func (x *Task) Reset()

func (*Task) String added in v0.0.1 

func (x *Task) String() string

func (*Task) Validate added in v0.0.1 

func (this *Task) Validate() error

type TaskConstructor added in v0.0.1 

type TaskConstructor struct {

	// name of the task
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// task namespace
	Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// docker image of task
	Image string `protobuf:"bytes,3,opt,name=image,proto3" json:"image,omitempty"`
	// args are arguments given to docker image at startup
	Args []string `protobuf:"bytes,5,rep,name=args,proto3" json:"args,omitempty"`
	// k/v map of environmental variables
	Env map[string]string `` /* 147-byte string literal not displayed */
	// schedule is the cron schedule: https://kubernetes.io/docs/concepts/workloads/controllers/cron-jobs/
	Schedule string `protobuf:"bytes,7,opt,name=schedule,proto3" json:"schedule,omitempty"`
	// completions is the number of times to execute the task. If completions = 0, the task will run forever
	Completions uint32 `protobuf:"varint,8,opt,name=completions,proto3" json:"completions,omitempty"`
	// contains filtered or unexported fields
}

TaskConstructor creates a task(cron job)

func (*TaskConstructor) Descriptor deprecated added in v0.0.1 

func (*TaskConstructor) Descriptor() ([]byte, []int)

Deprecated: Use TaskConstructor.ProtoReflect.Descriptor instead.

func (*TaskConstructor) GetArgs added in v0.0.1 

func (x *TaskConstructor) GetArgs() []string

func (*TaskConstructor) GetCompletions added in v0.0.4 

func (x *TaskConstructor) GetCompletions() uint32

func (*TaskConstructor) GetEnv added in v0.0.1 

func (x *TaskConstructor) GetEnv() map[string]string

func (*TaskConstructor) GetImage added in v0.0.1 

func (x *TaskConstructor) GetImage() string

func (*TaskConstructor) GetName added in v0.0.1 

func (x *TaskConstructor) GetName() string

func (*TaskConstructor) GetNamespace added in v0.0.1 

func (x *TaskConstructor) GetNamespace() string

func (*TaskConstructor) GetSchedule added in v0.0.1 

func (x *TaskConstructor) GetSchedule() string

func (*TaskConstructor) ProtoMessage added in v0.0.1 

func (*TaskConstructor) ProtoMessage()

func (*TaskConstructor) ProtoReflect added in v0.0.1 

func (x *TaskConstructor) ProtoReflect() protoreflect.Message

func (*TaskConstructor) Reset added in v0.0.1 

func (x *TaskConstructor) Reset()

func (*TaskConstructor) String added in v0.0.1 

func (x *TaskConstructor) String() string

func (*TaskConstructor) Validate added in v0.0.1 

func (this *TaskConstructor) Validate() error

type TaskUpdate added in v0.0.1 

type TaskUpdate struct {

	// name of the application
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// application namespace
	Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// docker image of application
	Image string `protobuf:"bytes,3,opt,name=image,proto3" json:"image,omitempty"`
	// args are arguments given to docker image at startup
	Args []string `protobuf:"bytes,5,rep,name=args,proto3" json:"args,omitempty"`
	// k/v map of environmental variables
	Env map[string]string `` /* 147-byte string literal not displayed */
	// schedule is the cron schedule: https://kubernetes.io/docs/concepts/workloads/controllers/cron-jobs/
	Schedule string `protobuf:"bytes,7,opt,name=schedule,proto3" json:"schedule,omitempty"`
	// completions is the number of times to execute the task. If completions = 0, the task will run forever
	Completions uint32 `protobuf:"varint,8,opt,name=completions,proto3" json:"completions,omitempty"`
	// contains filtered or unexported fields
}

TaskUpdate updates a task(cron job)

func (*TaskUpdate) Descriptor deprecated added in v0.0.1 

func (*TaskUpdate) Descriptor() ([]byte, []int)

Deprecated: Use TaskUpdate.ProtoReflect.Descriptor instead.

func (*TaskUpdate) GetArgs added in v0.0.1 

func (x *TaskUpdate) GetArgs() []string

func (*TaskUpdate) GetCompletions added in v0.0.4 

func (x *TaskUpdate) GetCompletions() uint32

func (*TaskUpdate) GetEnv added in v0.0.1 

func (x *TaskUpdate) GetEnv() map[string]string

func (*TaskUpdate) GetImage added in v0.0.1 

func (x *TaskUpdate) GetImage() string

func (*TaskUpdate) GetName added in v0.0.1 

func (x *TaskUpdate) GetName() string

func (*TaskUpdate) GetNamespace added in v0.0.1 

func (x *TaskUpdate) GetNamespace() string

func (*TaskUpdate) GetSchedule added in v0.0.1 

func (x *TaskUpdate) GetSchedule() string

func (*TaskUpdate) ProtoMessage added in v0.0.1 

func (*TaskUpdate) ProtoMessage()

func (*TaskUpdate) ProtoReflect added in v0.0.1 

func (x *TaskUpdate) ProtoReflect() protoreflect.Message

func (*TaskUpdate) Reset added in v0.0.1 

func (x *TaskUpdate) Reset()

func (*TaskUpdate) String added in v0.0.1 

func (x *TaskUpdate) String() string

func (*TaskUpdate) Validate added in v0.0.1 

func (this *TaskUpdate) Validate() error

type Tasks added in v0.0.1 

type Tasks struct {
	Tasks []*Task `protobuf:"bytes,1,rep,name=tasks,proto3" json:"tasks,omitempty"`
	// contains filtered or unexported fields
}

func (*Tasks) Descriptor deprecated added in v0.0.1 

func (*Tasks) Descriptor() ([]byte, []int)

Deprecated: Use Tasks.ProtoReflect.Descriptor instead.

func (*Tasks) GetTasks added in v0.0.1 

func (x *Tasks) GetTasks() []*Task

func (*Tasks) ProtoMessage added in v0.0.1 

func (*Tasks) ProtoMessage()

func (*Tasks) ProtoReflect added in v0.0.1 

func (x *Tasks) ProtoReflect() protoreflect.Message

func (*Tasks) Reset added in v0.0.1 

func (x *Tasks) Reset()

func (*Tasks) String added in v0.0.1 

func (x *Tasks) String() string

func (*Tasks) Validate added in v0.0.1 

func (this *Tasks) Validate() error

type UnimplementedKdeployServiceServer 

type UnimplementedKdeployServiceServer struct {
}

UnimplementedKdeployServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedKdeployServiceServer) CreateApp 

func (*UnimplementedKdeployServiceServer) CreateApp(context.Context, *AppConstructor) (*App, error)

func (*UnimplementedKdeployServiceServer) CreateTask added in v0.0.1 

func (*UnimplementedKdeployServiceServer) CreateTask(context.Context, *TaskConstructor) (*Task, error)

func (*UnimplementedKdeployServiceServer) DeleteAll added in v0.0.1 

func (*UnimplementedKdeployServiceServer) DeleteAll(context.Context, *Namespace) (*empty.Empty, error)

func (*UnimplementedKdeployServiceServer) DeleteApp 

func (*UnimplementedKdeployServiceServer) DeleteApp(context.Context, *Ref) (*empty.Empty, error)

func (*UnimplementedKdeployServiceServer) DeleteTask added in v0.0.1 

func (*UnimplementedKdeployServiceServer) DeleteTask(context.Context, *Ref) (*empty.Empty, error)

func (*UnimplementedKdeployServiceServer) GetApp 

func (*UnimplementedKdeployServiceServer) GetApp(context.Context, *Ref) (*App, error)

func (*UnimplementedKdeployServiceServer) GetTask added in v0.0.1 

func (*UnimplementedKdeployServiceServer) GetTask(context.Context, *Ref) (*Task, error)

func (*UnimplementedKdeployServiceServer) ListApps 

func (*UnimplementedKdeployServiceServer) ListApps(context.Context, *Namespace) (*Apps, error)

func (*UnimplementedKdeployServiceServer) ListNamespaces 

func (*UnimplementedKdeployServiceServer) ListNamespaces(context.Context, *empty.Empty) (*Namespaces, error)

func (*UnimplementedKdeployServiceServer) ListTasks added in v0.0.1 

func (*UnimplementedKdeployServiceServer) ListTasks(context.Context, *Namespace) (*Tasks, error)

func (*UnimplementedKdeployServiceServer) StreamLogs added in v0.0.4 

func (*UnimplementedKdeployServiceServer) StreamLogs(*Ref, KdeployService_StreamLogsServer) error

func (*UnimplementedKdeployServiceServer) UpdateApp 

func (*UnimplementedKdeployServiceServer) UpdateApp(context.Context, *AppUpdate) (*App, error)

func (*UnimplementedKdeployServiceServer) UpdateTask added in v0.0.1 

func (*UnimplementedKdeployServiceServer) UpdateTask(context.Context, *TaskUpdate) (*Task, error)

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.