kdeploypb

package
v0.0.11 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

View Source 
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.

View Source 
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.

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"`
	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) 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) GetLabels added in v0.0.9 

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

func (*App) GetName 

func (x *App) GetName() string

func (*App) GetNamespace 

func (x *App) GetNamespace() string

func (*App) GetNetworking added in v0.0.6 

func (x *App) GetNetworking() *Networking

func (*App) GetPorts 

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

func (*App) GetReplicas 

func (x *App) GetReplicas() uint32

func (*App) GetSelector added in v0.0.11 

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

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 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) Descriptor() ([]byte, []int)

Deprecated: Use AppInput.ProtoReflect.Descriptor instead.

func (*AppInput) GetArgs added in v0.0.8 

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

func (*AppInput) GetEnv added in v0.0.8 

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

func (*AppInput) GetImage added in v0.0.8 

func (x *AppInput) GetImage() string

func (*AppInput) GetLabels added in v0.0.9 

func (x *AppInput) GetLabels() map[string]string

func (*AppInput) GetName added in v0.0.8 

func (x *AppInput) GetName() string

func (*AppInput) GetNamespace added in v0.0.8 

func (x *AppInput) GetNamespace() string

func (*AppInput) GetNetworking added in v0.0.8 

func (x *AppInput) GetNetworking() *Networking

func (*AppInput) GetPorts added in v0.0.8 

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

func (*AppInput) GetReplicas added in v0.0.8 

func (x *AppInput) GetReplicas() uint32

func (*AppInput) GetSelector added in v0.0.11 

func (x *AppInput) GetSelector() map[string]string

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

func (*AppInput) Reset added in v0.0.8 

func (x *AppInput) Reset()

func (*AppInput) String added in v0.0.8 

func (x *AppInput) String() string

func (*AppInput) Validate added in v0.0.8 

func (this *AppInput) 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 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 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) Descriptor() ([]byte, []int)

Deprecated: Use Gateway.ProtoReflect.Descriptor instead.

func (*Gateway) GetLabels added in v0.0.9 

func (x *Gateway) GetLabels() map[string]string

func (*Gateway) GetListeners added in v0.0.9 

func (x *Gateway) GetListeners() []*GatewayListener

func (*Gateway) GetName added in v0.0.9 

func (x *Gateway) GetName() string

func (*Gateway) GetNamespace added in v0.0.9 

func (x *Gateway) GetNamespace() string

func (*Gateway) GetSelector added in v0.0.11 

func (x *Gateway) GetSelector() map[string]string

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

func (*Gateway) Reset added in v0.0.9 

func (x *Gateway) Reset()

func (*Gateway) String added in v0.0.9 

func (x *Gateway) String() string

func (*Gateway) Validate added in v0.0.9 

func (this *Gateway) Validate() error

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) Descriptor() ([]byte, []int)

Deprecated: Use HTTPRoute.ProtoReflect.Descriptor instead.

func (*HTTPRoute) GetAllowCredentials added in v0.0.7 

func (x *HTTPRoute) GetAllowCredentials() bool

func (*HTTPRoute) GetAllowHeaders added in v0.0.7 

func (x *HTTPRoute) GetAllowHeaders() []string

func (*HTTPRoute) GetAllowMethods added in v0.0.7 

func (x *HTTPRoute) GetAllowMethods() []string

func (*HTTPRoute) GetAllowOrigins added in v0.0.7 

func (x *HTTPRoute) GetAllowOrigins() []string

func (*HTTPRoute) GetExposeHeaders added in v0.0.7 

func (x *HTTPRoute) GetExposeHeaders() []string

func (*HTTPRoute) GetName added in v0.0.7 

func (x *HTTPRoute) GetName() string

func (*HTTPRoute) GetPathPrefix added in v0.0.7 

func (x *HTTPRoute) GetPathPrefix() string

func (*HTTPRoute) GetPort added in v0.0.7 

func (x *HTTPRoute) GetPort() uint32

func (*HTTPRoute) GetRewriteUri added in v0.0.7 

func (x *HTTPRoute) GetRewriteUri() string

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

func (*HTTPRoute) Reset added in v0.0.7 

func (x *HTTPRoute) Reset()

func (*HTTPRoute) String added in v0.0.7 

func (x *HTTPRoute) String() string

func (*HTTPRoute) Validate added in v0.0.7 

