grpc

package
v0.5.5 Latest Latest
Warning

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

 Go to latest Published: Oct 25, 2021 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_pkg_functions_grpc_functions_common_proto protoreflect.FileDescriptor
View Source 
var File_pkg_functions_grpc_functions_create_proto protoreflect.FileDescriptor
View Source 
var File_pkg_functions_grpc_functions_get_proto protoreflect.FileDescriptor
View Source 
var File_pkg_functions_grpc_functions_list_proto protoreflect.FileDescriptor
View Source 
var File_pkg_functions_grpc_functions_reconstruct_proto protoreflect.FileDescriptor
View Source 
var File_pkg_functions_grpc_functions_traffic_proto protoreflect.FileDescriptor
View Source 
var File_pkg_functions_grpc_functions_update_proto protoreflect.FileDescriptor
View Source 
var File_pkg_functions_grpc_pod_cancel_proto protoreflect.FileDescriptor
View Source 
var File_pkg_functions_grpc_pod_create_proto protoreflect.FileDescriptor
View Source 
var File_pkg_functions_grpc_pod_list_proto protoreflect.FileDescriptor
View Source 
var File_pkg_functions_grpc_protocol_proto protoreflect.FileDescriptor
View Source 
var File_pkg_functions_grpc_registries_get_proto protoreflect.FileDescriptor
View Source 
var File_pkg_functions_grpc_registry_delete_proto protoreflect.FileDescriptor
View Source 
var File_pkg_functions_grpc_registry_store_proto protoreflect.FileDescriptor
View Source 
var File_pkg_functions_grpc_revision_delete_proto protoreflect.FileDescriptor
View Source 
var File_pkg_functions_grpc_watch_functions_proto protoreflect.FileDescriptor
View Source 
var File_pkg_functions_grpc_watch_logs_proto protoreflect.FileDescriptor
View Source 
var File_pkg_functions_grpc_watch_pods_proto protoreflect.FileDescriptor
View Source 
var File_pkg_functions_grpc_watch_revisions_proto protoreflect.FileDescriptor
View Source 
var FunctionsService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "direktiv_functions.FunctionsService",
	HandlerType: (*FunctionsServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "StoreRegistry",
			Handler:    _FunctionsService_StoreRegistry_Handler,
		},
		{
			MethodName: "GetRegistries",
			Handler:    _FunctionsService_GetRegistries_Handler,
		},
		{
			MethodName: "DeleteRegistry",
			Handler:    _FunctionsService_DeleteRegistry_Handler,
		},
		{
			MethodName: "ReconstructFunction",
			Handler:    _FunctionsService_ReconstructFunction_Handler,
		},
		{
			MethodName: "UpdateFunction",
			Handler:    _FunctionsService_UpdateFunction_Handler,
		},
		{
			MethodName: "CreateFunction",
			Handler:    _FunctionsService_CreateFunction_Handler,
		},
		{
			MethodName: "DeleteFunctions",
			Handler:    _FunctionsService_DeleteFunctions_Handler,
		},
		{
			MethodName: "ListFunctions",
			Handler:    _FunctionsService_ListFunctions_Handler,
		},
		{
			MethodName: "GetFunction",
			Handler:    _FunctionsService_GetFunction_Handler,
		},
		{
			MethodName: "DeleteFunction",
			Handler:    _FunctionsService_DeleteFunction_Handler,
		},
		{
			MethodName: "SetFunctionsTraffic",
			Handler:    _FunctionsService_SetFunctionsTraffic_Handler,
		},
		{
			MethodName: "CreateFunctionsPod",
			Handler:    _FunctionsService_CreateFunctionsPod_Handler,
		},
		{
			MethodName: "CancelFunctionsPod",
			Handler:    _FunctionsService_CancelFunctionsPod_Handler,
		},
		{
			MethodName: "DeleteRevision",
			Handler:    _FunctionsService_DeleteRevision_Handler,
		},
		{
			MethodName: "ListPods",
			Handler:    _FunctionsService_ListPods_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "WatchFunctions",
			Handler:       _FunctionsService_WatchFunctions_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "WatchPods",
			Handler:       _FunctionsService_WatchPods_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "WatchRevisions",
			Handler:       _FunctionsService_WatchRevisions_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "WatchLogs",
			Handler:       _FunctionsService_WatchLogs_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "pkg/functions/grpc/protocol.proto",
}

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

Functions

func RegisterFunctionsServiceServer 

func RegisterFunctionsServiceServer(s grpc.ServiceRegistrar, srv FunctionsServiceServer)

Types

type BaseInfo 

type BaseInfo struct {
	Name          *string `protobuf:"bytes,1,opt,name=name,proto3,oneof" json:"name,omitempty"`
	Namespace     *string `protobuf:"bytes,2,opt,name=namespace,proto3,oneof" json:"namespace,omitempty"`
	Workflow      *string `protobuf:"bytes,3,opt,name=workflow,proto3,oneof" json:"workflow,omitempty"`
	Image         *string `protobuf:"bytes,4,opt,name=image,proto3,oneof" json:"image,omitempty"`
	Cmd           *string `protobuf:"bytes,5,opt,name=cmd,proto3,oneof" json:"cmd,omitempty"`
	Size          *int32  `protobuf:"varint,6,opt,name=size,proto3,oneof" json:"size,omitempty"`
	MinScale      *int32  `protobuf:"varint,7,opt,name=minScale,proto3,oneof" json:"minScale,omitempty"`
	NamespaceName *string `protobuf:"bytes,8,opt,name=namespaceName,proto3,oneof" json:"namespaceName,omitempty"`
	Path          *string `protobuf:"bytes,9,opt,name=path,proto3,oneof" json:"path,omitempty"`
	Revision      *string `protobuf:"bytes,10,opt,name=revision,proto3,oneof" json:"revision,omitempty"`
	// contains filtered or unexported fields
}

func (*BaseInfo) Descriptor deprecated 

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

Deprecated: Use BaseInfo.ProtoReflect.Descriptor instead.

func (*BaseInfo) GetCmd 

func (x *BaseInfo) GetCmd() string

func (*BaseInfo) GetImage 

func (x *BaseInfo) GetImage() string

func (*BaseInfo) GetMinScale 

func (x *BaseInfo) GetMinScale() int32

func (*BaseInfo) GetName 

func (x *BaseInfo) GetName() string

func (*BaseInfo) GetNamespace 

func (x *BaseInfo) GetNamespace() string

func (*BaseInfo) GetNamespaceName added in v0.5.0 

func (x *BaseInfo) GetNamespaceName() string

func (*BaseInfo) GetPath added in v0.5.0 

func (x *BaseInfo) GetPath() string

func (*BaseInfo) GetRevision added in v0.5.0 

func (x *BaseInfo) GetRevision() string

func (*BaseInfo) GetSize 

func (x *BaseInfo) GetSize() int32

func (*BaseInfo) GetWorkflow 

func (x *BaseInfo) GetWorkflow() string

func (*BaseInfo) ProtoMessage 

func (*BaseInfo) ProtoMessage()

func (*BaseInfo) ProtoReflect 

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

func (*BaseInfo) Reset 

func (x *BaseInfo) Reset()

func (*BaseInfo) String 

func (x *BaseInfo) String() string

type CancelPodRequest 

type CancelPodRequest struct {
	ActionID *string `protobuf:"bytes,1,opt,name=actionID,proto3,oneof" json:"actionID,omitempty"`
	// contains filtered or unexported fields
}

func (*CancelPodRequest) Descriptor deprecated 

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

Deprecated: Use CancelPodRequest.ProtoReflect.Descriptor instead.

func (*CancelPodRequest) GetActionID 

func (x *CancelPodRequest) GetActionID() string

func (*CancelPodRequest) ProtoMessage 

func (*CancelPodRequest) ProtoMessage()

func (*CancelPodRequest) ProtoReflect 

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

func (*CancelPodRequest) Reset 

func (x *CancelPodRequest) Reset()

func (*CancelPodRequest) String 

func (x *CancelPodRequest) String() string

type Condition 

type Condition struct {
	Name    *string `protobuf:"bytes,1,opt,name=name,proto3,oneof" json:"name,omitempty"`
	Status  *string `protobuf:"bytes,2,opt,name=status,proto3,oneof" json:"status,omitempty"`
	Reason  *string `protobuf:"bytes,3,opt,name=reason,proto3,oneof" json:"reason,omitempty"`
	Message *string `protobuf:"bytes,4,opt,name=message,proto3,oneof" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*Condition) Descriptor deprecated 

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

Deprecated: Use Condition.ProtoReflect.Descriptor instead.

func (*Condition) GetMessage 

func (x *Condition) GetMessage() string

func (*Condition) GetName 

func (x *Condition) GetName() string

func (*Condition) GetReason 

func (x *Condition) GetReason() string

func (*Condition) GetStatus 

func (x *Condition) GetStatus() string

func (*Condition) ProtoMessage 

func (*Condition) ProtoMessage()

func (*Condition) ProtoReflect 

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

func (*Condition) Reset 

func (x *Condition) Reset()

func (*Condition) String 

func (x *Condition) String() string

type CreateFunctionRequest 

type CreateFunctionRequest struct {
	Info *BaseInfo `protobuf:"bytes,1,opt,name=info,proto3,oneof" json:"info,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateFunctionRequest) Descriptor deprecated 

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

Deprecated: Use CreateFunctionRequest.ProtoReflect.Descriptor instead.

func (*CreateFunctionRequest) GetInfo 

func (x *CreateFunctionRequest) GetInfo() *BaseInfo

func (*CreateFunctionRequest) ProtoMessage 

func (*CreateFunctionRequest) ProtoMessage()

func (*CreateFunctionRequest) ProtoReflect 

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

func (*CreateFunctionRequest) Reset 

func (x *CreateFunctionRequest) Reset()

func (*CreateFunctionRequest) String 

func (x *CreateFunctionRequest) String() string

type CreatePodRequest 

type CreatePodRequest struct {
	Info       *BaseInfo `protobuf:"bytes,1,opt,name=info,proto3,oneof" json:"info,omitempty"`
	ActionID   *string   `protobuf:"bytes,2,opt,name=actionID,proto3,oneof" json:"actionID,omitempty"`
	InstanceID *string   `protobuf:"bytes,3,opt,name=InstanceID,proto3,oneof" json:"InstanceID,omitempty"`
	Step       *int64    `protobuf:"varint,4,opt,name=step,proto3,oneof" json:"step,omitempty"`
	// contains filtered or unexported fields
}

func (*CreatePodRequest) Descriptor deprecated 

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

Deprecated: Use CreatePodRequest.ProtoReflect.Descriptor instead.

func (*CreatePodRequest) GetActionID 

func (x *CreatePodRequest) GetActionID() string

func (*CreatePodRequest) GetInfo 

func (x *CreatePodRequest) GetInfo() *BaseInfo

func (*CreatePodRequest) GetInstanceID 

func (x *CreatePodRequest) GetInstanceID() string

func (*CreatePodRequest) GetStep 

func (x *CreatePodRequest) GetStep() int64

func (*CreatePodRequest) ProtoMessage 

func (*CreatePodRequest) ProtoMessage()

func (*CreatePodRequest) ProtoReflect 

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

func (*CreatePodRequest) Reset 

func (x *CreatePodRequest) Reset()

func (*CreatePodRequest) String 

func (x *CreatePodRequest) String() string

type CreatePodResponse 

type CreatePodResponse struct {
	Ip       *string `protobuf:"bytes,1,opt,name=ip,proto3,oneof" json:"ip,omitempty"`
	Hostname *string `protobuf:"bytes,2,opt,name=hostname,proto3,oneof" json:"hostname,omitempty"`
	// contains filtered or unexported fields
}

func (*CreatePodResponse) Descriptor deprecated 

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

Deprecated: Use CreatePodResponse.ProtoReflect.Descriptor instead.

func (*CreatePodResponse) GetHostname 

func (x *CreatePodResponse) GetHostname() string

func (*CreatePodResponse) GetIp 

func (x *CreatePodResponse) GetIp() string

func (*CreatePodResponse) ProtoMessage 

func (*CreatePodResponse) ProtoMessage()

func (*CreatePodResponse) ProtoReflect 

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

func (*CreatePodResponse) Reset 

func (x *CreatePodResponse) Reset()

func (*CreatePodResponse) String 

func (x *CreatePodResponse) String() string

type DeleteRegistryRequest 

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

func (*DeleteRegistryRequest) Descriptor deprecated 

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

Deprecated: Use DeleteRegistryRequest.ProtoReflect.Descriptor instead.

func (*DeleteRegistryRequest) GetName 

func (x *DeleteRegistryRequest) GetName() string

func (*DeleteRegistryRequest) GetNamespace 

func (x *DeleteRegistryRequest) GetNamespace() string

func (*DeleteRegistryRequest) ProtoMessage 

func (*DeleteRegistryRequest) ProtoMessage()

func (*DeleteRegistryRequest) ProtoReflect 

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

func (*DeleteRegistryRequest) Reset 

func (x *DeleteRegistryRequest) Reset()

func (*DeleteRegistryRequest) String 

func (x *DeleteRegistryRequest) String() string

type DeleteRevisionRequest 

type DeleteRevisionRequest struct {
	Revision *string `protobuf:"bytes,1,opt,name=revision,proto3,oneof" json:"revision,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteRevisionRequest) Descriptor deprecated 

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

Deprecated: Use DeleteRevisionRequest.ProtoReflect.Descriptor instead.

func (*DeleteRevisionRequest) GetRevision 

func (x *DeleteRevisionRequest) GetRevision() string

func (*DeleteRevisionRequest) ProtoMessage 

func (*DeleteRevisionRequest) ProtoMessage()

func (*DeleteRevisionRequest) ProtoReflect 

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

func (*DeleteRevisionRequest) Reset 

func (x *DeleteRevisionRequest) Reset()

func (*DeleteRevisionRequest) String 

func (x *DeleteRevisionRequest) String() string

type FunctionsConfig 

type FunctionsConfig struct {
	Maxscale *int32 `protobuf:"varint,1,opt,name=maxscale,proto3,oneof" json:"maxscale,omitempty"`
	// contains filtered or unexported fields
}

func (*FunctionsConfig) Descriptor deprecated 

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

Deprecated: Use FunctionsConfig.ProtoReflect.Descriptor instead.

func (*FunctionsConfig) GetMaxscale 

func (x *FunctionsConfig) GetMaxscale() int32

func (*FunctionsConfig) ProtoMessage 

func (*FunctionsConfig) ProtoMessage()

func (*FunctionsConfig) ProtoReflect 

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

func (*FunctionsConfig) Reset 

func (x *FunctionsConfig) Reset()

func (*FunctionsConfig) String 

func (x *FunctionsConfig) String() string

type FunctionsInfo 

type FunctionsInfo struct {
	Info        *BaseInfo    `protobuf:"bytes,1,opt,name=info,proto3,oneof" json:"info,omitempty"`
	Status      *string      `protobuf:"bytes,2,opt,name=status,proto3,oneof" json:"status,omitempty"`
	Conditions  []*Condition `protobuf:"bytes,3,rep,name=conditions,proto3" json:"conditions,omitempty"`
	ServiceName *string      `protobuf:"bytes,4,opt,name=serviceName,proto3,oneof" json:"serviceName,omitempty"`
	// contains filtered or unexported fields
}

func (*FunctionsInfo) Descriptor deprecated 

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

Deprecated: Use FunctionsInfo.ProtoReflect.Descriptor instead.

func (*FunctionsInfo) GetConditions 

func (x *FunctionsInfo) GetConditions() []*Condition

func (*FunctionsInfo) GetInfo 

func (x *FunctionsInfo) GetInfo() *BaseInfo

func (*FunctionsInfo) GetServiceName 

func (x *FunctionsInfo) GetServiceName() string

func (*FunctionsInfo) GetStatus 

func (x *FunctionsInfo) GetStatus() string

func (*FunctionsInfo) ProtoMessage 

func (*FunctionsInfo) ProtoMessage()

func (*FunctionsInfo) ProtoReflect 

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

func (*FunctionsInfo) Reset 

func (x *FunctionsInfo) Reset()

func (*FunctionsInfo) String 

func (x *FunctionsInfo) String() string

type FunctionsServiceClient 

type FunctionsServiceClient interface {
	StoreRegistry(ctx context.Context, in *StoreRegistryRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	GetRegistries(ctx context.Context, in *GetRegistriesRequest, opts ...grpc.CallOption) (*GetRegistriesResponse, error)
	DeleteRegistry(ctx context.Context, in *DeleteRegistryRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	ReconstructFunction(ctx context.Context, in *ReconstructFunctionRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	UpdateFunction(ctx context.Context, in *UpdateFunctionRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	CreateFunction(ctx context.Context, in *CreateFunctionRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	DeleteFunctions(ctx context.Context, in *ListFunctionsRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	ListFunctions(ctx context.Context, in *ListFunctionsRequest, opts ...grpc.CallOption) (*ListFunctionsResponse, error)
	GetFunction(ctx context.Context, in *GetFunctionRequest, opts ...grpc.CallOption) (*GetFunctionResponse, error)
	DeleteFunction(ctx context.Context, in *GetFunctionRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	SetFunctionsTraffic(ctx context.Context, in *SetTrafficRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	CreateFunctionsPod(ctx context.Context, in *CreatePodRequest, opts ...grpc.CallOption) (*CreatePodResponse, error)
	CancelFunctionsPod(ctx context.Context, in *CancelPodRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	DeleteRevision(ctx context.Context, in *DeleteRevisionRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	WatchFunctions(ctx context.Context, in *WatchFunctionsRequest, opts ...grpc.CallOption) (FunctionsService_WatchFunctionsClient, error)
	WatchPods(ctx context.Context, in *WatchPodsRequest, opts ...grpc.CallOption) (FunctionsService_WatchPodsClient, error)
	WatchRevisions(ctx context.Context, in *WatchRevisionsRequest, opts ...grpc.CallOption) (FunctionsService_WatchRevisionsClient, error)
	WatchLogs(ctx context.Context, in *WatchLogsRequest, opts ...grpc.CallOption) (FunctionsService_WatchLogsClient, error)
	ListPods(ctx context.Context, in *ListPodsRequest, opts ...grpc.CallOption) (*ListPodsResponse, error)
}

FunctionsServiceClient is the client API for FunctionsService 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 NewFunctionsServiceClient 

func NewFunctionsServiceClient(cc grpc.ClientConnInterface) FunctionsServiceClient

type FunctionsServiceServer 

type FunctionsServiceServer interface {
	StoreRegistry(context.Context, *StoreRegistryRequest) (*emptypb.Empty, error)
	GetRegistries(context.Context, *GetRegistriesRequest) (*GetRegistriesResponse, error)
	DeleteRegistry(context.Context, *DeleteRegistryRequest) (*emptypb.Empty, error)
	ReconstructFunction(context.Context, *ReconstructFunctionRequest) (*emptypb.Empty, error)
	UpdateFunction(context.Context, *UpdateFunctionRequest) (*emptypb.Empty, error)
	CreateFunction(context.Context, *CreateFunctionRequest) (*emptypb.Empty, error)
	DeleteFunctions(context.Context, *ListFunctionsRequest) (*emptypb.Empty, error)
	ListFunctions(context.Context, *ListFunctionsRequest) (*ListFunctionsResponse, error)
	GetFunction(context.Context, *GetFunctionRequest) (*GetFunctionResponse, error)
	DeleteFunction(context.Context, *GetFunctionRequest) (*emptypb.Empty, error)
	SetFunctionsTraffic(context.Context, *SetTrafficRequest) (*emptypb.Empty, error)
	CreateFunctionsPod(context.Context, *CreatePodRequest) (*CreatePodResponse, error)
	CancelFunctionsPod(context.Context, *CancelPodRequest) (*emptypb.Empty, error)
	DeleteRevision(context.Context, *DeleteRevisionRequest) (*emptypb.Empty, error)
	WatchFunctions(*WatchFunctionsRequest, FunctionsService_WatchFunctionsServer) error
	WatchPods(*WatchPodsRequest, FunctionsService_WatchPodsServer) error
	WatchRevisions(*WatchRevisionsRequest, FunctionsService_WatchRevisionsServer) error
	WatchLogs(*WatchLogsRequest, FunctionsService_WatchLogsServer) error
	ListPods(context.Context, *ListPodsRequest) (*ListPodsResponse, error)
	// contains filtered or unexported methods
}

FunctionsServiceServer is the server API for FunctionsService service. All implementations must embed UnimplementedFunctionsServiceServer for forward compatibility

type FunctionsService_WatchFunctionsClient added in v0.4.1 

type FunctionsService_WatchFunctionsClient interface {
	Recv() (*WatchFunctionsResponse, error)
	grpc.ClientStream
}

type FunctionsService_WatchFunctionsServer added in v0.4.1 

type FunctionsService_WatchFunctionsServer interface {
	Send(*WatchFunctionsResponse) error
	grpc.ServerStream
}

type FunctionsService_WatchLogsClient added in v0.4.1 

type FunctionsService_WatchLogsClient interface {
	Recv() (*WatchLogsResponse, error)
	grpc.ClientStream
}

type FunctionsService_WatchLogsServer added in v0.4.1 

type FunctionsService_WatchLogsServer interface {
	Send(*WatchLogsResponse) error
	grpc.ServerStream
}

type FunctionsService_WatchPodsClient added in v0.4.1 

type FunctionsService_WatchPodsClient interface {
	Recv() (*WatchPodsResponse, error)
	grpc.ClientStream
}

type FunctionsService_WatchPodsServer added in v0.4.1 

type FunctionsService_WatchPodsServer interface {
	Send(*WatchPodsResponse) error
	grpc.ServerStream
}

type FunctionsService_WatchRevisionsClient added in v0.4.1 

type FunctionsService_WatchRevisionsClient interface {
	Recv() (*WatchRevisionsResponse, error)
	grpc.ClientStream
}

type FunctionsService_WatchRevisionsServer added in v0.4.1 

type FunctionsService_WatchRevisionsServer interface {
	Send(*WatchRevisionsResponse) error
	grpc.ServerStream
}

type GetFunctionRequest 

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

func (*GetFunctionRequest) Descriptor deprecated 

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

Deprecated: Use GetFunctionRequest.ProtoReflect.Descriptor instead.

func (*GetFunctionRequest) GetServiceName 

func (x *GetFunctionRequest) GetServiceName() 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 {
	Name             *string          `protobuf:"bytes,1,opt,name=name,proto3,oneof" json:"name,omitempty"`
	Namespace        *string          `protobuf:"bytes,2,opt,name=namespace,proto3,oneof" json:"namespace,omitempty"`
	Workflow         *string          `protobuf:"bytes,3,opt,name=workflow,proto3,oneof" json:"workflow,omitempty"`
	Config           *FunctionsConfig `protobuf:"bytes,4,opt,name=config,proto3,oneof" json:"config,omitempty"`
	Revisions        []*Revision      `protobuf:"bytes,5,rep,name=revisions,proto3" json:"revisions,omitempty"`
	Scope            *string          `protobuf:"bytes,6,opt,name=scope,proto3,oneof" json:"scope,omitempty"`
	NamespaceID      *string          `protobuf:"bytes,7,opt,name=namespaceID,proto3,oneof" json:"namespaceID,omitempty"`
	Path             *string          `protobuf:"bytes,8,opt,name=path,proto3,oneof" json:"path,omitempty"`
	WorkflowRevision *string          `protobuf:"bytes,9,opt,name=workflowRevision,proto3,oneof" json:"workflowRevision,omitempty"`
	// contains filtered or unexported fields
}

func (*GetFunctionResponse) Descriptor deprecated 

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

Deprecated: Use GetFunctionResponse.ProtoReflect.Descriptor instead.

func (*GetFunctionResponse) GetConfig 

func (x *GetFunctionResponse) GetConfig() *FunctionsConfig

func (*GetFunctionResponse) GetName 

func (x *GetFunctionResponse) GetName() string

func (*GetFunctionResponse) GetNamespace 

func (x *GetFunctionResponse) GetNamespace() string

func (*GetFunctionResponse) GetNamespaceID added in v0.5.0 

func (x *GetFunctionResponse) GetNamespaceID() string

func (*GetFunctionResponse) GetPath added in v0.5.0 

func (x *GetFunctionResponse) GetPath() string

func (*GetFunctionResponse) GetRevisions 

func (x *GetFunctionResponse) GetRevisions() []*Revision

func (*GetFunctionResponse) GetScope added in v0.5.0 

func (x *GetFunctionResponse) GetScope() string

func (*GetFunctionResponse) GetWorkflow 

func (x *GetFunctionResponse) GetWorkflow() string

func (*GetFunctionResponse) GetWorkflowRevision added in v0.5.0 

func (x *GetFunctionResponse) GetWorkflowRevision() string

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 GetRegistriesRequest 

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

func (*GetRegistriesRequest) Descriptor deprecated 

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

Deprecated: Use GetRegistriesRequest.ProtoReflect.Descriptor instead.

func (*GetRegistriesRequest) GetNamespace 

func (x *GetRegistriesRequest) GetNamespace() string

func (*GetRegistriesRequest) ProtoMessage 

func (*GetRegistriesRequest) ProtoMessage()

func (*GetRegistriesRequest) ProtoReflect 

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

func (*GetRegistriesRequest) Reset 

func (x *GetRegistriesRequest) Reset()

func (*GetRegistriesRequest) String 

func (x *GetRegistriesRequest) String() string

type GetRegistriesResponse 

type GetRegistriesResponse struct {
	Registries []*GetRegistriesResponse_Registry `protobuf:"bytes,1,rep,name=registries,proto3" json:"registries,omitempty"`
	// contains filtered or unexported fields
}

func (*GetRegistriesResponse) Descriptor deprecated 

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

Deprecated: Use GetRegistriesResponse.ProtoReflect.Descriptor instead.

func (*GetRegistriesResponse) GetRegistries 

func (x *GetRegistriesResponse) GetRegistries() []*GetRegistriesResponse_Registry

func (*GetRegistriesResponse) ProtoMessage 

func (*GetRegistriesResponse) ProtoMessage()

func (*GetRegistriesResponse) ProtoReflect 

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

func (*GetRegistriesResponse) Reset 

func (x *GetRegistriesResponse) Reset()

func (*GetRegistriesResponse) String 

func (x *GetRegistriesResponse) String() string

type GetRegistriesResponse_Registry 

type GetRegistriesResponse_Registry struct {
	Name *string `protobuf:"bytes,1,opt,name=name,proto3,oneof" json:"name,omitempty"`
	Id   *string `protobuf:"bytes,2,opt,name=id,proto3,oneof" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetRegistriesResponse_Registry) Descriptor deprecated 

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

Deprecated: Use GetRegistriesResponse_Registry.ProtoReflect.Descriptor instead.

func (*GetRegistriesResponse_Registry) GetId 

func (x *GetRegistriesResponse_Registry) GetId() string

func (*GetRegistriesResponse_Registry) GetName 

func (x *GetRegistriesResponse_Registry) GetName() string

func (*GetRegistriesResponse_Registry) ProtoMessage 

func (*GetRegistriesResponse_Registry) ProtoMessage()

func (*GetRegistriesResponse_Registry) ProtoReflect 

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

func (*GetRegistriesResponse_Registry) Reset 

func (x *GetRegistriesResponse_Registry) Reset()

func (*GetRegistriesResponse_Registry) String 

func (x *GetRegistriesResponse_Registry) String() string

type ListFunctionsRequest 

type ListFunctionsRequest struct {
	Annotations map[string]string `` /* 163-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ListFunctionsRequest) Descriptor deprecated 

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

Deprecated: Use ListFunctionsRequest.ProtoReflect.Descriptor instead.

func (*ListFunctionsRequest) GetAnnotations 

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

func (*ListFunctionsRequest) ProtoMessage 

func (*ListFunctionsRequest) ProtoMessage()

func (*ListFunctionsRequest) ProtoReflect 

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

func (*ListFunctionsRequest) Reset 

func (x *ListFunctionsRequest) Reset()

func (*ListFunctionsRequest) String 

func (x *ListFunctionsRequest) String() string

type ListFunctionsResponse 

type ListFunctionsResponse struct {
	Config    *FunctionsConfig `protobuf:"bytes,1,opt,name=config,proto3,oneof" json:"config,omitempty"`
	Functions []*FunctionsInfo `protobuf:"bytes,2,rep,name=functions,proto3" json:"functions,omitempty"`
	// contains filtered or unexported fields
}

func (*ListFunctionsResponse) Descriptor deprecated 

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

Deprecated: Use ListFunctionsResponse.ProtoReflect.Descriptor instead.

func (*ListFunctionsResponse) GetConfig 

func (x *ListFunctionsResponse) GetConfig() *FunctionsConfig

func (*ListFunctionsResponse) GetFunctions 

func (x *ListFunctionsResponse) GetFunctions() []*FunctionsInfo

func (*ListFunctionsResponse) ProtoMessage 

func (*ListFunctionsResponse) ProtoMessage()

func (*ListFunctionsResponse) ProtoReflect 

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

func (*ListFunctionsResponse) Reset 

func (x *ListFunctionsResponse) Reset()

func (*ListFunctionsResponse) String 

func (x *ListFunctionsResponse) String() string

type ListPodsRequest added in v0.4.1 

type ListPodsRequest struct {
	Annotations map[string]string `` /* 163-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ListPodsRequest) Descriptor deprecated added in v0.4.1 

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

Deprecated: Use ListPodsRequest.ProtoReflect.Descriptor instead.

func (*ListPodsRequest) GetAnnotations added in v0.4.1 

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

func (*ListPodsRequest) ProtoMessage added in v0.4.1 

func (*ListPodsRequest) ProtoMessage()

func (*ListPodsRequest) ProtoReflect added in v0.4.1 

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

func (*ListPodsRequest) Reset added in v0.4.1 

func (x *ListPodsRequest) Reset()

func (*ListPodsRequest) String added in v0.4.1 

func (x *ListPodsRequest) String() string

type ListPodsResponse added in v0.4.1 

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

func (*ListPodsResponse) Descriptor deprecated added in v0.4.1 

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

Deprecated: Use ListPodsResponse.ProtoReflect.Descriptor instead.

func (*ListPodsResponse) GetPods added in v0.4.1 

func (x *ListPodsResponse) GetPods() []*PodsInfo

func (*ListPodsResponse) ProtoMessage added in v0.4.1 

func (*ListPodsResponse) ProtoMessage()

func (*ListPodsResponse) ProtoReflect added in v0.4.1 

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

func (*ListPodsResponse) Reset added in v0.4.1 

func (x *ListPodsResponse) Reset()

func (*ListPodsResponse) String added in v0.4.1 

func (x *ListPodsResponse) String() string

type PodsInfo added in v0.4.1 

type PodsInfo struct {
	Name            *string `protobuf:"bytes,1,opt,name=name,proto3,oneof" json:"name,omitempty"`
	Status          *string `protobuf:"bytes,2,opt,name=status,proto3,oneof" json:"status,omitempty"`
	ServiceName     *string `protobuf:"bytes,3,opt,name=serviceName,proto3,oneof" json:"serviceName,omitempty"`
	ServiceRevision *string `protobuf:"bytes,4,opt,name=serviceRevision,proto3,oneof" json:"serviceRevision,omitempty"`
	// contains filtered or unexported fields
}

func (*PodsInfo) Descriptor deprecated added in v0.4.1 

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

Deprecated: Use PodsInfo.ProtoReflect.Descriptor instead.

func (*PodsInfo) GetName added in v0.4.1 

func (x *PodsInfo) GetName() string

func (*PodsInfo) GetServiceName added in v0.4.1 

func (x *PodsInfo) GetServiceName() string

func (*PodsInfo) GetServiceRevision added in v0.4.1 

func (x *PodsInfo) GetServiceRevision() string

func (*PodsInfo) GetStatus added in v0.4.1 

func (x *PodsInfo) GetStatus() string

func (*PodsInfo) ProtoMessage added in v0.4.1 

func (*PodsInfo) ProtoMessage()

func (*PodsInfo) ProtoReflect added in v0.4.1 

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

func (*PodsInfo) Reset added in v0.4.1 

func (x *PodsInfo) Reset()

func (*PodsInfo) String added in v0.4.1 

func (x *PodsInfo) String() string

type ReconstructFunctionRequest added in v0.5.0 

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

func (*ReconstructFunctionRequest) Descriptor deprecated added in v0.5.0 

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

Deprecated: Use ReconstructFunctionRequest.ProtoReflect.Descriptor instead.

func (*ReconstructFunctionRequest) GetName added in v0.5.0 

func (x *ReconstructFunctionRequest) GetName() string

func (*ReconstructFunctionRequest) ProtoMessage added in v0.5.0 

func (*ReconstructFunctionRequest) ProtoMessage()

func (*ReconstructFunctionRequest) ProtoReflect added in v0.5.0 

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

func (*ReconstructFunctionRequest) Reset added in v0.5.0 

func (x *ReconstructFunctionRequest) Reset()

func (*ReconstructFunctionRequest) String added in v0.5.0 

func (x *ReconstructFunctionRequest) String() string

type Revision 

type Revision struct {
	Name            *string      `protobuf:"bytes,1,opt,name=name,proto3,oneof" json:"name,omitempty"`
	Image           *string      `protobuf:"bytes,2,opt,name=image,proto3,oneof" json:"image,omitempty"`
	Cmd             *string      `protobuf:"bytes,3,opt,name=cmd,proto3,oneof" json:"cmd,omitempty"`
	Size            *int32       `protobuf:"varint,4,opt,name=size,proto3,oneof" json:"size,omitempty"`
	MinScale        *int32       `protobuf:"varint,5,opt,name=minScale,proto3,oneof" json:"minScale,omitempty"`
	Generation      *int64       `protobuf:"varint,6,opt,name=generation,proto3,oneof" json:"generation,omitempty"`
	Created         *int64       `protobuf:"varint,7,opt,name=created,proto3,oneof" json:"created,omitempty"`
	Status          *string      `protobuf:"bytes,8,opt,name=status,proto3,oneof" json:"status,omitempty"`
	Conditions      []*Condition `protobuf:"bytes,9,rep,name=conditions,proto3" json:"conditions,omitempty"`
	Traffic         *int64       `protobuf:"varint,10,opt,name=traffic,proto3,oneof" json:"traffic,omitempty"`
	DesiredReplicas int64        `protobuf:"varint,11,opt,name=desiredReplicas,proto3" json:"desiredReplicas,omitempty"`
	ActualReplicas  int64        `protobuf:"varint,12,opt,name=actualReplicas,proto3" json:"actualReplicas,omitempty"`
	Rev             *string      `protobuf:"bytes,13,opt,name=rev,proto3,oneof" json:"rev,omitempty"`
	// contains filtered or unexported fields
}

func (*Revision) Descriptor deprecated 

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

Deprecated: Use Revision.ProtoReflect.Descriptor instead.

func (*Revision) GetActualReplicas added in v0.4.1 

func (x *Revision) GetActualReplicas() int64

func (*Revision) GetCmd 

func (x *Revision) GetCmd() string

func (*Revision) GetConditions 

func (x *Revision) GetConditions() []*Condition

func (*Revision) GetCreated 

func (x *Revision) GetCreated() int64

func (*Revision) GetDesiredReplicas added in v0.4.1 

func (x *Revision) GetDesiredReplicas() int64

func (*Revision) GetGeneration 

func (x *Revision) GetGeneration() int64

func (*Revision) GetImage 

func (x *Revision) GetImage() string

func (*Revision) GetMinScale 

func (x *Revision) GetMinScale() int32

func (*Revision) GetName 

func (x *Revision) GetName() string

func (*Revision) GetRev added in v0.5.0 

func (x *Revision) GetRev() string

func (*Revision) GetSize 

func (x *Revision) GetSize() int32

func (*Revision) GetStatus 

func (x *Revision) GetStatus() string

func (*Revision) GetTraffic 

func (x *Revision) GetTraffic() int64

func (*Revision) ProtoMessage 

func (*Revision) ProtoMessage()

func (*Revision) ProtoReflect 

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

func (*Revision) Reset 

func (x *Revision) Reset()

func (*Revision) String 

func (x *Revision) String() string

type SetTrafficRequest 

type SetTrafficRequest struct {
	Name    *string         `protobuf:"bytes,1,opt,name=name,proto3,oneof" json:"name,omitempty"`
	Traffic []*TrafficValue `protobuf:"bytes,2,rep,name=traffic,proto3" json:"traffic,omitempty"`
	// contains filtered or unexported fields
}

func (*SetTrafficRequest) Descriptor deprecated 

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

Deprecated: Use SetTrafficRequest.ProtoReflect.Descriptor instead.

func (*SetTrafficRequest) GetName 

func (x *SetTrafficRequest) GetName() string

func (*SetTrafficRequest) GetTraffic 

func (x *SetTrafficRequest) GetTraffic() []*TrafficValue

func (*SetTrafficRequest) ProtoMessage 

func (*SetTrafficRequest) ProtoMessage()

func (*SetTrafficRequest) ProtoReflect 

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

func (*SetTrafficRequest) Reset 

func (x *SetTrafficRequest) Reset()

func (*SetTrafficRequest) String 

func (x *SetTrafficRequest) String() string

type StoreRegistryRequest 

type StoreRegistryRequest struct {
	Namespace *string `protobuf:"bytes,1,opt,name=namespace,proto3,oneof" json:"namespace,omitempty"`
	Name      *string `protobuf:"bytes,2,opt,name=name,proto3,oneof" json:"name,omitempty"`
	Data      []byte  `protobuf:"bytes,3,opt,name=data,proto3,oneof" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*StoreRegistryRequest) Descriptor deprecated 

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

Deprecated: Use StoreRegistryRequest.ProtoReflect.Descriptor instead.

func (*StoreRegistryRequest) GetData 

func (x *StoreRegistryRequest) GetData() []byte

func (*StoreRegistryRequest) GetName 

func (x *StoreRegistryRequest) GetName() string

func (*StoreRegistryRequest) GetNamespace 

func (x *StoreRegistryRequest) GetNamespace() string

func (*StoreRegistryRequest) ProtoMessage 

func (*StoreRegistryRequest) ProtoMessage()

func (*StoreRegistryRequest) ProtoReflect 

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

func (*StoreRegistryRequest) Reset 

func (x *StoreRegistryRequest) Reset()

func (*StoreRegistryRequest) String 

func (x *StoreRegistryRequest) String() string

type Traffic added in v0.4.1 

type Traffic struct {
	RevisionName *string `protobuf:"bytes,1,opt,name=revisionName,proto3,oneof" json:"revisionName,omitempty"`
	Traffic      *int64  `protobuf:"varint,2,opt,name=traffic,proto3,oneof" json:"traffic,omitempty"`
	Generation   *int64  `protobuf:"varint,3,opt,name=generation,proto3,oneof" json:"generation,omitempty"`
	// contains filtered or unexported fields
}

func (*Traffic) Descriptor deprecated added in v0.4.1 

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

Deprecated: Use Traffic.ProtoReflect.Descriptor instead.

func (*Traffic) GetGeneration added in v0.4.1 

func (x *Traffic) GetGeneration() int64

func (*Traffic) GetRevisionName added in v0.4.1 

func (x *Traffic) GetRevisionName() string

func (*Traffic) GetTraffic added in v0.4.1 

func (x *Traffic) GetTraffic() int64

func (*Traffic) ProtoMessage added in v0.4.1 

func (*Traffic) ProtoMessage()

func (*Traffic) ProtoReflect added in v0.4.1 

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

func (*Traffic) Reset added in v0.4.1 

func (x *Traffic) Reset()

func (*Traffic) String added in v0.4.1 

func (x *Traffic) String() string

type TrafficValue 

type TrafficValue struct {
	Revision *string `protobuf:"bytes,1,opt,name=revision,proto3,oneof" json:"revision,omitempty"`
	Percent  *int64  `protobuf:"varint,2,opt,name=percent,proto3,oneof" json:"percent,omitempty"`
	// contains filtered or unexported fields
}

func (*TrafficValue) Descriptor deprecated 

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

Deprecated: Use TrafficValue.ProtoReflect.Descriptor instead.

func (*TrafficValue) GetPercent 

func (x *TrafficValue) GetPercent() int64

func (*TrafficValue) GetRevision 

func (x *TrafficValue) GetRevision() string

func (*TrafficValue) ProtoMessage 

func (*TrafficValue) ProtoMessage()

func (*TrafficValue) ProtoReflect 

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

func (*TrafficValue) Reset 

func (x *TrafficValue) Reset()

func (*TrafficValue) String 

func (x *TrafficValue) String() string

type UnimplementedFunctionsServiceServer 

type UnimplementedFunctionsServiceServer struct {
}

UnimplementedFunctionsServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedFunctionsServiceServer) CancelFunctionsPod 

func (UnimplementedFunctionsServiceServer) CancelFunctionsPod(context.Context, *CancelPodRequest) (*emptypb.Empty, error)

func (UnimplementedFunctionsServiceServer) CreateFunction 

func (UnimplementedFunctionsServiceServer) CreateFunction(context.Context, *CreateFunctionRequest) (*emptypb.Empty, error)

func (UnimplementedFunctionsServiceServer) CreateFunctionsPod 

func (UnimplementedFunctionsServiceServer) CreateFunctionsPod(context.Context, *CreatePodRequest) (*CreatePodResponse, error)

func (UnimplementedFunctionsServiceServer) DeleteFunction 

func (UnimplementedFunctionsServiceServer) DeleteFunction(context.Context, *GetFunctionRequest) (*emptypb.Empty, error)

func (UnimplementedFunctionsServiceServer) DeleteFunctions 

func (UnimplementedFunctionsServiceServer) DeleteFunctions(context.Context, *ListFunctionsRequest) (*emptypb.Empty, error)

func (UnimplementedFunctionsServiceServer) DeleteRegistry 

func (UnimplementedFunctionsServiceServer) DeleteRegistry(context.Context, *DeleteRegistryRequest) (*emptypb.Empty, error)

func (UnimplementedFunctionsServiceServer) DeleteRevision 

func (UnimplementedFunctionsServiceServer) DeleteRevision(context.Context, *DeleteRevisionRequest) (*emptypb.Empty, error)

func (UnimplementedFunctionsServiceServer) GetFunction 

func (UnimplementedFunctionsServiceServer) GetFunction(context.Context, *GetFunctionRequest) (*GetFunctionResponse, error)

func (UnimplementedFunctionsServiceServer) GetRegistries 

func (UnimplementedFunctionsServiceServer) GetRegistries(context.Context, *GetRegistriesRequest) (*GetRegistriesResponse, error)

func (UnimplementedFunctionsServiceServer) ListFunctions 

func (UnimplementedFunctionsServiceServer) ListFunctions(context.Context, *ListFunctionsRequest) (*ListFunctionsResponse, error)

func (UnimplementedFunctionsServiceServer) ListPods added in v0.4.1 

func (UnimplementedFunctionsServiceServer) ListPods(context.Context, *ListPodsRequest) (*ListPodsResponse, error)

func (UnimplementedFunctionsServiceServer) ReconstructFunction added in v0.5.0 

func (UnimplementedFunctionsServiceServer) ReconstructFunction(context.Context, *ReconstructFunctionRequest) (*emptypb.Empty, error)

func (UnimplementedFunctionsServiceServer) SetFunctionsTraffic 

func (UnimplementedFunctionsServiceServer) SetFunctionsTraffic(context.Context, *SetTrafficRequest) (*emptypb.Empty, error)

func (UnimplementedFunctionsServiceServer) StoreRegistry 

func (UnimplementedFunctionsServiceServer) StoreRegistry(context.Context, *StoreRegistryRequest) (*emptypb.Empty, error)

func (UnimplementedFunctionsServiceServer) UpdateFunction 

func (UnimplementedFunctionsServiceServer) UpdateFunction(context.Context, *UpdateFunctionRequest) (*emptypb.Empty, error)

func (UnimplementedFunctionsServiceServer) WatchFunctions added in v0.4.1 

func (UnimplementedFunctionsServiceServer) WatchFunctions(*WatchFunctionsRequest, FunctionsService_WatchFunctionsServer) error

func (UnimplementedFunctionsServiceServer) WatchLogs added in v0.4.1 

func (UnimplementedFunctionsServiceServer) WatchLogs(*WatchLogsRequest, FunctionsService_WatchLogsServer) error

func (UnimplementedFunctionsServiceServer) WatchPods added in v0.4.1 

func (UnimplementedFunctionsServiceServer) WatchPods(*WatchPodsRequest, FunctionsService_WatchPodsServer) error

func (UnimplementedFunctionsServiceServer) WatchRevisions added in v0.4.1 

func (UnimplementedFunctionsServiceServer) WatchRevisions(*WatchRevisionsRequest, FunctionsService_WatchRevisionsServer) error

type UnsafeFunctionsServiceServer 

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

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

type UpdateFunctionRequest 

type UpdateFunctionRequest struct {
	Info           *BaseInfo `protobuf:"bytes,1,opt,name=info,proto3,oneof" json:"info,omitempty"`
	ServiceName    *string   `protobuf:"bytes,2,opt,name=ServiceName,proto3,oneof" json:"ServiceName,omitempty"`
	TrafficPercent *int64    `protobuf:"varint,3,opt,name=TrafficPercent,proto3,oneof" json:"TrafficPercent,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateFunctionRequest) Descriptor deprecated 

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

Deprecated: Use UpdateFunctionRequest.ProtoReflect.Descriptor instead.

func (*UpdateFunctionRequest) GetInfo 

func (x *UpdateFunctionRequest) GetInfo() *BaseInfo

func (*UpdateFunctionRequest) GetServiceName 

func (x *UpdateFunctionRequest) GetServiceName() string

func (*UpdateFunctionRequest) GetTrafficPercent 

func (x *UpdateFunctionRequest) GetTrafficPercent() int64

func (*UpdateFunctionRequest) ProtoMessage 

func (*UpdateFunctionRequest) ProtoMessage()

func (*UpdateFunctionRequest) ProtoReflect 

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

func (*UpdateFunctionRequest) Reset 

func (x *UpdateFunctionRequest) Reset()

func (*UpdateFunctionRequest) String 

func (x *UpdateFunctionRequest) String() string

type WatchFunctionsRequest added in v0.4.1 

type WatchFunctionsRequest struct {
	Annotations map[string]string `` /* 163-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*WatchFunctionsRequest) Descriptor deprecated added in v0.4.1 

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

Deprecated: Use WatchFunctionsRequest.ProtoReflect.Descriptor instead.

func (*WatchFunctionsRequest) GetAnnotations added in v0.4.1 

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

func (*WatchFunctionsRequest) ProtoMessage added in v0.4.1 

func (*WatchFunctionsRequest) ProtoMessage()

func (*WatchFunctionsRequest) ProtoReflect added in v0.4.1 

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

func (*WatchFunctionsRequest) Reset added in v0.4.1 

func (x *WatchFunctionsRequest) Reset()

func (*WatchFunctionsRequest) String added in v0.4.1 

func (x *WatchFunctionsRequest) String() string

type WatchFunctionsResponse added in v0.4.1 

type WatchFunctionsResponse struct {
	Event    *string        `protobuf:"bytes,1,opt,name=event,proto3,oneof" json:"event,omitempty"`
	Function *FunctionsInfo `protobuf:"bytes,2,opt,name=function,proto3,oneof" json:"function,omitempty"`
	Traffic  []*Traffic     `protobuf:"bytes,3,rep,name=traffic,proto3" json:"traffic,omitempty"`
	// contains filtered or unexported fields
}

func (*WatchFunctionsResponse) Descriptor deprecated added in v0.4.1 

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

Deprecated: Use WatchFunctionsResponse.ProtoReflect.Descriptor instead.

func (*WatchFunctionsResponse) GetEvent added in v0.4.1 

func (x *WatchFunctionsResponse) GetEvent() string

func (*WatchFunctionsResponse) GetFunction added in v0.4.1 

func (x *WatchFunctionsResponse) GetFunction() *FunctionsInfo

func (*WatchFunctionsResponse) GetTraffic added in v0.4.1 

func (x *WatchFunctionsResponse) GetTraffic() []*Traffic

func (*WatchFunctionsResponse) ProtoMessage added in v0.4.1 

func (*WatchFunctionsResponse) ProtoMessage()

func (*WatchFunctionsResponse) ProtoReflect added in v0.4.1 

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

func (*WatchFunctionsResponse) Reset added in v0.4.1 

func (x *WatchFunctionsResponse) Reset()

func (*WatchFunctionsResponse) String added in v0.4.1 

func (x *WatchFunctionsResponse) String() string

type WatchLogsRequest added in v0.4.1 

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

func (*WatchLogsRequest) Descriptor deprecated added in v0.4.1 

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

Deprecated: Use WatchLogsRequest.ProtoReflect.Descriptor instead.

func (*WatchLogsRequest) GetPodName added in v0.4.1 

func (x *WatchLogsRequest) GetPodName() string

func (*WatchLogsRequest) ProtoMessage added in v0.4.1 

func (*WatchLogsRequest) ProtoMessage()

func (*WatchLogsRequest) ProtoReflect added in v0.4.1 

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

func (*WatchLogsRequest) Reset added in v0.4.1 

func (x *WatchLogsRequest) Reset()

func (*WatchLogsRequest) String added in v0.4.1 

func (x *WatchLogsRequest) String() string

type WatchLogsResponse added in v0.4.1 

type WatchLogsResponse struct {
	Data *string `protobuf:"bytes,1,opt,name=data,proto3,oneof" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*WatchLogsResponse) Descriptor deprecated added in v0.4.1 

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

Deprecated: Use WatchLogsResponse.ProtoReflect.Descriptor instead.

func (*WatchLogsResponse) GetData added in v0.4.1 

func (x *WatchLogsResponse) GetData() string

func (*WatchLogsResponse) ProtoMessage added in v0.4.1 

func (*WatchLogsResponse) ProtoMessage()

func (*WatchLogsResponse) ProtoReflect added in v0.4.1 

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

func (*WatchLogsResponse) Reset added in v0.4.1 

func (x *WatchLogsResponse) Reset()

func (*WatchLogsResponse) String added in v0.4.1 

func (x *WatchLogsResponse) String() string

type WatchPodsRequest added in v0.4.1 

type WatchPodsRequest struct {
	ServiceName  *string `protobuf:"bytes,1,opt,name=ServiceName,proto3,oneof" json:"ServiceName,omitempty"`
	RevisionName *string `protobuf:"bytes,2,opt,name=RevisionName,proto3,oneof" json:"RevisionName,omitempty"`
	// contains filtered or unexported fields
}

func (*WatchPodsRequest) Descriptor deprecated added in v0.4.1 

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

Deprecated: Use WatchPodsRequest.ProtoReflect.Descriptor instead.

func (*WatchPodsRequest) GetRevisionName added in v0.4.1 

func (x *WatchPodsRequest) GetRevisionName() string

func (*WatchPodsRequest) GetServiceName added in v0.4.1 

func (x *WatchPodsRequest) GetServiceName() string

func (*WatchPodsRequest) ProtoMessage added in v0.4.1 

func (*WatchPodsRequest) ProtoMessage()

func (*WatchPodsRequest) ProtoReflect added in v0.4.1 

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

func (*WatchPodsRequest) Reset added in v0.4.1 

func (x *WatchPodsRequest) Reset()

func (*WatchPodsRequest) String added in v0.4.1 

func (x *WatchPodsRequest) String() string

type WatchPodsResponse added in v0.4.1 

type WatchPodsResponse struct {
	Event *string   `protobuf:"bytes,1,opt,name=event,proto3,oneof" json:"event,omitempty"`
	Pod   *PodsInfo `protobuf:"bytes,2,opt,name=pod,proto3,oneof" json:"pod,omitempty"`
	// contains filtered or unexported fields
}

func (*WatchPodsResponse) Descriptor deprecated added in v0.4.1 

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

Deprecated: Use WatchPodsResponse.ProtoReflect.Descriptor instead.

func (*WatchPodsResponse) GetEvent added in v0.4.1 

func (x *WatchPodsResponse) GetEvent() string

func (*WatchPodsResponse) GetPod added in v0.4.1 

func (x *WatchPodsResponse) GetPod() *PodsInfo

func (*WatchPodsResponse) ProtoMessage added in v0.4.1 

func (*WatchPodsResponse) ProtoMessage()

func (*WatchPodsResponse) ProtoReflect added in v0.4.1 

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

func (*WatchPodsResponse) Reset added in v0.4.1 

func (x *WatchPodsResponse) Reset()

func (*WatchPodsResponse) String added in v0.4.1 

func (x *WatchPodsResponse) String() string

type WatchRevisionsRequest added in v0.4.1 

type WatchRevisionsRequest struct {
	ServiceName  *string `protobuf:"bytes,1,opt,name=ServiceName,proto3,oneof" json:"ServiceName,omitempty"`
	RevisionName *string `protobuf:"bytes,2,opt,name=RevisionName,proto3,oneof" json:"RevisionName,omitempty"`
	Scope        *string `protobuf:"bytes,6,opt,name=scope,proto3,oneof" json:"scope,omitempty"`
	// contains filtered or unexported fields
}

func (*WatchRevisionsRequest) Descriptor deprecated added in v0.4.1 

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

Deprecated: Use WatchRevisionsRequest.ProtoReflect.Descriptor instead.

func (*WatchRevisionsRequest) GetRevisionName added in v0.4.1 

func (x *WatchRevisionsRequest) GetRevisionName() string

func (*WatchRevisionsRequest) GetScope added in v0.5.0 

func (x *WatchRevisionsRequest) GetScope() string

func (*WatchRevisionsRequest) GetServiceName added in v0.4.1 

func (x *WatchRevisionsRequest) GetServiceName() string

func (*WatchRevisionsRequest) ProtoMessage added in v0.4.1 

func (*WatchRevisionsRequest) ProtoMessage()

func (*WatchRevisionsRequest) ProtoReflect added in v0.4.1 

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

func (*WatchRevisionsRequest) Reset added in v0.4.1 

func (x *WatchRevisionsRequest) Reset()

func (*WatchRevisionsRequest) String added in v0.4.1 

func (x *WatchRevisionsRequest) String() string

type WatchRevisionsResponse added in v0.4.1 

type WatchRevisionsResponse struct {
	Event     *string          `protobuf:"bytes,1,opt,name=event,proto3,oneof" json:"event,omitempty"`
	Name      *string          `protobuf:"bytes,2,opt,name=name,proto3,oneof" json:"name,omitempty"`
	Namespace *string          `protobuf:"bytes,3,opt,name=namespace,proto3,oneof" json:"namespace,omitempty"`
	Workflow  *string          `protobuf:"bytes,4,opt,name=workflow,proto3,oneof" json:"workflow,omitempty"`
	Config    *FunctionsConfig `protobuf:"bytes,5,opt,name=config,proto3,oneof" json:"config,omitempty"`
	Revision  *Revision        `protobuf:"bytes,6,opt,name=revision,proto3,oneof" json:"revision,omitempty"`
	// contains filtered or unexported fields
}

func (*WatchRevisionsResponse) Descriptor deprecated added in v0.4.1 

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

Deprecated: Use WatchRevisionsResponse.ProtoReflect.Descriptor instead.

func (*WatchRevisionsResponse) GetConfig added in v0.4.1 

func (x *WatchRevisionsResponse) GetConfig() *FunctionsConfig

func (*WatchRevisionsResponse) GetEvent added in v0.4.1 

func (x *WatchRevisionsResponse) GetEvent() string

func (*WatchRevisionsResponse) GetName added in v0.4.1 

func (x *WatchRevisionsResponse) GetName() string

func (*WatchRevisionsResponse) GetNamespace added in v0.4.1 

func (x *WatchRevisionsResponse) GetNamespace() string

func (*WatchRevisionsResponse) GetRevision added in v0.4.1 

func (x *WatchRevisionsResponse) GetRevision() *Revision

func (*WatchRevisionsResponse) GetWorkflow added in v0.4.1 

func (x *WatchRevisionsResponse) GetWorkflow() string

func (*WatchRevisionsResponse) ProtoMessage added in v0.4.1 

func (*WatchRevisionsResponse) ProtoMessage()

func (*WatchRevisionsResponse) ProtoReflect added in v0.4.1 

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

func (*WatchRevisionsResponse) Reset added in v0.4.1 

func (x *WatchRevisionsResponse) Reset()

func (*WatchRevisionsResponse) String added in v0.4.1 

func (x *WatchRevisionsResponse) 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.