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)