spiv1

package
v1.14.0 Latest Latest
Warning

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

 Go to latest Published: Dec 14, 2022 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var DeploymentAdapterService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "sdk.spi.v1.DeploymentAdapterService",
	HandlerType: (*DeploymentAdapterServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateNamespace",
			Handler:    _DeploymentAdapterService_CreateNamespace_Handler,
		},
		{
			MethodName: "GetSparks",
			Handler:    _DeploymentAdapterService_GetSparks_Handler,
		},
		{
			MethodName: "GetPods",
			Handler:    _DeploymentAdapterService_GetPods_Handler,
		},
		{
			MethodName: "DeploySpark",
			Handler:    _DeploymentAdapterService_DeploySpark_Handler,
		},
		{
			MethodName: "UndeploySpark",
			Handler:    _DeploymentAdapterService_UndeploySpark_Handler,
		},
		{
			MethodName: "GetSpark",
			Handler:    _DeploymentAdapterService_GetSpark_Handler,
		},
		{
			MethodName: "ScaleSpark",
			Handler:    _DeploymentAdapterService_ScaleSpark_Handler,
		},
		{
			MethodName: "GetSecrets",
			Handler:    _DeploymentAdapterService_GetSecrets_Handler,
		},
		{
			MethodName: "CreateSecret",
			Handler:    _DeploymentAdapterService_CreateSecret_Handler,
		},
		{
			MethodName: "ReplaceSecret",
			Handler:    _DeploymentAdapterService_ReplaceSecret_Handler,
		},
		{
			MethodName: "DeleteSecret",
			Handler:    _DeploymentAdapterService_DeleteSecret_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "CreateEventStream",
			Handler:       _DeploymentAdapterService_CreateEventStream_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "azarc/sdk/spi/v1/provider.proto",
}

DeploymentAdapterService_ServiceDesc is the grpc.ServiceDesc for DeploymentAdapterService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_azarc_sdk_spi_v1_provider_proto protoreflect.FileDescriptor

Functions

func RegisterDeploymentAdapterServiceServer 

func RegisterDeploymentAdapterServiceServer(s grpc.ServiceRegistrar, srv DeploymentAdapterServiceServer)

Types

type CreateEventStreamRequest 

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

func (*CreateEventStreamRequest) Descriptor deprecated 

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

Deprecated: Use CreateEventStreamRequest.ProtoReflect.Descriptor instead.

func (*CreateEventStreamRequest) GetNamespace 

func (x *CreateEventStreamRequest) GetNamespace() string

func (*CreateEventStreamRequest) ProtoMessage 

func (*CreateEventStreamRequest) ProtoMessage()

func (*CreateEventStreamRequest) ProtoReflect 

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

func (*CreateEventStreamRequest) Reset 

func (x *CreateEventStreamRequest) Reset()

func (*CreateEventStreamRequest) String 

func (x *CreateEventStreamRequest) String() string

type CreateNamespaceRequest 

type CreateNamespaceRequest struct {
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// Labels are metadata for functions which may be used by the faas-provider or the gateway
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*CreateNamespaceRequest) Descriptor deprecated 

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

Deprecated: Use CreateNamespaceRequest.ProtoReflect.Descriptor instead.

func (*CreateNamespaceRequest) GetLabels 

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

func (*CreateNamespaceRequest) GetNamespace 

func (x *CreateNamespaceRequest) GetNamespace() string

func (*CreateNamespaceRequest) ProtoMessage 

func (*CreateNamespaceRequest) ProtoMessage()

func (*CreateNamespaceRequest) ProtoReflect 

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

func (*CreateNamespaceRequest) Reset 

func (x *CreateNamespaceRequest) Reset()

func (*CreateNamespaceRequest) String 

func (x *CreateNamespaceRequest) String() string

type CreateNamespaceResponse 

type CreateNamespaceResponse struct {
	// contains filtered or unexported fields
}

func (*CreateNamespaceResponse) Descriptor deprecated 

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

Deprecated: Use CreateNamespaceResponse.ProtoReflect.Descriptor instead.

func (*CreateNamespaceResponse) ProtoMessage 

func (*CreateNamespaceResponse) ProtoMessage()

func (*CreateNamespaceResponse) ProtoReflect 

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

func (*CreateNamespaceResponse) Reset 

func (x *CreateNamespaceResponse) Reset()

func (*CreateNamespaceResponse) String 

func (x *CreateNamespaceResponse) String() string

type CreateSecretRequest 

type CreateSecretRequest struct {
	Secret *Secret `protobuf:"bytes,1,opt,name=secret,proto3" json:"secret,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateSecretRequest) Descriptor deprecated 

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

Deprecated: Use CreateSecretRequest.ProtoReflect.Descriptor instead.

func (*CreateSecretRequest) GetSecret 

func (x *CreateSecretRequest) GetSecret() *Secret

func (*CreateSecretRequest) ProtoMessage 

func (*CreateSecretRequest) ProtoMessage()

func (*CreateSecretRequest) ProtoReflect 

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

func (*CreateSecretRequest) Reset 

func (x *CreateSecretRequest) Reset()

func (*CreateSecretRequest) String 

func (x *CreateSecretRequest) String() string

type CreateSecretResponse 

type CreateSecretResponse struct {
	// contains filtered or unexported fields
}

func (*CreateSecretResponse) Descriptor deprecated 

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

Deprecated: Use CreateSecretResponse.ProtoReflect.Descriptor instead.

func (*CreateSecretResponse) ProtoMessage 

func (*CreateSecretResponse) ProtoMessage()

func (*CreateSecretResponse) ProtoReflect 

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

func (*CreateSecretResponse) Reset 

func (x *CreateSecretResponse) Reset()

func (*CreateSecretResponse) String 

func (x *CreateSecretResponse) String() string

type DeleteSecretRequest 

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

func (*DeleteSecretRequest) Descriptor deprecated 

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

Deprecated: Use DeleteSecretRequest.ProtoReflect.Descriptor instead.

func (*DeleteSecretRequest) GetName 

func (x *DeleteSecretRequest) GetName() string

func (*DeleteSecretRequest) GetNamespace 

func (x *DeleteSecretRequest) GetNamespace() string

func (*DeleteSecretRequest) ProtoMessage 

func (*DeleteSecretRequest) ProtoMessage()

func (*DeleteSecretRequest) ProtoReflect 

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

func (*DeleteSecretRequest) Reset 

func (x *DeleteSecretRequest) Reset()

func (*DeleteSecretRequest) String 

func (x *DeleteSecretRequest) String() string

type DeleteSecretResponse 

type DeleteSecretResponse struct {
	// contains filtered or unexported fields
}

func (*DeleteSecretResponse) Descriptor deprecated 

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

Deprecated: Use DeleteSecretResponse.ProtoReflect.Descriptor instead.

func (*DeleteSecretResponse) ProtoMessage 

func (*DeleteSecretResponse) ProtoMessage()

func (*DeleteSecretResponse) ProtoReflect 

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

func (*DeleteSecretResponse) Reset 

func (x *DeleteSecretResponse) Reset()

func (*DeleteSecretResponse) String 

func (x *DeleteSecretResponse) String() string

type DeploySparkRequest 

type DeploySparkRequest struct {
	Deployment *SparkDeployment `protobuf:"bytes,1,opt,name=deployment,proto3" json:"deployment,omitempty"`
	// contains filtered or unexported fields
}

func (*DeploySparkRequest) Descriptor deprecated 

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

Deprecated: Use DeploySparkRequest.ProtoReflect.Descriptor instead.

func (*DeploySparkRequest) GetDeployment 

func (x *DeploySparkRequest) GetDeployment() *SparkDeployment

func (*DeploySparkRequest) ProtoMessage 

func (*DeploySparkRequest) ProtoMessage()

func (*DeploySparkRequest) ProtoReflect 

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

func (*DeploySparkRequest) Reset 

func (x *DeploySparkRequest) Reset()

func (*DeploySparkRequest) String 

func (x *DeploySparkRequest) String() string

type DeploySparkResponse 

type DeploySparkResponse struct {
	// contains filtered or unexported fields
}

func (*DeploySparkResponse) Descriptor deprecated 

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

Deprecated: Use DeploySparkResponse.ProtoReflect.Descriptor instead.

func (*DeploySparkResponse) ProtoMessage 

func (*DeploySparkResponse) ProtoMessage()

func (*DeploySparkResponse) ProtoReflect 

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

func (*DeploySparkResponse) Reset 

func (x *DeploySparkResponse) Reset()

func (*DeploySparkResponse) String 

func (x *DeploySparkResponse) String() string

type DeploymentAdapterServiceClient 

type DeploymentAdapterServiceClient interface {
	CreateNamespace(ctx context.Context, in *CreateNamespaceRequest, opts ...grpc.CallOption) (*CreateNamespaceResponse, error)
	GetSparks(ctx context.Context, in *GetFunctionsRequest, opts ...grpc.CallOption) (*GetFunctionsResponse, error)
	GetPods(ctx context.Context, in *GetPodsRequest, opts ...grpc.CallOption) (*GetPodsResponse, error)
	DeploySpark(ctx context.Context, in *DeploySparkRequest, opts ...grpc.CallOption) (*DeploySparkResponse, error)
	UndeploySpark(ctx context.Context, in *UndeploySparkRequest, opts ...grpc.CallOption) (*UndeploySparkResponse, error)
	GetSpark(ctx context.Context, in *GetFunctionRequest, opts ...grpc.CallOption) (*GetFunctionResponse, error)
	ScaleSpark(ctx context.Context, in *ScaleSparkRequest, opts ...grpc.CallOption) (*ScaleSparkResponse, error)
	GetSecrets(ctx context.Context, in *GetSecretsRequest, opts ...grpc.CallOption) (*GetSecretsResponse, error)
	CreateSecret(ctx context.Context, in *CreateSecretRequest, opts ...grpc.CallOption) (*CreateSecretResponse, error)
	ReplaceSecret(ctx context.Context, in *ReplaceSecretRequest, opts ...grpc.CallOption) (*ReplaceSecretResponse, error)
	DeleteSecret(ctx context.Context, in *DeleteSecretRequest, opts ...grpc.CallOption) (*DeleteSecretResponse, error)
	CreateEventStream(ctx context.Context, in *CreateEventStreamRequest, opts ...grpc.CallOption) (DeploymentAdapterService_CreateEventStreamClient, error)
}

DeploymentAdapterServiceClient is the client API for DeploymentAdapterService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewDeploymentAdapterServiceClient 

func NewDeploymentAdapterServiceClient(cc grpc.ClientConnInterface) DeploymentAdapterServiceClient

type DeploymentAdapterServiceServer 

type DeploymentAdapterServiceServer interface {
	CreateNamespace(context.Context, *CreateNamespaceRequest) (*CreateNamespaceResponse, error)
	GetSparks(context.Context, *GetFunctionsRequest) (*GetFunctionsResponse, error)
	GetPods(context.Context, *GetPodsRequest) (*GetPodsResponse, error)
	DeploySpark(context.Context, *DeploySparkRequest) (*DeploySparkResponse, error)
	UndeploySpark(context.Context, *UndeploySparkRequest) (*UndeploySparkResponse, error)
	GetSpark(context.Context, *GetFunctionRequest) (*GetFunctionResponse, error)
	ScaleSpark(context.Context, *ScaleSparkRequest) (*ScaleSparkResponse, error)
	GetSecrets(context.Context, *GetSecretsRequest) (*GetSecretsResponse, error)
	CreateSecret(context.Context, *CreateSecretRequest) (*CreateSecretResponse, error)
	ReplaceSecret(context.Context, *ReplaceSecretRequest) (*ReplaceSecretResponse, error)
	DeleteSecret(context.Context, *DeleteSecretRequest) (*DeleteSecretResponse, error)
	CreateEventStream(*CreateEventStreamRequest, DeploymentAdapterService_CreateEventStreamServer) error
}

DeploymentAdapterServiceServer is the server API for DeploymentAdapterService service. All implementations should embed UnimplementedDeploymentAdapterServiceServer for forward compatibility

type DeploymentAdapterService_CreateEventStreamClient 

type DeploymentAdapterService_CreateEventStreamClient interface {
	Recv() (*StreamEvent, error)
	grpc.ClientStream
}

type DeploymentAdapterService_CreateEventStreamServer 

type DeploymentAdapterService_CreateEventStreamServer interface {
	Send(*StreamEvent) error
	grpc.ServerStream
}

type GetFunctionRequest 

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

func (*GetFunctionRequest) Descriptor deprecated 

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

Deprecated: Use GetFunctionRequest.ProtoReflect.Descriptor instead.

func (*GetFunctionRequest) GetName 

func (x *GetFunctionRequest) GetName() string

func (*GetFunctionRequest) GetNamespace 

func (x *GetFunctionRequest) GetNamespace() string

func (*GetFunctionRequest) ProtoMessage 

func (*GetFunctionRequest) ProtoMessage()

func (*GetFunctionRequest) ProtoReflect 

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

func (*GetFunctionRequest) Reset 

func (x *GetFunctionRequest) Reset()

func (*GetFunctionRequest) String 

func (x *GetFunctionRequest) String() string

type GetFunctionResponse 

type GetFunctionResponse struct {
	Function *SparkStatus `protobuf:"bytes,1,opt,name=function,proto3" json:"function,omitempty"`
	// contains filtered or unexported fields
}

func (*GetFunctionResponse) Descriptor deprecated 

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

Deprecated: Use GetFunctionResponse.ProtoReflect.Descriptor instead.

func (*GetFunctionResponse) GetFunction 

func (x *GetFunctionResponse) GetFunction() *SparkStatus

func (*GetFunctionResponse) ProtoMessage 

func (*GetFunctionResponse) ProtoMessage()

func (*GetFunctionResponse) ProtoReflect 

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

func (*GetFunctionResponse) Reset 

func (x *GetFunctionResponse) Reset()

func (*GetFunctionResponse) String 

func (x *GetFunctionResponse) String() string

type GetFunctionsRequest 

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

func (*GetFunctionsRequest) Descriptor deprecated 

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

Deprecated: Use GetFunctionsRequest.ProtoReflect.Descriptor instead.

func (*GetFunctionsRequest) GetNamespace 

func (x *GetFunctionsRequest) GetNamespace() string

func (*GetFunctionsRequest) ProtoMessage 

func (*GetFunctionsRequest) ProtoMessage()

func (*GetFunctionsRequest) ProtoReflect 

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

func (*GetFunctionsRequest) Reset 

func (x *GetFunctionsRequest) Reset()

func (*GetFunctionsRequest) String 

func (x *GetFunctionsRequest) String() string

type GetFunctionsResponse 

type GetFunctionsResponse struct {
	Functions []*SparkStatus `protobuf:"bytes,1,rep,name=functions,proto3" json:"functions,omitempty"`
	// contains filtered or unexported fields
}

func (*GetFunctionsResponse) Descriptor deprecated 

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

Deprecated: Use GetFunctionsResponse.ProtoReflect.Descriptor instead.

func (*GetFunctionsResponse) GetFunctions 

func (x *GetFunctionsResponse) GetFunctions() []*SparkStatus

func (*GetFunctionsResponse) ProtoMessage 

func (*GetFunctionsResponse) ProtoMessage()

func (*GetFunctionsResponse) ProtoReflect 

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

func (*GetFunctionsResponse) Reset 

func (x *GetFunctionsResponse) Reset()

func (*GetFunctionsResponse) String 

func (x *GetFunctionsResponse) String() string

type GetPodsRequest 

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

func (*GetPodsRequest) Descriptor deprecated 

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

Deprecated: Use GetPodsRequest.ProtoReflect.Descriptor instead.

func (*GetPodsRequest) GetFunction 

func (x *GetPodsRequest) GetFunction() string

func (*GetPodsRequest) GetNamespace 

func (x *GetPodsRequest) GetNamespace() string

func (*GetPodsRequest) ProtoMessage 

func (*GetPodsRequest) ProtoMessage()

func (*GetPodsRequest) ProtoReflect 

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

func (*GetPodsRequest) Reset 

func (x *GetPodsRequest) Reset()

func (*GetPodsRequest) String 

func (x *GetPodsRequest) String() string

type GetPodsResponse 

type GetPodsResponse struct {
	Pods []*Pod `protobuf:"bytes,1,rep,name=pods,proto3" json:"pods,omitempty"`
	// contains filtered or unexported fields
}

func (*GetPodsResponse) Descriptor deprecated 

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

Deprecated: Use GetPodsResponse.ProtoReflect.Descriptor instead.

func (*GetPodsResponse) GetPods 

func (x *GetPodsResponse) GetPods() []*Pod

func (*GetPodsResponse) ProtoMessage 

func (*GetPodsResponse) ProtoMessage()

func (*GetPodsResponse) ProtoReflect 

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

func (*GetPodsResponse) Reset 

func (x *GetPodsResponse) Reset()

func (*GetPodsResponse) String 

func (x *GetPodsResponse) String() string

type GetSecretsRequest 

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

func (*GetSecretsRequest) Descriptor deprecated 

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

Deprecated: Use GetSecretsRequest.ProtoReflect.Descriptor instead.

func (*GetSecretsRequest) GetNamespace 

func (x *GetSecretsRequest) GetNamespace() string

func (*GetSecretsRequest) ProtoMessage 

func (*GetSecretsRequest) ProtoMessage()

func (*GetSecretsRequest) ProtoReflect 

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

func (*GetSecretsRequest) Reset 

func (x *GetSecretsRequest) Reset()

func (*GetSecretsRequest) String 

func (x *GetSecretsRequest) String() string

type GetSecretsResponse 

type GetSecretsResponse struct {
	Secrets []*Secret `protobuf:"bytes,1,rep,name=secrets,proto3" json:"secrets,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSecretsResponse) Descriptor deprecated 

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

Deprecated: Use GetSecretsResponse.ProtoReflect.Descriptor instead.

func (*GetSecretsResponse) GetSecrets 

func (x *GetSecretsResponse) GetSecrets() []*Secret

func (*GetSecretsResponse) ProtoMessage 

func (*GetSecretsResponse) ProtoMessage()

func (*GetSecretsResponse) ProtoReflect 

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

func (*GetSecretsResponse) Reset 

func (x *GetSecretsResponse) Reset()

func (*GetSecretsResponse) String 

func (x *GetSecretsResponse) String() string

type Pod 

type Pod struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Ip   string `protobuf:"bytes,2,opt,name=ip,proto3" json:"ip,omitempty"`
	// contains filtered or unexported fields
}

