grpc

package
Version: v0.5.6 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

View Source
var File_pkg_functions_grpc_build_proto protoreflect.FileDescriptor
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,
		},
		{
			MethodName: "Build",
			Handler:    _FunctionsService_Build_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 BuildResponse added in v0.5.6

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

func (*BuildResponse) Descriptor deprecated added in v0.5.6

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

Deprecated: Use BuildResponse.ProtoReflect.Descriptor instead.

func (*BuildResponse) GetBuild added in v0.5.6

func (x *BuildResponse) GetBuild() string

func (*BuildResponse) ProtoMessage added in v0.5.6

func (*BuildResponse) ProtoMessage()

func (*BuildResponse) ProtoReflect added in v0.5.6

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

func (*BuildResponse) Reset added in v0.5.6

func (x *BuildResponse) Reset()

func (*BuildResponse) String added in v0.5.6

func (x *BuildResponse) 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) (*empty.Empty, error)
	GetRegistries(ctx context.Context, in *GetRegistriesRequest, opts ...grpc.CallOption) (*GetRegistriesResponse, error)
	DeleteRegistry(ctx context.Context, in *DeleteRegistryRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	ReconstructFunction(ctx context.Context, in *ReconstructFunctionRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	UpdateFunction(ctx context.Context, in *UpdateFunctionRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	CreateFunction(ctx context.Context, in *CreateFunctionRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	DeleteFunctions(ctx context.Context, in *ListFunctionsRequest, opts ...grpc.CallOption) (*empty.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) (*empty.Empty, error)
	SetFunctionsTraffic(ctx context.Context, in *SetTrafficRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	CreateFunctionsPod(ctx context.Context, in *CreatePodRequest, opts ...grpc.CallOption) (*CreatePodResponse, error)
	CancelFunctionsPod(ctx context.Context, in *CancelPodRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	DeleteRevision(ctx context.Context, in *DeleteRevisionRequest, opts ...grpc.CallOption) (*empty.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)
	Build(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*BuildResponse, 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.

type FunctionsServiceServer

type FunctionsServiceServer interface {
	StoreRegistry(context.Context, *StoreRegistryRequest) (*empty.Empty, error)
	GetRegistries(context.Context, *GetRegistriesRequest) (*GetRegistriesResponse, error)
	DeleteRegistry(context.Context, *DeleteRegistryRequest) (*empty.Empty, error)
	ReconstructFunction(context.Context, *ReconstructFunctionRequest) (*empty.Empty, error)
	UpdateFunction(context.Context, *UpdateFunctionRequest) (*empty.Empty, error)
	CreateFunction(context.Context, *CreateFunctionRequest) (*empty.Empty, error)
	DeleteFunctions(context.Context, *ListFunctionsRequest) (*empty.Empty, error)
	ListFunctions(context.Context, *ListFunctionsRequest) (*ListFunctionsResponse, error)
	GetFunction(context.Context, *GetFunctionRequest) (*GetFunctionResponse, error)
	DeleteFunction(context.Context, *GetFunctionRequest) (*empty.Empty, error)
	SetFunctionsTraffic(context.Context, *SetTrafficRequest) (*empty.Empty, error)
	CreateFunctionsPod(context.Context, *CreatePodRequest) (*CreatePodResponse, error)
	CancelFunctionsPod(context.Context, *CancelPodRequest) (*empty.Empty, error)
	DeleteRevision(context.Context, *DeleteRevisionRequest) (*empty.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)
	Build(context.Context, *empty.Empty) (*BuildResponse, 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 (*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 (*GetRegistriesResponse_Registry) GetName

func (*GetRegistriesResponse_Registry) ProtoMessage

func (*GetRegistriesResponse_Registry) ProtoMessage()

func (*GetRegistriesResponse_Registry) ProtoReflect

func (*GetRegistriesResponse_Registry) Reset

func (x *GetRegistriesResponse_Registry) Reset()

func (*GetRegistriesResponse_Registry) 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 (*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) Build added in v0.5.6

func (UnimplementedFunctionsServiceServer) CancelFunctionsPod

func (UnimplementedFunctionsServiceServer) CreateFunction

func (UnimplementedFunctionsServiceServer) CreateFunctionsPod

func (UnimplementedFunctionsServiceServer) DeleteFunction

func (UnimplementedFunctionsServiceServer) DeleteFunctions

func (UnimplementedFunctionsServiceServer) DeleteRegistry

func (UnimplementedFunctionsServiceServer) DeleteRevision

func (UnimplementedFunctionsServiceServer) GetFunction

func (UnimplementedFunctionsServiceServer) GetRegistries

func (UnimplementedFunctionsServiceServer) ListFunctions

func (UnimplementedFunctionsServiceServer) ListPods added in v0.4.1

func (UnimplementedFunctionsServiceServer) ReconstructFunction added in v0.5.0

func (UnimplementedFunctionsServiceServer) SetFunctionsTraffic

func (UnimplementedFunctionsServiceServer) StoreRegistry

func (UnimplementedFunctionsServiceServer) UpdateFunction

func (UnimplementedFunctionsServiceServer) WatchFunctions added in v0.4.1

func (UnimplementedFunctionsServiceServer) WatchLogs added in v0.4.1

func (UnimplementedFunctionsServiceServer) WatchPods added in v0.4.1

func (UnimplementedFunctionsServiceServer) WatchRevisions added in v0.4.1

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL