Documentation
¶
Index ¶
- Variables
- func RegisterKdeployServiceServer(s *grpc.Server, srv KdeployServiceServer)
- type App
- func (*App) Descriptor() ([]byte, []int)deprecated
- func (x *App) GetArgs() []string
- func (x *App) GetEnv() map[string]string
- func (x *App) GetImage() string
- func (x *App) GetLabels() map[string]string
- func (x *App) GetName() string
- func (x *App) GetNamespace() string
- func (x *App) GetNetworking() *Networking
- func (x *App) GetPorts() map[string]uint32
- func (x *App) GetReplicas() uint32
- func (x *App) GetSelector() map[string]string
- func (x *App) GetStatus() *AppStatus
- func (*App) ProtoMessage()
- func (x *App) ProtoReflect() protoreflect.Message
- func (x *App) Reset()
- func (x *App) String() string
- func (this *App) Validate() error
- type AppInput
- func (*AppInput) Descriptor() ([]byte, []int)deprecated
- func (x *AppInput) GetArgs() []string
- func (x *AppInput) GetEnv() map[string]string
- func (x *AppInput) GetImage() string
- func (x *AppInput) GetLabels() map[string]string
- func (x *AppInput) GetName() string
- func (x *AppInput) GetNamespace() string
- func (x *AppInput) GetNetworking() *Networking
- func (x *AppInput) GetPorts() map[string]uint32
- func (x *AppInput) GetReplicas() uint32
- func (x *AppInput) GetSelector() map[string]string
- func (*AppInput) ProtoMessage()
- func (x *AppInput) ProtoReflect() protoreflect.Message
- func (x *AppInput) Reset()
- func (x *AppInput) String() string
- func (this *AppInput) Validate() error
- type AppStatus
- type Apps
- type Gateway
- func (*Gateway) Descriptor() ([]byte, []int)deprecated
- func (x *Gateway) GetLabels() map[string]string
- func (x *Gateway) GetListeners() []*GatewayListener
- func (x *Gateway) GetName() string
- func (x *Gateway) GetNamespace() string
- func (x *Gateway) GetSelector() map[string]string
- func (*Gateway) ProtoMessage()
- func (x *Gateway) ProtoReflect() protoreflect.Message
- func (x *Gateway) Reset()
- func (x *Gateway) String() string
- func (this *Gateway) Validate() error
- type GatewayInput
- func (*GatewayInput) Descriptor() ([]byte, []int)deprecated
- func (x *GatewayInput) GetLabels() map[string]string
- func (x *GatewayInput) GetListeners() []*GatewayListener
- func (x *GatewayInput) GetName() string
- func (x *GatewayInput) GetNamespace() string
- func (x *GatewayInput) GetSelector() map[string]string
- func (*GatewayInput) ProtoMessage()
- func (x *GatewayInput) ProtoReflect() protoreflect.Message
- func (x *GatewayInput) Reset()
- func (x *GatewayInput) String() string
- func (this *GatewayInput) Validate() error
- type GatewayListener
- func (*GatewayListener) Descriptor() ([]byte, []int)deprecated
- func (x *GatewayListener) GetHosts() []string
- func (x *GatewayListener) GetName() string
- func (x *GatewayListener) GetPort() uint32
- func (x *GatewayListener) GetProtocol() Protocol
- func (x *GatewayListener) GetTlsConfig() *ServerTLSSettings
- func (*GatewayListener) ProtoMessage()
- func (x *GatewayListener) ProtoReflect() protoreflect.Message
- func (x *GatewayListener) Reset()
- func (x *GatewayListener) String() string
- func (this *GatewayListener) Validate() error
- type HTTPRoute
- func (*HTTPRoute) Descriptor() ([]byte, []int)deprecated
- func (x *HTTPRoute) GetAllowCredentials() bool
- func (x *HTTPRoute) GetAllowHeaders() []string
- func (x *HTTPRoute) GetAllowMethods() []string
- func (x *HTTPRoute) GetAllowOrigins() []string
- func (x *HTTPRoute) GetExposeHeaders() []string
- func (x *HTTPRoute) GetName() string
- func (x *HTTPRoute) GetPathPrefix() string
- func (x *HTTPRoute) GetPort() uint32
- func (x *HTTPRoute) GetRewriteUri() string
- func (*HTTPRoute) ProtoMessage()
- func (x *HTTPRoute) ProtoReflect() protoreflect.Message
- func (x *HTTPRoute) Reset()
- func (x *HTTPRoute) String() string
- func (this *HTTPRoute) Validate() error
- type KdeployServiceClient
- type KdeployServiceServer
- type KdeployService_StreamLogsClient
- type KdeployService_StreamLogsServer
- type Log
- type Namespace
- type Namespaces
- func (*Namespaces) Descriptor() ([]byte, []int)deprecated
- func (x *Namespaces) GetNamespaces() []string
- func (*Namespaces) ProtoMessage()
- func (x *Namespaces) ProtoReflect() protoreflect.Message
- func (x *Namespaces) Reset()
- func (x *Namespaces) String() string
- func (this *Namespaces) Validate() error
- type Networking
- func (*Networking) Descriptor() ([]byte, []int)deprecated
- func (x *Networking) GetExport() bool
- func (x *Networking) GetGateways() []string
- func (x *Networking) GetHosts() []string
- func (x *Networking) GetHttpRoutes() []*HTTPRoute
- func (*Networking) ProtoMessage()
- func (x *Networking) ProtoReflect() protoreflect.Message
- func (x *Networking) Reset()
- func (x *Networking) String() string
- func (this *Networking) Validate() error
- type Protocol
- type Ref
- type Replica
- func (*Replica) Descriptor() ([]byte, []int)deprecated
- func (x *Replica) GetCondition() string
- func (x *Replica) GetPhase() string
- func (x *Replica) GetReason() string
- func (*Replica) ProtoMessage()
- func (x *Replica) ProtoReflect() protoreflect.Message
- func (x *Replica) Reset()
- func (x *Replica) String() string
- func (this *Replica) Validate() error
- type ServerTLSSettings
- func (*ServerTLSSettings) Descriptor() ([]byte, []int)deprecated
- func (x *ServerTLSSettings) GetCaCertificates() string
- func (x *ServerTLSSettings) GetCipherSuites() []string
- func (x *ServerTLSSettings) GetCredentialName() string
- func (x *ServerTLSSettings) GetHttpsRedirect() bool
- func (x *ServerTLSSettings) GetMode() TLSmode
- func (x *ServerTLSSettings) GetPrivateKey() string
- func (x *ServerTLSSettings) GetServerCertificate() string
- func (x *ServerTLSSettings) GetSubjectAltNames() []string
- func (x *ServerTLSSettings) GetVerifyCertificateHash() []string
- func (x *ServerTLSSettings) GetVerifyCertificateSpki() []string
- func (*ServerTLSSettings) ProtoMessage()
- func (x *ServerTLSSettings) ProtoReflect() protoreflect.Message
- func (x *ServerTLSSettings) Reset()
- func (x *ServerTLSSettings) String() string
- func (this *ServerTLSSettings) Validate() error
- type TLSmode
- type Task
- func (*Task) Descriptor() ([]byte, []int)deprecated
- func (x *Task) GetArgs() []string
- func (x *Task) GetCompletions() uint32
- func (x *Task) GetEnv() map[string]string
- func (x *Task) GetImage() string
- func (x *Task) GetLabels() map[string]string
- func (x *Task) GetName() string
- func (x *Task) GetNamespace() string
- func (x *Task) GetSchedule() string
- func (x *Task) GetSelector() map[string]string
- func (*Task) ProtoMessage()
- func (x *Task) ProtoReflect() protoreflect.Message
- func (x *Task) Reset()
- func (x *Task) String() string
- func (this *Task) Validate() error
- type TaskInput
- func (*TaskInput) Descriptor() ([]byte, []int)deprecated
- func (x *TaskInput) GetArgs() []string
- func (x *TaskInput) GetCompletions() uint32
- func (x *TaskInput) GetEnv() map[string]string
- func (x *TaskInput) GetImage() string
- func (x *TaskInput) GetLabels() map[string]string
- func (x *TaskInput) GetName() string
- func (x *TaskInput) GetNamespace() string
- func (x *TaskInput) GetSchedule() string
- func (x *TaskInput) GetSelector() map[string]string
- func (*TaskInput) ProtoMessage()
- func (x *TaskInput) ProtoReflect() protoreflect.Message
- func (x *TaskInput) Reset()
- func (x *TaskInput) String() string
- func (this *TaskInput) Validate() error
- type Tasks
- type UnimplementedKdeployServiceServer
- func (*UnimplementedKdeployServiceServer) CreateApp(context.Context, *AppInput) (*App, error)
- func (*UnimplementedKdeployServiceServer) CreateGateway(context.Context, *GatewayInput) (*Gateway, error)
- func (*UnimplementedKdeployServiceServer) CreateTask(context.Context, *TaskInput) (*Task, error)
- func (*UnimplementedKdeployServiceServer) DeleteAll(context.Context, *Namespace) (*empty.Empty, error)
- func (*UnimplementedKdeployServiceServer) DeleteApp(context.Context, *Ref) (*empty.Empty, error)
- func (*UnimplementedKdeployServiceServer) DeleteGateway(context.Context, *Ref) (*empty.Empty, error)
- func (*UnimplementedKdeployServiceServer) DeleteTask(context.Context, *Ref) (*empty.Empty, error)
- func (*UnimplementedKdeployServiceServer) GetApp(context.Context, *Ref) (*App, error)
- func (*UnimplementedKdeployServiceServer) GetGateway(context.Context, *Ref) (*Gateway, error)
- func (*UnimplementedKdeployServiceServer) GetTask(context.Context, *Ref) (*Task, error)
- func (*UnimplementedKdeployServiceServer) ListApps(context.Context, *Namespace) (*Apps, error)
- func (*UnimplementedKdeployServiceServer) ListNamespaces(context.Context, *empty.Empty) (*Namespaces, error)
- func (*UnimplementedKdeployServiceServer) ListTasks(context.Context, *Namespace) (*Tasks, error)
- func (*UnimplementedKdeployServiceServer) StreamLogs(*Ref, KdeployService_StreamLogsServer) error
- func (*UnimplementedKdeployServiceServer) UpdateApp(context.Context, *AppInput) (*App, error)
- func (*UnimplementedKdeployServiceServer) UpdateGateway(context.Context, *GatewayInput) (*Gateway, error)
- func (*UnimplementedKdeployServiceServer) UpdateTask(context.Context, *TaskInput) (*Task, error)
Constants ¶
This section is empty.
Variables ¶
var ( Protocol_name = map[int32]string{ 0: "INVALID_PROTOCOL", 1: "HTTP", 2: "HTTPS", 3: "GRPC", 4: "HTTP2", 5: "MONGO", 6: "TCP", 7: "TLS", } Protocol_value = map[string]int32{ "INVALID_PROTOCOL": 0, "HTTP": 1, "HTTPS": 2, "GRPC": 3, "HTTP2": 4, "MONGO": 5, "TCP": 6, "TLS": 7, } )
Enum value maps for Protocol.
var ( TLSmode_name = map[int32]string{ 0: "PASSTHROUGH", 1: "SIMPLE", 2: "MUTUAL", 3: "AUTO_PASSTHROUGH", 4: "ISTIO_MUTUAL", } TLSmode_value = map[string]int32{ "PASSTHROUGH": 0, "SIMPLE": 1, "MUTUAL": 2, "AUTO_PASSTHROUGH": 3, "ISTIO_MUTUAL": 4, } )
Enum value maps for TLSmode.
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"`
Labels map[string]string `` /* 153-byte string literal not displayed */
Selector map[string]string `` /* 158-byte string literal not displayed */
// gateway/service-mesh networking
Networking *Networking `protobuf:"bytes,11,opt,name=networking,proto3" json:"networking,omitempty"`
// status tracks the state of the application during it's lifecycle
Status *AppStatus `protobuf:"bytes,20,opt,name=status,proto3" json:"status,omitempty"`
// contains filtered or unexported fields
}
App is a stateless application
func (*App) Descriptor
deprecated
func (*App) GetNamespace ¶
func (*App) GetNetworking ¶ added in v0.0.6
func (x *App) GetNetworking() *Networking
func (*App) GetReplicas ¶
func (*App) GetSelector ¶ added in v0.0.11
func (*App) ProtoMessage ¶
func (*App) ProtoMessage()
func (*App) ProtoReflect ¶
func (x *App) ProtoReflect() protoreflect.Message
type AppInput ¶ added in v0.0.8
type AppInput 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"`
Networking *Networking `protobuf:"bytes,9,opt,name=networking,proto3" json:"networking,omitempty"`
Labels map[string]string `` /* 154-byte string literal not displayed */
Selector map[string]string `` /* 158-byte string literal not displayed */
// contains filtered or unexported fields
}
AppInput creates/replaces an app
func (*AppInput) Descriptor
deprecated
added in
v0.0.8
func (*AppInput) GetNamespace ¶ added in v0.0.8
func (*AppInput) GetNetworking ¶ added in v0.0.8
func (x *AppInput) GetNetworking() *Networking
func (*AppInput) GetReplicas ¶ added in v0.0.8
func (*AppInput) GetSelector ¶ added in v0.0.11
func (*AppInput) ProtoMessage ¶ added in v0.0.8
func (*AppInput) ProtoMessage()
func (*AppInput) ProtoReflect ¶ added in v0.0.8
func (x *AppInput) ProtoReflect() protoreflect.Message
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) GetReplicas ¶ added in v0.0.1
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
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) GetApplications ¶
func (*Apps) ProtoMessage ¶
func (*Apps) ProtoMessage()
func (*Apps) ProtoReflect ¶
func (x *Apps) ProtoReflect() protoreflect.Message
type Gateway ¶ added in v0.0.9
type Gateway 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"`
Listeners []*GatewayListener `protobuf:"bytes,3,rep,name=listeners,proto3" json:"listeners,omitempty"`
Labels map[string]string `` /* 153-byte string literal not displayed */
Selector map[string]string `` /* 157-byte string literal not displayed */
// contains filtered or unexported fields
}
func (*Gateway) Descriptor
deprecated
added in
v0.0.9
func (*Gateway) GetListeners ¶ added in v0.0.9
func (x *Gateway) GetListeners() []*GatewayListener
func (*Gateway) GetNamespace ¶ added in v0.0.9
func (*Gateway) GetSelector ¶ added in v0.0.11
func (*Gateway) ProtoMessage ¶ added in v0.0.9
func (*Gateway) ProtoMessage()
func (*Gateway) ProtoReflect ¶ added in v0.0.9
func (x *Gateway) ProtoReflect() protoreflect.Message
type GatewayInput ¶ added in v0.0.9
type GatewayInput 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"`
Listeners []*GatewayListener `protobuf:"bytes,3,rep,name=listeners,proto3" json:"listeners,omitempty"`
Labels map[string]string `` /* 153-byte string literal not displayed */
Selector map[string]string `` /* 157-byte string literal not displayed */
// contains filtered or unexported fields
}
func (*GatewayInput) Descriptor
deprecated
added in
v0.0.9
func (*GatewayInput) Descriptor() ([]byte, []int)
Deprecated: Use GatewayInput.ProtoReflect.Descriptor instead.
func (*GatewayInput) GetLabels ¶ added in v0.0.9
func (x *GatewayInput) GetLabels() map[string]string
func (*GatewayInput) GetListeners ¶ added in v0.0.9
func (x *GatewayInput) GetListeners() []*GatewayListener
func (*GatewayInput) GetName ¶ added in v0.0.9
func (x *GatewayInput) GetName() string
func (*GatewayInput) GetNamespace ¶ added in v0.0.9
func (x *GatewayInput) GetNamespace() string
func (*GatewayInput) GetSelector ¶ added in v0.0.11
func (x *GatewayInput) GetSelector() map[string]string
func (*GatewayInput) ProtoMessage ¶ added in v0.0.9
func (*GatewayInput) ProtoMessage()
func (*GatewayInput) ProtoReflect ¶ added in v0.0.9
func (x *GatewayInput) ProtoReflect() protoreflect.Message
func (*GatewayInput) Reset ¶ added in v0.0.9
func (x *GatewayInput) Reset()
func (*GatewayInput) String ¶ added in v0.0.9
func (x *GatewayInput) String() string
func (*GatewayInput) Validate ¶ added in v0.0.9
func (this *GatewayInput) Validate() error
type GatewayListener ¶ added in v0.0.9
type GatewayListener struct {
Port uint32 `protobuf:"varint,1,opt,name=port,proto3" json:"port,omitempty"`
Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
Protocol Protocol `protobuf:"varint,3,opt,name=protocol,proto3,enum=kdeploy.Protocol" json:"protocol,omitempty"`
Hosts []string `protobuf:"bytes,4,rep,name=hosts,proto3" json:"hosts,omitempty"`
TlsConfig *ServerTLSSettings `protobuf:"bytes,5,opt,name=tls_config,json=tlsConfig,proto3" json:"tls_config,omitempty"`
// contains filtered or unexported fields
}
func (*GatewayListener) Descriptor
deprecated
added in
v0.0.9
func (*GatewayListener) Descriptor() ([]byte, []int)
Deprecated: Use GatewayListener.ProtoReflect.Descriptor instead.
func (*GatewayListener) GetHosts ¶ added in v0.0.9
func (x *GatewayListener) GetHosts() []string
func (*GatewayListener) GetName ¶ added in v0.0.9
func (x *GatewayListener) GetName() string
func (*GatewayListener) GetPort ¶ added in v0.0.9
func (x *GatewayListener) GetPort() uint32
func (*GatewayListener) GetProtocol ¶ added in v0.0.9
func (x *GatewayListener) GetProtocol() Protocol
func (*GatewayListener) GetTlsConfig ¶ added in v0.0.9
func (x *GatewayListener) GetTlsConfig() *ServerTLSSettings
func (*GatewayListener) ProtoMessage ¶ added in v0.0.9
func (*GatewayListener) ProtoMessage()
func (*GatewayListener) ProtoReflect ¶ added in v0.0.9
func (x *GatewayListener) ProtoReflect() protoreflect.Message
func (*GatewayListener) Reset ¶ added in v0.0.9
func (x *GatewayListener) Reset()
func (*GatewayListener) String ¶ added in v0.0.9
func (x *GatewayListener) String() string
func (*GatewayListener) Validate ¶ added in v0.0.9
func (this *GatewayListener) Validate() error
type HTTPRoute ¶ added in v0.0.7
type HTTPRoute struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
Port uint32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
PathPrefix string `protobuf:"bytes,3,opt,name=path_prefix,json=pathPrefix,proto3" json:"path_prefix,omitempty"`
RewriteUri string `protobuf:"bytes,4,opt,name=rewrite_uri,json=rewriteUri,proto3" json:"rewrite_uri,omitempty"`
// The list of origins that are allowed to perform CORS requests
AllowOrigins []string `protobuf:"bytes,5,rep,name=allow_origins,json=allowOrigins,proto3" json:"allow_origins,omitempty"`
// The list of methods that are allowed to perform CORS requests
AllowMethods []string `protobuf:"bytes,6,rep,name=allow_methods,json=allowMethods,proto3" json:"allow_methods,omitempty"`
// The list of headers that are allowed to perform CORS requests
AllowHeaders []string `protobuf:"bytes,7,rep,name=allow_headers,json=allowHeaders,proto3" json:"allow_headers,omitempty"`
// The list of origins that are allowed to perform CORS requests
ExposeHeaders []string `protobuf:"bytes,8,rep,name=expose_headers,json=exposeHeaders,proto3" json:"expose_headers,omitempty"`
// adds `Access-Control-Allow-Credentials` header
AllowCredentials bool `protobuf:"varint,9,opt,name=allow_credentials,json=allowCredentials,proto3" json:"allow_credentials,omitempty"`
// contains filtered or unexported fields
}
HTTPRoute is a single http route(istio HttpRoute)
func (*HTTPRoute) Descriptor
deprecated
added in
v0.0.7
func (*HTTPRoute) GetAllowCredentials ¶ added in v0.0.7
func (*HTTPRoute) GetAllowHeaders ¶ added in v0.0.7
func (*HTTPRoute) GetAllowMethods ¶ added in v0.0.7
func (*HTTPRoute) GetAllowOrigins ¶ added in v0.0.7
func (*HTTPRoute) GetExposeHeaders ¶ added in v0.0.7
func (*HTTPRoute) GetPathPrefix ¶ added in v0.0.7
func (*HTTPRoute) GetRewriteUri ¶ added in v0.0.7
func (*HTTPRoute) ProtoMessage ¶ added in v0.0.7
func (*HTTPRoute) ProtoMessage()
func (*HTTPRoute) ProtoReflect ¶ added in v0.0.7
func (x *HTTPRoute) ProtoReflect() protoreflect.Message
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 *AppInput, 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 *AppInput, 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 *TaskInput, 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 *TaskInput, 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)
CreateGateway(ctx context.Context, in *GatewayInput, opts ...grpc.CallOption) (*Gateway, error)
UpdateGateway(ctx context.Context, in *GatewayInput, opts ...grpc.CallOption) (*Gateway, error)
DeleteGateway(ctx context.Context, in *Ref, opts ...grpc.CallOption) (*empty.Empty, error)
GetGateway(ctx context.Context, in *Ref, opts ...grpc.CallOption) (*Gateway, 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, *AppInput) (*App, error)
// UpdateApp edits/patches an existing stateless application(k8s deployment & service) within an existing namespace(k8s namespace)
UpdateApp(context.Context, *AppInput) (*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, *TaskInput) (*Task, error)
// UpdateTask edits/patches an existing task(k8s cron job) within an existing namespace(k8s namespace)
UpdateTask(context.Context, *TaskInput) (*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
CreateGateway(context.Context, *GatewayInput) (*Gateway, error)
UpdateGateway(context.Context, *GatewayInput) (*Gateway, error)
DeleteGateway(context.Context, *Ref) (*empty.Empty, error)
GetGateway(context.Context, *Ref) (*Gateway, 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) GetMessage ¶
func (*Log) ProtoMessage ¶
func (*Log) ProtoMessage()
func (*Log) ProtoReflect ¶
func (x *Log) ProtoReflect() protoreflect.Message
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) GetNamespace ¶
func (*Namespace) ProtoMessage ¶
func (*Namespace) ProtoMessage()
func (*Namespace) ProtoReflect ¶
func (x *Namespace) ProtoReflect() protoreflect.Message
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 Networking ¶ added in v0.0.6
type Networking struct {
Gateways []string `protobuf:"bytes,1,rep,name=gateways,proto3" json:"gateways,omitempty"`
Hosts []string `protobuf:"bytes,2,rep,name=hosts,proto3" json:"hosts,omitempty"`
Export bool `protobuf:"varint,3,opt,name=export,proto3" json:"export,omitempty"`
HttpRoutes []*HTTPRoute `protobuf:"bytes,4,rep,name=http_routes,json=httpRoutes,proto3" json:"http_routes,omitempty"`
// contains filtered or unexported fields
}
func (*Networking) Descriptor
deprecated
added in
v0.0.6
func (*Networking) Descriptor() ([]byte, []int)
Deprecated: Use Networking.ProtoReflect.Descriptor instead.
func (*Networking) GetExport ¶ added in v0.0.6
func (x *Networking) GetExport() bool
func (*Networking) GetGateways ¶ added in v0.0.6
func (x *Networking) GetGateways() []string
func (*Networking) GetHosts ¶ added in v0.0.6
func (x *Networking) GetHosts() []string
func (*Networking) GetHttpRoutes ¶ added in v0.0.7
func (x *Networking) GetHttpRoutes() []*HTTPRoute
func (*Networking) ProtoMessage ¶ added in v0.0.6
func (*Networking) ProtoMessage()
func (*Networking) ProtoReflect ¶ added in v0.0.6
func (x *Networking) ProtoReflect() protoreflect.Message
func (*Networking) Reset ¶ added in v0.0.6
func (x *Networking) Reset()
func (*Networking) String ¶ added in v0.0.6
func (x *Networking) String() string
func (*Networking) Validate ¶ added in v0.0.6
func (this *Networking) Validate() error
type Protocol ¶ added in v0.0.9
type Protocol int32
func (Protocol) Descriptor ¶ added in v0.0.9
func (Protocol) Descriptor() protoreflect.EnumDescriptor
func (Protocol) EnumDescriptor
deprecated
added in
v0.0.9
func (Protocol) Number ¶ added in v0.0.9
func (x Protocol) Number() protoreflect.EnumNumber
func (Protocol) Type ¶ added in v0.0.9
func (Protocol) Type() protoreflect.EnumType
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) GetNamespace ¶ added in v0.0.1
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
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) GetCondition ¶
func (*Replica) ProtoMessage ¶
func (*Replica) ProtoMessage()
func (*Replica) ProtoReflect ¶
func (x *Replica) ProtoReflect() protoreflect.Message
type ServerTLSSettings ¶ added in v0.0.9
type ServerTLSSettings struct {
HttpsRedirect bool `protobuf:"varint,1,opt,name=https_redirect,json=httpsRedirect,proto3" json:"https_redirect,omitempty"`
Mode TLSmode `protobuf:"varint,2,opt,name=mode,proto3,enum=kdeploy.TLSmode" json:"mode,omitempty"`
ServerCertificate string `protobuf:"bytes,3,opt,name=server_certificate,json=serverCertificate,proto3" json:"server_certificate,omitempty"`
PrivateKey string `protobuf:"bytes,4,opt,name=private_key,json=privateKey,proto3" json:"private_key,omitempty"`
CaCertificates string `protobuf:"bytes,5,opt,name=ca_certificates,json=caCertificates,proto3" json:"ca_certificates,omitempty"`
CredentialName string `protobuf:"bytes,10,opt,name=credential_name,json=credentialName,proto3" json:"credential_name,omitempty"`
SubjectAltNames []string `protobuf:"bytes,6,rep,name=subject_alt_names,json=subjectAltNames,proto3" json:"subject_alt_names,omitempty"`
VerifyCertificateSpki []string `` /* 127-byte string literal not displayed */
VerifyCertificateHash []string `` /* 127-byte string literal not displayed */
CipherSuites []string `protobuf:"bytes,9,rep,name=cipher_suites,json=cipherSuites,proto3" json:"cipher_suites,omitempty"`
// contains filtered or unexported fields
}
func (*ServerTLSSettings) Descriptor
deprecated
added in
v0.0.9
func (*ServerTLSSettings) Descriptor() ([]byte, []int)
Deprecated: Use ServerTLSSettings.ProtoReflect.Descriptor instead.
func (*ServerTLSSettings) GetCaCertificates ¶ added in v0.0.9
func (x *ServerTLSSettings) GetCaCertificates() string
func (*ServerTLSSettings) GetCipherSuites ¶ added in v0.0.9
func (x *ServerTLSSettings) GetCipherSuites() []string
func (*ServerTLSSettings) GetCredentialName ¶ added in v0.0.9
func (x *ServerTLSSettings) GetCredentialName() string
func (*ServerTLSSettings) GetHttpsRedirect ¶ added in v0.0.9
func (x *ServerTLSSettings) GetHttpsRedirect() bool
func (*ServerTLSSettings) GetMode ¶ added in v0.0.9
func (x *ServerTLSSettings) GetMode() TLSmode
func (*ServerTLSSettings) GetPrivateKey ¶ added in v0.0.9
func (x *ServerTLSSettings) GetPrivateKey() string
func (*ServerTLSSettings) GetServerCertificate ¶ added in v0.0.9
func (x *ServerTLSSettings) GetServerCertificate() string
func (*ServerTLSSettings) GetSubjectAltNames ¶ added in v0.0.9
func (x *ServerTLSSettings) GetSubjectAltNames() []string
func (*ServerTLSSettings) GetVerifyCertificateHash ¶ added in v0.0.9
func (x *ServerTLSSettings) GetVerifyCertificateHash() []string
func (*ServerTLSSettings) GetVerifyCertificateSpki ¶ added in v0.0.9
func (x *ServerTLSSettings) GetVerifyCertificateSpki() []string
func (*ServerTLSSettings) ProtoMessage ¶ added in v0.0.9
func (*ServerTLSSettings) ProtoMessage()
func (*ServerTLSSettings) ProtoReflect ¶ added in v0.0.9
func (x *ServerTLSSettings) ProtoReflect() protoreflect.Message
func (*ServerTLSSettings) Reset ¶ added in v0.0.9
func (x *ServerTLSSettings) Reset()
func (*ServerTLSSettings) String ¶ added in v0.0.9
func (x *ServerTLSSettings) String() string
func (*ServerTLSSettings) Validate ¶ added in v0.0.9
func (this *ServerTLSSettings) Validate() error
type TLSmode ¶ added in v0.0.9
type TLSmode int32
func (TLSmode) Descriptor ¶ added in v0.0.9
func (TLSmode) Descriptor() protoreflect.EnumDescriptor
func (TLSmode) EnumDescriptor
deprecated
added in
v0.0.9
func (TLSmode) Number ¶ added in v0.0.9
func (x TLSmode) Number() protoreflect.EnumNumber
func (TLSmode) Type ¶ added in v0.0.9
func (TLSmode) Type() protoreflect.EnumType
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"`
Labels map[string]string `` /* 153-byte string literal not displayed */
Selector map[string]string `` /* 158-byte string literal not displayed */
// contains filtered or unexported fields
}
Task is scheduled cron job
func (*Task) Descriptor
deprecated
added in
v0.0.1
func (*Task) GetCompletions ¶ added in v0.0.1
func (*Task) GetNamespace ¶ added in v0.0.1
func (*Task) GetSchedule ¶ added in v0.0.1
func (*Task) GetSelector ¶ added in v0.0.9
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
type TaskInput ¶ added in v0.0.8
type TaskInput 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"`
Labels map[string]string `` /* 153-byte string literal not displayed */
Selector map[string]string `` /* 158-byte string literal not displayed */
// contains filtered or unexported fields
}
TaskInput creates/updates a task(cron job)
func (*TaskInput) Descriptor
deprecated
added in
v0.0.8
func (*TaskInput) GetCompletions ¶ added in v0.0.8
func (*TaskInput) GetNamespace ¶ added in v0.0.8
func (*TaskInput) GetSchedule ¶ added in v0.0.8
func (*TaskInput) GetSelector ¶ added in v0.0.9
func (*TaskInput) ProtoMessage ¶ added in v0.0.8
func (*TaskInput) ProtoMessage()
func (*TaskInput) ProtoReflect ¶ added in v0.0.8
func (x *TaskInput) ProtoReflect() protoreflect.Message
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) ProtoMessage ¶ added in v0.0.1
func (*Tasks) ProtoMessage()
func (*Tasks) ProtoReflect ¶ added in v0.0.1
func (x *Tasks) ProtoReflect() protoreflect.Message
type UnimplementedKdeployServiceServer ¶
type UnimplementedKdeployServiceServer struct {
}
UnimplementedKdeployServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedKdeployServiceServer) CreateGateway ¶ added in v0.0.9
func (*UnimplementedKdeployServiceServer) CreateGateway(context.Context, *GatewayInput) (*Gateway, error)
func (*UnimplementedKdeployServiceServer) CreateTask ¶ added in v0.0.1
func (*UnimplementedKdeployServiceServer) DeleteGateway ¶ added in v0.0.9
func (*UnimplementedKdeployServiceServer) DeleteTask ¶ added in v0.0.1
func (*UnimplementedKdeployServiceServer) GetGateway ¶ added in v0.0.9
func (*UnimplementedKdeployServiceServer) ListNamespaces ¶
func (*UnimplementedKdeployServiceServer) ListNamespaces(context.Context, *empty.Empty) (*Namespaces, error)
func (*UnimplementedKdeployServiceServer) StreamLogs ¶ added in v0.0.4
func (*UnimplementedKdeployServiceServer) StreamLogs(*Ref, KdeployService_StreamLogsServer) error
func (*UnimplementedKdeployServiceServer) UpdateGateway ¶ added in v0.0.9
func (*UnimplementedKdeployServiceServer) UpdateGateway(context.Context, *GatewayInput) (*Gateway, error)