func (*Pod) Descriptor deprecated 

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

Deprecated: Use Pod.ProtoReflect.Descriptor instead.

func (*Pod) GetIp 

func (x *Pod) GetIp() string

func (*Pod) GetName 

func (x *Pod) GetName() string

func (*Pod) ProtoMessage 

func (*Pod) ProtoMessage()

func (*Pod) ProtoReflect 

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

func (*Pod) Reset 

func (x *Pod) Reset()

func (*Pod) String 

func (x *Pod) String() string

type ReplaceSecretRequest 

type ReplaceSecretRequest struct {
	Secret *Secret `protobuf:"bytes,1,opt,name=secret,proto3" json:"secret,omitempty"`
	// contains filtered or unexported fields
}

func (*ReplaceSecretRequest) Descriptor deprecated 

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

Deprecated: Use ReplaceSecretRequest.ProtoReflect.Descriptor instead.

func (*ReplaceSecretRequest) GetSecret 

func (x *ReplaceSecretRequest) GetSecret() *Secret

func (*ReplaceSecretRequest) ProtoMessage 

func (*ReplaceSecretRequest) ProtoMessage()

func (*ReplaceSecretRequest) ProtoReflect 

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

func (*ReplaceSecretRequest) Reset 

func (x *ReplaceSecretRequest) Reset()