func (this *HTTPRoute) 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 *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) 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 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
const (
	Protocol_INVALID_PROTOCOL Protocol = 0
	Protocol_HTTP             Protocol = 1
	Protocol_HTTPS            Protocol = 2
	Protocol_GRPC             Protocol = 3
	Protocol_HTTP2            Protocol = 4
	Protocol_MONGO            Protocol = 5
	Protocol_TCP              Protocol = 6
	Protocol_TLS              Protocol = 7
)

func (Protocol) Descriptor added in v0.0.9 

func (Protocol) Descriptor() protoreflect.EnumDescriptor

func (Protocol) Enum added in v0.0.9 

func (x Protocol) Enum() *Protocol

func (Protocol) EnumDescriptor deprecated added in v0.0.9 

func (Protocol) EnumDescriptor() ([]byte, []int)

Deprecated: Use Protocol.Descriptor instead.

func (Protocol) Number added in v0.0.9 

func (x Protocol) Number() protoreflect.EnumNumber

func (Protocol) String added in v0.0.9 

func (x Protocol) String() string

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) 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 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
const (
	TLSmode_PASSTHROUGH      TLSmode = 0
	TLSmode_SIMPLE           TLSmode = 1
	TLSmode_MUTUAL           TLSmode = 2
	TLSmode_AUTO_PASSTHROUGH TLSmode = 3
	TLSmode_ISTIO_MUTUAL     TLSmode = 4
)

func (TLSmode) Descriptor added in v0.0.9 

func (TLSmode) Descriptor() protoreflect.EnumDescriptor

func (TLSmode) Enum added in v0.0.9 

func (x TLSmode) Enum() *TLSmode

func (TLSmode) EnumDescriptor deprecated added in v0.0.9 

func (TLSmode) EnumDescriptor() ([]byte, []int)

Deprecated: Use TLSmode.Descriptor instead.

func (TLSmode) Number added in v0.0.9 

func (x TLSmode) Number() protoreflect.EnumNumber

func (TLSmode) String added in v0.0.9 

func (x TLSmode) String() string

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) 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) GetLabels added in v0.0.11 

func (x *Task) GetLabels() map[string]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) GetSelector added in v0.0.9 

func (x *Task) GetSelector() map[string]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 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) Descriptor() ([]byte, []int)

Deprecated: Use TaskInput.ProtoReflect.Descriptor instead.

func (*TaskInput) GetArgs added in v0.0.8 

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

func (*TaskInput) GetCompletions added in v0.0.8 

func (x *TaskInput) GetCompletions() uint32

func (*TaskInput) GetEnv added in v0.0.8 

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

func (*TaskInput) GetImage added in v0.0.8 

func (x *TaskInput) GetImage() string

func (*TaskInput) GetLabels added in v0.0.11 

func (x *TaskInput) GetLabels() map[string]string

func (*TaskInput) GetName added in v0.0.8 

func (x *TaskInput) GetName() string

func (*TaskInput) GetNamespace added in v0.0.8 

func (x *TaskInput) GetNamespace() string

func (*TaskInput) GetSchedule added in v0.0.8 

func (x *TaskInput) GetSchedule() string

func (*TaskInput) GetSelector added in v0.0.9 

func (x *TaskInput) GetSelector() map[string]string

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

func (*TaskInput) Reset added in v0.0.8 

func (x *TaskInput) Reset()

func (*TaskInput) String added in v0.0.8 

func (x *TaskInput) String() string

func (*TaskInput) Validate added in v0.0.8 

func (this *TaskInput) 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, *AppInput) (*App, error)

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) CreateTask(context.Context, *TaskInput) (*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) DeleteGateway added in v0.0.9 

func (*UnimplementedKdeployServiceServer) DeleteGateway(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) GetGateway added in v0.0.9 

func (*UnimplementedKdeployServiceServer) GetGateway(context.Context, *Ref) (*Gateway, 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, *AppInput) (*App, error)

func (*UnimplementedKdeployServiceServer) UpdateGateway added in v0.0.9 

func (*UnimplementedKdeployServiceServer) UpdateGateway(context.Context, *GatewayInput) (*Gateway, error)

func (*UnimplementedKdeployServiceServer) UpdateTask added in v0.0.1 

func (*UnimplementedKdeployServiceServer) UpdateTask(context.Context, *TaskInput) (*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.