func (*ReplaceSecretRequest) String 

func (x *ReplaceSecretRequest) String() string

type ReplaceSecretResponse 

type ReplaceSecretResponse struct {
	// contains filtered or unexported fields
}

func (*ReplaceSecretResponse) Descriptor deprecated 

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

Deprecated: Use ReplaceSecretResponse.ProtoReflect.Descriptor instead.

func (*ReplaceSecretResponse) ProtoMessage 

func (*ReplaceSecretResponse) ProtoMessage()

func (*ReplaceSecretResponse) ProtoReflect 

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

func (*ReplaceSecretResponse) Reset 

func (x *ReplaceSecretResponse) Reset()

func (*ReplaceSecretResponse) String 

func (x *ReplaceSecretResponse) String() string

type ScaleSparkRequest 

type ScaleSparkRequest struct {
	Name      string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Replicas  uint64 `protobuf:"varint,2,opt,name=replicas,proto3" json:"replicas,omitempty"`
	Namespace string `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// contains filtered or unexported fields
}

func (*ScaleSparkRequest) Descriptor deprecated 

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

Deprecated: Use ScaleSparkRequest.ProtoReflect.Descriptor instead.

func (*ScaleSparkRequest) GetName 

func (x *ScaleSparkRequest) GetName() string

func (*ScaleSparkRequest) GetNamespace 

func (x *ScaleSparkRequest) GetNamespace() string

func (*ScaleSparkRequest) GetReplicas 

func (x *ScaleSparkRequest) GetReplicas() uint64

func (*ScaleSparkRequest) ProtoMessage 

func (*ScaleSparkRequest) ProtoMessage()

func (*ScaleSparkRequest) ProtoReflect 

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

func (*ScaleSparkRequest) Reset 

func (x *ScaleSparkRequest) Reset()

func (*ScaleSparkRequest) String 

func (x *ScaleSparkRequest) String() string

type ScaleSparkResponse 

type ScaleSparkResponse struct {
	// contains filtered or unexported fields
}

func (*ScaleSparkResponse) Descriptor deprecated 

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

Deprecated: Use ScaleSparkResponse.ProtoReflect.Descriptor instead.

func (*ScaleSparkResponse) ProtoMessage 

func (*ScaleSparkResponse) ProtoMessage()

func (*ScaleSparkResponse) ProtoReflect 

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

func (*ScaleSparkResponse) Reset 

func (x *ScaleSparkResponse) Reset()

func (*ScaleSparkResponse) String 

func (x *ScaleSparkResponse) String() string

type Secret 

type Secret struct {

	// Name of the secret
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Namespace if applicable for the secret
	Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// Value is a string representing the string's value
	Value string `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	// RawValue can be used to provide binary data when Value is not set
	RawValue []byte `protobuf:"bytes,4,opt,name=raw_value,json=rawValue,proto3" json:"raw_value,omitempty"`
	// The key name of the secret secret_key: value
	SecretKey string `protobuf:"bytes,5,opt,name=secret_key,json=secretKey,proto3" json:"secret_key,omitempty"`
	// contains filtered or unexported fields
}

func (*Secret) Descriptor deprecated 

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

Deprecated: Use Secret.ProtoReflect.Descriptor instead.

func (*Secret) GetName 

func (x *Secret) GetName() string

func (*Secret) GetNamespace 

func (x *Secret) GetNamespace() string

func (*Secret) GetRawValue 

func (x *Secret) GetRawValue() []byte

func (*Secret) GetSecretKey 

func (x *Secret) GetSecretKey() string

func (*Secret) GetValue 

func (x *Secret) GetValue() string

func (*Secret) ProtoMessage 

func (*Secret) ProtoMessage()

func (*Secret) ProtoReflect 

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

func (*Secret) Reset 

func (x *Secret) Reset()

func (*Secret) String 

func (x *Secret) String() string

type SparkCreatedEvent 

type SparkCreatedEvent struct {
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Name      string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Ip        string `protobuf:"bytes,3,opt,name=ip,proto3" json:"ip,omitempty"`
	Function  string `protobuf:"bytes,4,opt,name=function,proto3" json:"function,omitempty"`
	// contains filtered or unexported fields
}

func (*SparkCreatedEvent) Descriptor deprecated 

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

Deprecated: Use SparkCreatedEvent.ProtoReflect.Descriptor instead.

func (*SparkCreatedEvent) GetFunction 

func (x *SparkCreatedEvent) GetFunction() string

func (*SparkCreatedEvent) GetIp 

func (x *SparkCreatedEvent) GetIp() string

func (*SparkCreatedEvent) GetName 

func (x *SparkCreatedEvent) GetName() string

func (*SparkCreatedEvent) GetNamespace 

func (x *SparkCreatedEvent) GetNamespace() string

func (*SparkCreatedEvent) ProtoMessage 

func (*SparkCreatedEvent) ProtoMessage()

func (*SparkCreatedEvent) ProtoReflect 

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

func (*SparkCreatedEvent) Reset 

func (x *SparkCreatedEvent) Reset()

func (*SparkCreatedEvent) String 

func (x *SparkCreatedEvent) String() string

type SparkDeletedEvent 

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

func (*SparkDeletedEvent) Descriptor deprecated 

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

Deprecated: Use SparkDeletedEvent.ProtoReflect.Descriptor instead.

func (*SparkDeletedEvent) GetFunction 

func (x *SparkDeletedEvent) GetFunction() string

func (*SparkDeletedEvent) GetName 

func (x *SparkDeletedEvent) GetName() string

func (*SparkDeletedEvent) GetNamespace 

func (x *SparkDeletedEvent) GetNamespace() string

func (*SparkDeletedEvent) ProtoMessage 

func (*SparkDeletedEvent) ProtoMessage()

func (*SparkDeletedEvent) ProtoReflect 

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

func (*SparkDeletedEvent) Reset 

func (x *SparkDeletedEvent) Reset()

func (*SparkDeletedEvent) String 

func (x *SparkDeletedEvent) String() string

type SparkDeployment 

type SparkDeployment struct {

	// Service is the name of the function deployment
	Service string `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	// Image is a fully-qualified container image
	Image string `protobuf:"bytes,2,opt,name=image,proto3" json:"image,omitempty"`
	// Namespace for the function, if supported by the faas-provider
	Namespace string `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// EnvVars set environment variables for the function runtime
	EnvVars map[string]string `` /* 170-byte string literal not displayed */
	// Constraints are specific to the faas-provider
	Constraints []string `protobuf:"bytes,6,rep,name=constraints,proto3" json:"constraints,omitempty"`
	// Secrets list of secrets to be made available to function
	Secrets []string `protobuf:"bytes,7,rep,name=secrets,proto3" json:"secrets,omitempty"`
	// Labels are metadata for functions which may be used by the faas-provider or the gateway
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// Annotations are metadata for functions which may be used by the faas-provider or the gateway
	Annotations map[string]string `` /* 163-byte string literal not displayed */
	// Limits for function
	Limits *SparkResources `protobuf:"bytes,10,opt,name=limits,proto3" json:"limits,omitempty"`
	// Requests of resources requested by function
	Requests *SparkResources `protobuf:"bytes,11,opt,name=requests,proto3" json:"requests,omitempty"`
	// ReadOnlyRootFilesystem removes write-access from the root filesystem mount-point
	ReadOnlyRootFilesystem bool `` /* 133-byte string literal not displayed */
	// Ingress if set will configure an ingress for the deployment service
	Ingress *SparkDeployment_Ingress `protobuf:"bytes,13,opt,name=ingress,proto3" json:"ingress,omitempty"`
	// VolumeMount configures mounting of 1 or more volumes
	VolumeMounts []*VolumeMount `protobuf:"bytes,14,rep,name=volume_mounts,json=volumeMounts,proto3" json:"volume_mounts,omitempty"`
	// contains filtered or unexported fields
}

func (*SparkDeployment) Descriptor deprecated 

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

Deprecated: Use SparkDeployment.ProtoReflect.Descriptor instead.

func (*SparkDeployment) GetAnnotations 

func (x *SparkDeployment) GetAnnotations() map[string]string

func (*SparkDeployment) GetConstraints 

func (x *SparkDeployment) GetConstraints() []string

func (*SparkDeployment) GetEnvVars 

func (x *SparkDeployment) GetEnvVars() map[string]string

func (*SparkDeployment) GetImage 

func (x *SparkDeployment) GetImage() string

func (*SparkDeployment) GetIngress 

func (x *SparkDeployment) GetIngress() *SparkDeployment_Ingress

func (*SparkDeployment) GetLabels 

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

func (*SparkDeployment) GetLimits 

func (x *SparkDeployment) GetLimits() *SparkResources

func (*SparkDeployment) GetNamespace 

func (x *SparkDeployment) GetNamespace() string

func (*SparkDeployment) GetReadOnlyRootFilesystem 

func (x *SparkDeployment) GetReadOnlyRootFilesystem() bool

func (*SparkDeployment) GetRequests 

func (x *SparkDeployment) GetRequests() *SparkResources

func (*SparkDeployment) GetSecrets 

func (x *SparkDeployment) GetSecrets() []string

func (*SparkDeployment) GetService 

func (x *SparkDeployment) GetService() string

func (*SparkDeployment) GetVolumeMounts 

func (x *SparkDeployment) GetVolumeMounts() []*VolumeMount

func (*SparkDeployment) ProtoMessage 

func (*SparkDeployment) ProtoMessage()

func (*SparkDeployment) ProtoReflect 

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

func (*SparkDeployment) Reset 

func (x *SparkDeployment) Reset()

func (*SparkDeployment) String 

func (x *SparkDeployment) String() string

type SparkDeployment_Ingress 

type SparkDeployment_Ingress struct {
	Host string `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	// contains filtered or unexported fields
}

func (*SparkDeployment_Ingress) Descriptor deprecated 

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

Deprecated: Use SparkDeployment_Ingress.ProtoReflect.Descriptor instead.

func (*SparkDeployment_Ingress) GetHost 

func (x *SparkDeployment_Ingress) GetHost() string

func (*SparkDeployment_Ingress) GetPath 

func (x *SparkDeployment_Ingress) GetPath() string

func (*SparkDeployment_Ingress) ProtoMessage 

func (*SparkDeployment_Ingress) ProtoMessage()

func (*SparkDeployment_Ingress) ProtoReflect 

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

func (*SparkDeployment_Ingress) Reset 

func (x *SparkDeployment_Ingress) Reset()

func (*SparkDeployment_Ingress) String 

func (x *SparkDeployment_Ingress) String() string

type SparkResources 

type SparkResources struct {
	Memory string `protobuf:"bytes,1,opt,name=memory,proto3" json:"memory,omitempty"`
	Cpu    string `protobuf:"bytes,2,opt,name=cpu,proto3" json:"cpu,omitempty"`
	// contains filtered or unexported fields
}

func (*SparkResources) Descriptor deprecated 

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

Deprecated: Use SparkResources.ProtoReflect.Descriptor instead.

func (*SparkResources) GetCpu 

func (x *SparkResources) GetCpu() string

func (*SparkResources) GetMemory 

func (x *SparkResources) GetMemory() string

func (*SparkResources) ProtoMessage 

func (*SparkResources) ProtoMessage()

func (*SparkResources) ProtoReflect 

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

func (*SparkResources) Reset 

func (x *SparkResources) Reset()

func (*SparkResources) String 

func (x *SparkResources) String() string

type SparkStatus 

type SparkStatus struct {

	// Name is the name of the function deployment
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Image is a fully-qualified container image
	Image string `protobuf:"bytes,2,opt,name=image,proto3" json:"image,omitempty"`
	// Namespace for the function, if supported by the faas-provider
	Namespace string `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// EnvVars set environment variables for the function runtime
	EnvVars map[string]string `` /* 170-byte string literal not displayed */
	// Constraints are specific to the faas-provider
	Constraints []string `protobuf:"bytes,5,rep,name=constraints,proto3" json:"constraints,omitempty"`
	// Secrets list of secrets to be made available to function
	Secrets []string `protobuf:"bytes,6,rep,name=secrets,proto3" json:"secrets,omitempty"`
	// Labels are metadata for functions which may be used by the faas-provider or the gateway
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// Annotations are metadata for functions which may be used by the faas-provider or the gateway
	Annotations map[string]string `` /* 163-byte string literal not displayed */
	// Limits for function
	Limits *SparkResources `protobuf:"bytes,9,opt,name=limits,proto3" json:"limits,omitempty"`
	// Requests of resources requested by function
	Requests *SparkResources `protobuf:"bytes,10,opt,name=requests,proto3" json:"requests,omitempty"`
	// ReadOnlyRootFilesystem removes write-access from the root filesystem mount-point
	ReadOnlyFileSystem bool `protobuf:"varint,11,opt,name=read_only_file_system,json=readOnlyFileSystem,proto3" json:"read_only_file_system,omitempty"`
	// InvocationCount count of invocations
	InvocationCount uint64 `protobuf:"varint,12,opt,name=invocation_count,json=invocationCount,proto3" json:"invocation_count,omitempty"`
	// Replicas desired within the cluster
	Replicas uint64 `protobuf:"varint,13,opt,name=replicas,proto3" json:"replicas,omitempty"`
	// AvailableReplicas is the count of replicas ready to receive invocations as reported by the faas-provider
	AvailableReplicas uint64 `protobuf:"varint,14,opt,name=available_replicas,json=availableReplicas,proto3" json:"available_replicas,omitempty"`
	// CreatedAt is the time read back from the faas backend's data store for when the function or its container was created.
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,15,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// contains filtered or unexported fields
}

func (*SparkStatus) Descriptor deprecated 

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

Deprecated: Use SparkStatus.ProtoReflect.Descriptor instead.

func (*SparkStatus) GetAnnotations 

func (x *SparkStatus) GetAnnotations() map[string]string

func (*SparkStatus) GetAvailableReplicas 

func (x *SparkStatus) GetAvailableReplicas() uint64

func (*SparkStatus) GetConstraints 

func (x *SparkStatus) GetConstraints() []string

func (*SparkStatus) GetCreatedAt 

func (x *SparkStatus) GetCreatedAt() *timestamppb.Timestamp

func (*SparkStatus) GetEnvVars 

func (x *SparkStatus) GetEnvVars() map[string]string

func (*SparkStatus) GetImage 

func (x *SparkStatus) GetImage() string

func (*SparkStatus) GetInvocationCount 

func (x *SparkStatus) GetInvocationCount() uint64

func (*SparkStatus) GetLabels 

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

func (*SparkStatus) GetLimits 

func (x *SparkStatus) GetLimits() *SparkResources

func (*SparkStatus) GetName 

func (x *SparkStatus) GetName() string

func (*SparkStatus) GetNamespace 

func (x *SparkStatus) GetNamespace() string

func (*SparkStatus) GetReadOnlyFileSystem 

func (x *SparkStatus) GetReadOnlyFileSystem() bool

func (*SparkStatus) GetReplicas 

func (x *SparkStatus) GetReplicas() uint64

func (*SparkStatus) GetRequests 

func (x *SparkStatus) GetRequests() *SparkResources

func (*SparkStatus) GetSecrets 

func (x *SparkStatus) GetSecrets() []string

func (*SparkStatus) ProtoMessage 

func (*SparkStatus) ProtoMessage()

func (*SparkStatus) ProtoReflect 

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

func (*SparkStatus) Reset 

func (x *SparkStatus) Reset()

func (*SparkStatus) String 

func (x *SparkStatus) String() string

type StreamEvent 

type StreamEvent struct {

	// Types that are assignable to Event:
	//
	//	*StreamEvent_SparkCreated
	//	*StreamEvent_SparkDeleted
	Event isStreamEvent_Event `protobuf_oneof:"event"`
	// contains filtered or unexported fields
}

func (*StreamEvent) Descriptor deprecated 

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

Deprecated: Use StreamEvent.ProtoReflect.Descriptor instead.

func (*StreamEvent) GetEvent 

func (m *StreamEvent) GetEvent() isStreamEvent_Event

func (*StreamEvent) GetSparkCreated 

func (x *StreamEvent) GetSparkCreated() *SparkCreatedEvent

func (*StreamEvent) GetSparkDeleted 

func (x *StreamEvent) GetSparkDeleted() *SparkDeletedEvent

func (*StreamEvent) ProtoMessage 

func (*StreamEvent) ProtoMessage()

func (*StreamEvent) ProtoReflect 

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

func (*StreamEvent) Reset 

func (x *StreamEvent) Reset()

func (*StreamEvent) String 

func (x *StreamEvent) String() string

type StreamEvent_SparkCreated 

type StreamEvent_SparkCreated struct {
	SparkCreated *SparkCreatedEvent `protobuf:"bytes,1,opt,name=spark_created,json=sparkCreated,proto3,oneof"`
}

type StreamEvent_SparkDeleted 

type StreamEvent_SparkDeleted struct {
	SparkDeleted *SparkDeletedEvent `protobuf:"bytes,2,opt,name=spark_deleted,json=sparkDeleted,proto3,oneof"`
}

type UndeploySparkRequest 

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

func (*UndeploySparkRequest) Descriptor deprecated 

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

Deprecated: Use UndeploySparkRequest.ProtoReflect.Descriptor instead.

func (*UndeploySparkRequest) GetName 

func (x *UndeploySparkRequest) GetName() string

func (*UndeploySparkRequest) GetNamespace 

func (x *UndeploySparkRequest) GetNamespace() string

func (*UndeploySparkRequest) ProtoMessage 

func (*UndeploySparkRequest) ProtoMessage()

func (*UndeploySparkRequest) ProtoReflect 

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

func (*UndeploySparkRequest) Reset 

func (x *UndeploySparkRequest) Reset()

func (*UndeploySparkRequest) String 

func (x *UndeploySparkRequest) String() string

type UndeploySparkResponse 

type UndeploySparkResponse struct {
	// contains filtered or unexported fields
}

func (*UndeploySparkResponse) Descriptor deprecated 

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

Deprecated: Use UndeploySparkResponse.ProtoReflect.Descriptor instead.

func (*UndeploySparkResponse) ProtoMessage 

func (*UndeploySparkResponse) ProtoMessage()

func (*UndeploySparkResponse) ProtoReflect 

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

func (*UndeploySparkResponse) Reset 

func (x *UndeploySparkResponse) Reset()

func (*UndeploySparkResponse) String 

func (x *UndeploySparkResponse) String() string

type UnimplementedDeploymentAdapterServiceServer 

type UnimplementedDeploymentAdapterServiceServer struct {
}

UnimplementedDeploymentAdapterServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedDeploymentAdapterServiceServer) CreateEventStream 

func (UnimplementedDeploymentAdapterServiceServer) CreateEventStream(*CreateEventStreamRequest, DeploymentAdapterService_CreateEventStreamServer) error

func (UnimplementedDeploymentAdapterServiceServer) CreateNamespace 

func (UnimplementedDeploymentAdapterServiceServer) CreateNamespace(context.Context, *CreateNamespaceRequest) (*CreateNamespaceResponse, error)

func (UnimplementedDeploymentAdapterServiceServer) CreateSecret 

func (UnimplementedDeploymentAdapterServiceServer) CreateSecret(context.Context, *CreateSecretRequest) (*CreateSecretResponse, error)

func (UnimplementedDeploymentAdapterServiceServer) DeleteSecret 

func (UnimplementedDeploymentAdapterServiceServer) DeleteSecret(context.Context, *DeleteSecretRequest) (*DeleteSecretResponse, error)

func (UnimplementedDeploymentAdapterServiceServer) DeploySpark 

func (UnimplementedDeploymentAdapterServiceServer) DeploySpark(context.Context, *DeploySparkRequest) (*DeploySparkResponse, error)

func (UnimplementedDeploymentAdapterServiceServer) GetPods 

func (UnimplementedDeploymentAdapterServiceServer) GetPods(context.Context, *GetPodsRequest) (*GetPodsResponse, error)

func (UnimplementedDeploymentAdapterServiceServer) GetSecrets 

func (UnimplementedDeploymentAdapterServiceServer) GetSecrets(context.Context, *GetSecretsRequest) (*GetSecretsResponse, error)

func (UnimplementedDeploymentAdapterServiceServer) GetSpark 

func (UnimplementedDeploymentAdapterServiceServer) GetSpark(context.Context, *GetFunctionRequest) (*GetFunctionResponse, error)

func (UnimplementedDeploymentAdapterServiceServer) GetSparks 

func (UnimplementedDeploymentAdapterServiceServer) GetSparks(context.Context, *GetFunctionsRequest) (*GetFunctionsResponse, error)

func (UnimplementedDeploymentAdapterServiceServer) ReplaceSecret 

func (UnimplementedDeploymentAdapterServiceServer) ReplaceSecret(context.Context, *ReplaceSecretRequest) (*ReplaceSecretResponse, error)

func (UnimplementedDeploymentAdapterServiceServer) ScaleSpark 

func (UnimplementedDeploymentAdapterServiceServer) ScaleSpark(context.Context, *ScaleSparkRequest) (*ScaleSparkResponse, error)

func (UnimplementedDeploymentAdapterServiceServer) UndeploySpark 

func (UnimplementedDeploymentAdapterServiceServer) UndeploySpark(context.Context, *UndeploySparkRequest) (*UndeploySparkResponse, error)

type UnsafeDeploymentAdapterServiceServer 

type UnsafeDeploymentAdapterServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeDeploymentAdapterServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DeploymentAdapterServiceServer will result in compilation errors.

type VolumeMount 

type VolumeMount struct {
	Name        string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	ReadOnly    bool   `protobuf:"varint,2,opt,name=read_only,json=readOnly,proto3" json:"read_only,omitempty"`
	MountPath   string `protobuf:"bytes,3,opt,name=mount_path,json=mountPath,proto3" json:"mount_path,omitempty"`
	SubPath     string `protobuf:"bytes,4,opt,name=sub_path,json=subPath,proto3" json:"sub_path,omitempty"`
	SubPathExpr string `protobuf:"bytes,5,opt,name=sub_path_expr,json=subPathExpr,proto3" json:"sub_path_expr,omitempty"`
	// contains filtered or unexported fields
}

func (*VolumeMount) Descriptor deprecated 

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

Deprecated: Use VolumeMount.ProtoReflect.Descriptor instead.

func (*VolumeMount) GetMountPath 

func (x *VolumeMount) GetMountPath() string

func (*VolumeMount) GetName 

func (x *VolumeMount) GetName() string

func (*VolumeMount) GetReadOnly 

func (x *VolumeMount) GetReadOnly() bool

func (*VolumeMount) GetSubPath 

func (x *VolumeMount) GetSubPath() string

func (*VolumeMount) GetSubPathExpr 

func (x *VolumeMount) GetSubPathExpr() string

func (*VolumeMount) ProtoMessage 

func (*VolumeMount) ProtoMessage()

func (*VolumeMount) ProtoReflect 

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

func (*VolumeMount) Reset 

func (x *VolumeMount) Reset()

func (*VolumeMount) String 

func (x *VolumeMount) String() string

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.