v1alpha1

package
v0.3.0-alpha.7 Latest Latest
Warning

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

 Go to latest Published: Feb 15, 2023 License: MPL-2.0 Imports: 18 Imported by: 7

Documentation

Overview

Package v1alpha1 is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package v1alpha1 is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var (
	ResourceDefinitionSpec_Sensitivity_name = map[int32]string{
		0: "NON_SENSITIVE",
		1: "SENSITIVE",
	}
	ResourceDefinitionSpec_Sensitivity_value = map[string]int32{
		"NON_SENSITIVE": 0,
		"SENSITIVE":     1,
	}
)

Enum value maps for ResourceDefinitionSpec_Sensitivity.

View Source 
var (
	LabelTerm_Operation_name = map[int32]string{
		0: "EXISTS",
		1: "EQUAL",
		2: "NOT_EXISTS",
	}
	LabelTerm_Operation_value = map[string]int32{
		"EXISTS":     0,
		"EQUAL":      1,
		"NOT_EXISTS": 2,
	}
)

Enum value maps for LabelTerm_Operation.

View Source 
var (
	ErrInvalidLength        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflow          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroup = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ControllerInputKind_name = map[int32]string{
		0: "WEAK",
		1: "STRONG",
		2: "DESTROY_READY",
	}
	ControllerInputKind_value = map[string]int32{
		"WEAK":          0,
		"STRONG":        1,
		"DESTROY_READY": 2,
	}
)

Enum value maps for ControllerInputKind.

View Source 
var (
	ControllerOutputKind_name = map[int32]string{
		0: "EXCLUSIVE",
		1: "SHARED",
	}
	ControllerOutputKind_value = map[string]int32{
		"EXCLUSIVE": 0,
		"SHARED":    1,
	}
)

Enum value maps for ControllerOutputKind.

View Source 
var (
	EventType_name = map[int32]string{
		0: "CREATED",
		1: "UPDATED",
		2: "DESTROYED",
		3: "BOOTSTRAPPED",
		4: "ERRORED",
	}
	EventType_value = map[string]int32{
		"CREATED":      0,
		"UPDATED":      1,
		"DESTROYED":    2,
		"BOOTSTRAPPED": 3,
		"ERRORED":      4,
	}
)

Enum value maps for EventType.

View Source 
var ControllerAdapter_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "cosi.runtime.ControllerAdapter",
	HandlerType: (*ControllerAdapterServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "QueueReconcile",
			Handler:    _ControllerAdapter_QueueReconcile_Handler,
		},
		{
			MethodName: "UpdateInputs",
			Handler:    _ControllerAdapter_UpdateInputs_Handler,
		},
		{
			MethodName: "Get",
			Handler:    _ControllerAdapter_Get_Handler,
		},
		{
			MethodName: "WatchFor",
			Handler:    _ControllerAdapter_WatchFor_Handler,
		},
		{
			MethodName: "Create",
			Handler:    _ControllerAdapter_Create_Handler,
		},
		{
			MethodName: "Update",
			Handler:    _ControllerAdapter_Update_Handler,
		},
		{
			MethodName: "Teardown",
			Handler:    _ControllerAdapter_Teardown_Handler,
		},
		{
			MethodName: "Destroy",
			Handler:    _ControllerAdapter_Destroy_Handler,
		},
		{
			MethodName: "AddFinalizer",
			Handler:    _ControllerAdapter_AddFinalizer_Handler,
		},
		{
			MethodName: "RemoveFinalizer",
			Handler:    _ControllerAdapter_RemoveFinalizer_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "ReconcileEvents",
			Handler:       _ControllerAdapter_ReconcileEvents_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "List",
			Handler:       _ControllerAdapter_List_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "v1alpha1/runtime.proto",
}

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

View Source 
var ControllerRuntime_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "cosi.runtime.ControllerRuntime",
	HandlerType: (*ControllerRuntimeServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "RegisterController",
			Handler:    _ControllerRuntime_RegisterController_Handler,
		},
		{
			MethodName: "Start",
			Handler:    _ControllerRuntime_Start_Handler,
		},
		{
			MethodName: "Stop",
			Handler:    _ControllerRuntime_Stop_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "v1alpha1/runtime.proto",
}

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

View Source 
var File_v1alpha1_meta_proto protoreflect.FileDescriptor
View Source 
var File_v1alpha1_resource_proto protoreflect.FileDescriptor
View Source 
var File_v1alpha1_runtime_proto protoreflect.FileDescriptor
View Source 
var File_v1alpha1_state_proto protoreflect.FileDescriptor
View Source 
var State_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "cosi.resource.State",
	HandlerType: (*StateServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Get",
			Handler:    _State_Get_Handler,
		},
		{
			MethodName: "Create",
			Handler:    _State_Create_Handler,
		},
		{
			MethodName: "Update",
			Handler:    _State_Update_Handler,
		},
		{
			MethodName: "Destroy",
			Handler:    _State_Destroy_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "List",
			Handler:       _State_List_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "Watch",
			Handler:       _State_Watch_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "v1alpha1/state.proto",
}

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

Functions

func RegisterControllerAdapterHandler 

func RegisterControllerAdapterHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterControllerAdapterHandler registers the http handlers for service ControllerAdapter to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterControllerAdapterHandlerClient 

func RegisterControllerAdapterHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ControllerAdapterClient) error

RegisterControllerAdapterHandlerClient registers the http handlers for service ControllerAdapter to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "ControllerAdapterClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "ControllerAdapterClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "ControllerAdapterClient" to call the correct interceptors.

func RegisterControllerAdapterHandlerFromEndpoint 

func RegisterControllerAdapterHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterControllerAdapterHandlerFromEndpoint is same as RegisterControllerAdapterHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterControllerAdapterHandlerServer 

func RegisterControllerAdapterHandlerServer(ctx context.Context, mux *runtime.ServeMux, server ControllerAdapterServer) error

RegisterControllerAdapterHandlerServer registers the http handlers for service ControllerAdapter to "mux". UnaryRPC :call ControllerAdapterServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterControllerAdapterHandlerFromEndpoint instead.

func RegisterControllerAdapterServer 

func RegisterControllerAdapterServer(s grpc.ServiceRegistrar, srv ControllerAdapterServer)

func RegisterControllerRuntimeHandler 

func RegisterControllerRuntimeHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterControllerRuntimeHandler registers the http handlers for service ControllerRuntime to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterControllerRuntimeHandlerClient 

func RegisterControllerRuntimeHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ControllerRuntimeClient) error

RegisterControllerRuntimeHandlerClient registers the http handlers for service ControllerRuntime to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "ControllerRuntimeClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "ControllerRuntimeClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "ControllerRuntimeClient" to call the correct interceptors.

func RegisterControllerRuntimeHandlerFromEndpoint 

func RegisterControllerRuntimeHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterControllerRuntimeHandlerFromEndpoint is same as RegisterControllerRuntimeHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterControllerRuntimeHandlerServer 

func RegisterControllerRuntimeHandlerServer(ctx context.Context, mux *runtime.ServeMux, server ControllerRuntimeServer) error

RegisterControllerRuntimeHandlerServer registers the http handlers for service ControllerRuntime to "mux". UnaryRPC :call ControllerRuntimeServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterControllerRuntimeHandlerFromEndpoint instead.

func RegisterControllerRuntimeServer 

func RegisterControllerRuntimeServer(s grpc.ServiceRegistrar, srv ControllerRuntimeServer)

func RegisterStateHandler 

func RegisterStateHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterStateHandler registers the http handlers for service State to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterStateHandlerClient 

func RegisterStateHandlerClient(ctx context.Context, mux *runtime.ServeMux, client StateClient) error

RegisterStateHandlerClient registers the http handlers for service State to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "StateClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "StateClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "StateClient" to call the correct interceptors.

func RegisterStateHandlerFromEndpoint 

func RegisterStateHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterStateHandlerFromEndpoint is same as RegisterStateHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterStateHandlerServer 

func RegisterStateHandlerServer(ctx context.Context, mux *runtime.ServeMux, server StateServer) error

RegisterStateHandlerServer registers the http handlers for service State to "mux". UnaryRPC :call StateServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterStateHandlerFromEndpoint instead.

func RegisterStateServer 

func RegisterStateServer(s grpc.ServiceRegistrar, srv StateServer)

Types

type ConditionFinalizersEmpty 

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

func (*ConditionFinalizersEmpty) Descriptor deprecated 

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

Deprecated: Use ConditionFinalizersEmpty.ProtoReflect.Descriptor instead.

func (*ConditionFinalizersEmpty) EqualMessageVT added in v0.3.0 

func (this *ConditionFinalizersEmpty) EqualMessageVT(thatMsg proto.Message) bool

func (*ConditionFinalizersEmpty) EqualVT added in v0.3.0 

func (this *ConditionFinalizersEmpty) EqualVT(that *ConditionFinalizersEmpty) bool

func (*ConditionFinalizersEmpty) MarshalToSizedBufferVT 

func (m *ConditionFinalizersEmpty) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ConditionFinalizersEmpty) MarshalToVT 

func (m *ConditionFinalizersEmpty) MarshalToVT(dAtA []byte) (int, error)

func (*ConditionFinalizersEmpty) MarshalVT 

func (m *ConditionFinalizersEmpty) MarshalVT() (dAtA []byte, err error)

func (*ConditionFinalizersEmpty) ProtoMessage 

func (*ConditionFinalizersEmpty) ProtoMessage()

func (*ConditionFinalizersEmpty) ProtoReflect 

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

func (*ConditionFinalizersEmpty) Reset 

func (x *ConditionFinalizersEmpty) Reset()

func (*ConditionFinalizersEmpty) SizeVT 

func (m *ConditionFinalizersEmpty) SizeVT() (n int)

func (*ConditionFinalizersEmpty) String 

func (x *ConditionFinalizersEmpty) String() string

func (*ConditionFinalizersEmpty) UnmarshalVT 

func (m *ConditionFinalizersEmpty) UnmarshalVT(dAtA []byte) error

type ControllerAdapterClient 

type ControllerAdapterClient interface {
	// ReconcileEvents sends a message on each reconcile event to the controller.
	//
	// Controller is supposed to called 'ReconcileEvents' on start and run reconcile loop
	// each time there is an event received.
	ReconcileEvents(ctx context.Context, in *ReconcileEventsRequest, opts ...grpc.CallOption) (ControllerAdapter_ReconcileEventsClient, error)
	QueueReconcile(ctx context.Context, in *QueueReconcileRequest, opts ...grpc.CallOption) (*QueueReconcileResponse, error)
	// UpdateInputs updates the list of controller inputs.
	//
	// This call replaces the list of inputs with the new list.
	// For any new inputs a separate watch is established and reconcile
	// events are sent for new inputs.
	UpdateInputs(ctx context.Context, in *UpdateInputsRequest, opts ...grpc.CallOption) (*UpdateInputsResponse, error)
	// Get a resource.
	//
	// Resource should be either input or ouput of the controller.
	Get(ctx context.Context, in *RuntimeGetRequest, opts ...grpc.CallOption) (*RuntimeGetResponse, error)
	// List resources.
	//
	// Resource should be either input or ouput of the controller.
	List(ctx context.Context, in *RuntimeListRequest, opts ...grpc.CallOption) (ControllerAdapter_ListClient, error)
	// WatchFor a specific resource state.
	//
	// Resource should be either input or ouput of the controller.
	WatchFor(ctx context.Context, in *RuntimeWatchForRequest, opts ...grpc.CallOption) (*RuntimeWatchForResponse, error)
	// Create a new resource.
	//
	// Resource should be an output of the controller.
	Create(ctx context.Context, in *RuntimeCreateRequest, opts ...grpc.CallOption) (*RuntimeCreateResponse, error)
	// Update a resource.
	//
	// Up-to-date current version should be specified for the update to succeed.
	//
	// Resource should be an output of the controller, for shared outputs
	// resource should be owned by the controller.
	Update(ctx context.Context, in *RuntimeUpdateRequest, opts ...grpc.CallOption) (*RuntimeUpdateResponse, error)
	// Teardown marks a resource as going through the teardown phase.
	//
	// Teardown phase notifies other controllers using the resource as a strong input
	// that the resource is going away, and once cleanup is done, finalizer should be removed
	// which unblocks resource destruction.
	//
	// Resource should be an output of the controller, for shared outputs
	// resource should be owned by the controller.
	Teardown(ctx context.Context, in *RuntimeTeardownRequest, opts ...grpc.CallOption) (*RuntimeTeardownResponse, error)
	// Destroy a resource.
	//
	// Resource should have no finalizers to be destroyed.
	//
	// Resource should be an output of the controller, for shared outputs
	// resource should be owned by the controller.
	Destroy(ctx context.Context, in *RuntimeDestroyRequest, opts ...grpc.CallOption) (*RuntimeDestroyResponse, error)
	// AddFinalizer adds a finalizer on the resource.
	//
	// Resource should be a strong input of the controller.
	AddFinalizer(ctx context.Context, in *RuntimeAddFinalizerRequest, opts ...grpc.CallOption) (*RuntimeAddFinalizerResponse, error)
	// RemoveFinalizer remove a finalizer from the resource.
	//
	// Resource should be a strong input of the controller.
	RemoveFinalizer(ctx context.Context, in *RuntimeRemoveFinalizerRequest, opts ...grpc.CallOption) (*RuntimeRemoveFinalizerResponse, error)
}

ControllerAdapterClient is the client API for ControllerAdapter 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 NewControllerAdapterClient 

func NewControllerAdapterClient(cc grpc.ClientConnInterface) ControllerAdapterClient

type ControllerAdapterServer 

type ControllerAdapterServer interface {
	// ReconcileEvents sends a message on each reconcile event to the controller.
	//
	// Controller is supposed to called 'ReconcileEvents' on start and run reconcile loop
	// each time there is an event received.
	ReconcileEvents(*ReconcileEventsRequest, ControllerAdapter_ReconcileEventsServer) error
	QueueReconcile(context.Context, *QueueReconcileRequest) (*QueueReconcileResponse, error)
	// UpdateInputs updates the list of controller inputs.
	//
	// This call replaces the list of inputs with the new list.
	// For any new inputs a separate watch is established and reconcile
	// events are sent for new inputs.
	UpdateInputs(context.Context, *UpdateInputsRequest) (*UpdateInputsResponse, error)
	// Get a resource.
	//
	// Resource should be either input or ouput of the controller.
	Get(context.Context, *RuntimeGetRequest) (*RuntimeGetResponse, error)
	// List resources.
	//
	// Resource should be either input or ouput of the controller.
	List(*RuntimeListRequest, ControllerAdapter_ListServer) error
	// WatchFor a specific resource state.
	//
	// Resource should be either input or ouput of the controller.
	WatchFor(context.Context, *RuntimeWatchForRequest) (*RuntimeWatchForResponse, error)
	// Create a new resource.
	//
	// Resource should be an output of the controller.
	Create(context.Context, *RuntimeCreateRequest) (*RuntimeCreateResponse, error)
	// Update a resource.
	//
	// Up-to-date current version should be specified for the update to succeed.
	//
	// Resource should be an output of the controller, for shared outputs
	// resource should be owned by the controller.
	Update(context.Context, *RuntimeUpdateRequest) (*RuntimeUpdateResponse, error)
	// Teardown marks a resource as going through the teardown phase.
	//
	// Teardown phase notifies other controllers using the resource as a strong input
	// that the resource is going away, and once cleanup is done, finalizer should be removed
	// which unblocks resource destruction.
	//
	// Resource should be an output of the controller, for shared outputs
	// resource should be owned by the controller.
	Teardown(context.Context, *RuntimeTeardownRequest) (*RuntimeTeardownResponse, error)
	// Destroy a resource.
	//
	// Resource should have no finalizers to be destroyed.
	//
	// Resource should be an output of the controller, for shared outputs
	// resource should be owned by the controller.
	Destroy(context.Context, *RuntimeDestroyRequest) (*RuntimeDestroyResponse, error)
	// AddFinalizer adds a finalizer on the resource.
	//
	// Resource should be a strong input of the controller.
	AddFinalizer(context.Context, *RuntimeAddFinalizerRequest) (*RuntimeAddFinalizerResponse, error)
	// RemoveFinalizer remove a finalizer from the resource.
	//
	// Resource should be a strong input of the controller.
	RemoveFinalizer(context.Context, *RuntimeRemoveFinalizerRequest) (*RuntimeRemoveFinalizerResponse, error)
	// contains filtered or unexported methods
}

ControllerAdapterServer is the server API for ControllerAdapter service. All implementations must embed UnimplementedControllerAdapterServer for forward compatibility

type ControllerAdapter_ListClient 

type ControllerAdapter_ListClient interface {
	Recv() (*RuntimeListResponse, error)
	grpc.ClientStream
}

type ControllerAdapter_ListServer 

type ControllerAdapter_ListServer interface {
	Send(*RuntimeListResponse) error
	grpc.ServerStream
}

type ControllerAdapter_ReconcileEventsClient 

type ControllerAdapter_ReconcileEventsClient interface {
	Recv() (*ReconcileEventsResponse, error)
	grpc.ClientStream
}

type ControllerAdapter_ReconcileEventsServer 

type ControllerAdapter_ReconcileEventsServer interface {
	Send(*ReconcileEventsResponse) error
	grpc.ServerStream
}

type ControllerInput 

type ControllerInput struct {
	Kind      ControllerInputKind `protobuf:"varint,1,opt,name=kind,proto3,enum=cosi.runtime.ControllerInputKind" json:"kind,omitempty"`
	Namespace string              `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Type      string              `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
	Id        *string             `protobuf:"bytes,4,opt,name=id,proto3,oneof" json:"id,omitempty"`
	// contains filtered or unexported fields
}

ControllerInput describes resources which controller depends on.

Controller is notified about each input resource change. Controller can either depend on a specific resource instance (by id) or it might watch all the resources under a namespace. Controller input might not exist yet when the input is registered.

Controller has read-only access to its inputs.

func (*ControllerInput) Descriptor deprecated 

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

Deprecated: Use ControllerInput.ProtoReflect.Descriptor instead.

func (*ControllerInput) EqualMessageVT added in v0.3.0 

func (this *ControllerInput) EqualMessageVT(thatMsg proto.Message) bool

func (*ControllerInput) EqualVT added in v0.3.0 

func (this *ControllerInput) EqualVT(that *ControllerInput) bool

func (*ControllerInput) GetId 

func (x *ControllerInput) GetId() string

func (*ControllerInput) GetKind 

func (x *ControllerInput) GetKind() ControllerInputKind

func (*ControllerInput) GetNamespace 

func (x *ControllerInput) GetNamespace() string

func (*ControllerInput) GetType 

func (x *ControllerInput) GetType() string

func (*ControllerInput) MarshalToSizedBufferVT 

func (m *ControllerInput) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ControllerInput) MarshalToVT 

func (m *ControllerInput) MarshalToVT(dAtA []byte) (int, error)

func (*ControllerInput) MarshalVT 

func (m *ControllerInput) MarshalVT() (dAtA []byte, err error)

func (*ControllerInput) ProtoMessage 

func (*ControllerInput) ProtoMessage()

func (*ControllerInput) ProtoReflect 

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

func (*ControllerInput) Reset 

func (x *ControllerInput) Reset()

func (*ControllerInput) SizeVT 

func (m *ControllerInput) SizeVT() (n int)

func (*ControllerInput) String 

func (x *ControllerInput) String() string

func (*ControllerInput) UnmarshalVT 

func (m *ControllerInput) UnmarshalVT(dAtA []byte) error

type ControllerInputKind 

type ControllerInputKind int32
const (
	// Controllers are notified on changes to weak inputs.
	//
	// Weak inputs can't have finalizers set on.
	// Controller watches weak inputs, but it doesn't depend in a strong way on a resource,
	// so that resource can be deleted without any cleanup required on the controller side.
	ControllerInputKind_WEAK ControllerInputKind = 0
	// Strong inputs build upon weak inputs, the difference is that controller signals
	// that it should be notified (via teardown) that resource is going to be deleted.
	//
	// Controller can add finalizers on strong inputs.
	ControllerInputKind_STRONG ControllerInputKind = 1
	// DestroyReady inputs provide notifications to the controllers when some resource
	// is ready to be destroyed (all finalizers are removed).
	//
	// Usually outputs are declared as DestroyReady inputs to trigger reconcile loop
	// when the resource is ready to be destroyed.
	//
	// Controller will be notified when the resource enters "teardown" phase and has no
	// finalizers attached.
	// Resources are filtered to be owned by the controller.
	ControllerInputKind_DESTROY_READY ControllerInputKind = 2
)

func (ControllerInputKind) Descriptor 

func (ControllerInputKind) Descriptor() protoreflect.EnumDescriptor

func (ControllerInputKind) Enum 

func (x ControllerInputKind) Enum() *ControllerInputKind

func (ControllerInputKind) EnumDescriptor deprecated 

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

Deprecated: Use ControllerInputKind.Descriptor instead.

func (ControllerInputKind) Number 

func (x ControllerInputKind) Number() protoreflect.EnumNumber

func (ControllerInputKind) String 

func (x ControllerInputKind) String() string

func (ControllerInputKind) Type 

func (ControllerInputKind) Type() protoreflect.EnumType

type ControllerOutput 

type ControllerOutput struct {
	Type string               `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	Kind ControllerOutputKind `protobuf:"varint,3,opt,name=kind,proto3,enum=cosi.runtime.ControllerOutputKind" json:"kind,omitempty"`
	// contains filtered or unexported fields
}

ControllerOutput describes resources which controller can modify (created, update and destroy).

Output is defined by a resource type, so controller claims ownerships of the resource type across all namespaces.

func (*ControllerOutput) Descriptor deprecated 

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

Deprecated: Use ControllerOutput.ProtoReflect.Descriptor instead.

func (*ControllerOutput) EqualMessageVT added in v0.3.0 

func (this *ControllerOutput) EqualMessageVT(thatMsg proto.Message) bool

func (*ControllerOutput) EqualVT added in v0.3.0 

func (this *ControllerOutput) EqualVT(that *ControllerOutput) bool

func (*ControllerOutput) GetKind 

func (x *ControllerOutput) GetKind() ControllerOutputKind

func (*ControllerOutput) GetType 

func (x *ControllerOutput) GetType() string

func (*ControllerOutput) MarshalToSizedBufferVT 

func (m *ControllerOutput) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ControllerOutput) MarshalToVT 

func (m *ControllerOutput) MarshalToVT(dAtA []byte) (int, error)

func (*ControllerOutput) MarshalVT 

func (m *ControllerOutput) MarshalVT() (dAtA []byte, err error)

func (*ControllerOutput) ProtoMessage 

func (*ControllerOutput) ProtoMessage()

func (*ControllerOutput) ProtoReflect 

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

func (*ControllerOutput) Reset 

func (x *ControllerOutput) Reset()

func (*ControllerOutput) SizeVT 

func (m *ControllerOutput) SizeVT() (n int)

func (*ControllerOutput) String 

func (x *ControllerOutput) String() string

func (*ControllerOutput) UnmarshalVT 

func (m *ControllerOutput) UnmarshalVT(dAtA []byte) error

type ControllerOutputKind 

type ControllerOutputKind int32
const (
	// Exclusive output implies that the resource type is owned by a single controller.
	//
	// No other controller can register same resource type as either exclusive or shared output,
	// so any resource of the type is only modified by a single controller.
	ControllerOutputKind_EXCLUSIVE ControllerOutputKind = 0
	// Shared output means that controller only owns instances of the resource type which were created
	// by the controller.
	//
	// Many controllers can register same resource type as a shared output. Each controller owns
	// only the resources which were created by the controller.
	ControllerOutputKind_SHARED ControllerOutputKind = 1
)

func (ControllerOutputKind) Descriptor 

func (ControllerOutputKind) Descriptor() protoreflect.EnumDescriptor

func (ControllerOutputKind) Enum 

func (x ControllerOutputKind) Enum() *ControllerOutputKind

func (ControllerOutputKind) EnumDescriptor deprecated 

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

Deprecated: Use ControllerOutputKind.Descriptor instead.

func (ControllerOutputKind) Number 

func (x ControllerOutputKind) Number() protoreflect.EnumNumber

func (ControllerOutputKind) String 

func (x ControllerOutputKind) String() string

func (ControllerOutputKind) Type 

func (ControllerOutputKind) Type() protoreflect.EnumType

type ControllerRuntimeClient 

type ControllerRuntimeClient interface {
	// RegisterController registers the controller and establishes a token for ControllerAdapter calls.
	//
	// RegisterController builds initial set of inputs and outputs for the controller.
	// If there's a conflict on inputs or outputs, RegisterController fails.
	// RegisterController enforces unique controller names.
	RegisterController(ctx context.Context, in *RegisterControllerRequest, opts ...grpc.CallOption) (*RegisterControllerResponse, error)
	// Start the controller runtime.
	//
	// Start should only be called once.
	// Once the runtime is started, controllers start receiving reconcile events via
	// the ControllerAdapter APIs.
	Start(ctx context.Context, in *StartRequest, opts ...grpc.CallOption) (*StartResponse, error)
	// Stop the controller runtime.
	//
	// Stop should only be called once.
	Stop(ctx context.Context, in *StopRequest, opts ...grpc.CallOption) (*StopResponse, error)
}

ControllerRuntimeClient is the client API for ControllerRuntime 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 NewControllerRuntimeClient 

func NewControllerRuntimeClient(cc grpc.ClientConnInterface) ControllerRuntimeClient

type ControllerRuntimeServer 

type ControllerRuntimeServer interface {
	// RegisterController registers the controller and establishes a token for ControllerAdapter calls.
	//
	// RegisterController builds initial set of inputs and outputs for the controller.
	// If there's a conflict on inputs or outputs, RegisterController fails.
	// RegisterController enforces unique controller names.
	RegisterController(context.Context, *RegisterControllerRequest) (*RegisterControllerResponse, error)
	// Start the controller runtime.
	//
	// Start should only be called once.
	// Once the runtime is started, controllers start receiving reconcile events via
	// the ControllerAdapter APIs.
	Start(context.Context, *StartRequest) (*StartResponse, error)
	// Stop the controller runtime.
	//
	// Stop should only be called once.
	Stop(context.Context, *StopRequest) (*StopResponse, error)
	// contains filtered or unexported methods
}

ControllerRuntimeServer is the server API for ControllerRuntime service. All implementations must embed UnimplementedControllerRuntimeServer for forward compatibility

type CreateOptions 

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

func (*CreateOptions) Descriptor deprecated 

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

Deprecated: Use CreateOptions.ProtoReflect.Descriptor instead.

func (*CreateOptions) EqualMessageVT added in v0.3.0 

func (this *CreateOptions) EqualMessageVT(thatMsg proto.Message) bool

func (*CreateOptions) EqualVT added in v0.3.0 

func (this *CreateOptions) EqualVT(that *CreateOptions) bool

func (*CreateOptions) GetOwner 

func (x *CreateOptions) GetOwner() string

func (*CreateOptions) MarshalToSizedBufferVT 

func (m *CreateOptions) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*CreateOptions) MarshalToVT 

func (m *CreateOptions) MarshalToVT(dAtA []byte) (int, error)

func (*CreateOptions) MarshalVT 

func (m *CreateOptions) MarshalVT() (dAtA []byte, err error)

func (*CreateOptions) ProtoMessage 

func (*CreateOptions) ProtoMessage()

func (*CreateOptions) ProtoReflect 

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

func (*CreateOptions) Reset 

func (x *CreateOptions) Reset()

func (*CreateOptions) SizeVT 

func (m *CreateOptions) SizeVT() (n int)

func (*CreateOptions) String 

func (x *CreateOptions) String() string

func (*CreateOptions) UnmarshalVT 

func (m *CreateOptions) UnmarshalVT(dAtA []byte) error

type CreateRequest 

type CreateRequest struct {
	Resource *Resource      `protobuf:"bytes,1,opt,name=resource,proto3" json:"resource,omitempty"`
	Options  *CreateOptions `protobuf:"bytes,2,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateRequest) Descriptor deprecated 

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

Deprecated: Use CreateRequest.ProtoReflect.Descriptor instead.

func (*CreateRequest) EqualMessageVT added in v0.3.0 

func (this *CreateRequest) EqualMessageVT(thatMsg proto.Message) bool

func (*CreateRequest) EqualVT added in v0.3.0 

func (this *CreateRequest) EqualVT(that *CreateRequest) bool

func (*CreateRequest) GetOptions 

func (x *CreateRequest) GetOptions() *CreateOptions

func (*CreateRequest) GetResource 

func (x *CreateRequest) GetResource() *Resource

func (*CreateRequest) MarshalToSizedBufferVT 

func (m *CreateRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*CreateRequest) MarshalToVT 

func (m *CreateRequest) MarshalToVT(dAtA []byte) (int, error)

func (*CreateRequest) MarshalVT 

func (m *CreateRequest) MarshalVT() (dAtA []byte, err error)

func (*CreateRequest) ProtoMessage 

func (*CreateRequest) ProtoMessage()

func (*CreateRequest) ProtoReflect 

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

func (*CreateRequest) Reset 

func (x *CreateRequest) Reset()

func (*CreateRequest) SizeVT 

func (m *CreateRequest) SizeVT() (n int)

func (*CreateRequest) String 

func (x *CreateRequest) String() string

func (*CreateRequest) UnmarshalVT 

func (m *CreateRequest) UnmarshalVT(dAtA []byte) error

type CreateResponse 

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

func (*CreateResponse) Descriptor deprecated 

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

Deprecated: Use CreateResponse.ProtoReflect.Descriptor instead.

func (*CreateResponse) EqualMessageVT added in v0.3.0 

func (this *CreateResponse) EqualMessageVT(thatMsg proto.Message) bool

func (*CreateResponse) EqualVT added in v0.3.0 

func (this *CreateResponse) EqualVT(that *CreateResponse) bool

func (*CreateResponse) GetResource added in v0.2.0 

func (x *CreateResponse) GetResource() *Resource

func (*CreateResponse) MarshalToSizedBufferVT 

func (m *CreateResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*CreateResponse) MarshalToVT 

func (m *CreateResponse) MarshalToVT(dAtA []byte) (int, error)

func (*CreateResponse) MarshalVT 

func (m *CreateResponse) MarshalVT() (dAtA []byte, err error)

func (*CreateResponse) ProtoMessage 

func (*CreateResponse) ProtoMessage()

func (*CreateResponse) ProtoReflect 

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

func (*CreateResponse) Reset 

func (x *CreateResponse) Reset()

func (*CreateResponse) SizeVT 

func (m *CreateResponse) SizeVT() (n int)

func (*CreateResponse) String 

func (x *CreateResponse) String() string

func (*CreateResponse) UnmarshalVT 

func (m *CreateResponse) UnmarshalVT(dAtA []byte) error

type DestroyOptions 

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

func (*DestroyOptions) Descriptor deprecated 

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

Deprecated: Use DestroyOptions.ProtoReflect.Descriptor instead.

func (*DestroyOptions) EqualMessageVT added in v0.3.0 

func (this *DestroyOptions) EqualMessageVT(thatMsg proto.Message) bool

func (*DestroyOptions) EqualVT added in v0.3.0 

func (this *DestroyOptions) EqualVT(that *DestroyOptions) bool

func (*DestroyOptions) GetOwner 

func (x *DestroyOptions) GetOwner() string

func (*DestroyOptions) MarshalToSizedBufferVT 

func (m *DestroyOptions) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*DestroyOptions) MarshalToVT 

func (m *DestroyOptions) MarshalToVT(dAtA []byte) (int, error)

func (*DestroyOptions) MarshalVT 

func (m *DestroyOptions) MarshalVT() (dAtA []byte, err error)

func (*DestroyOptions) ProtoMessage 

func (*DestroyOptions) ProtoMessage()

func (*DestroyOptions) ProtoReflect 

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

func (*DestroyOptions) Reset 

func (x *DestroyOptions) Reset()

func (*DestroyOptions) SizeVT 

func (m *DestroyOptions) SizeVT() (n int)

func (*DestroyOptions) String 

func (x *DestroyOptions) String() string

func (*DestroyOptions) UnmarshalVT 

func (m *DestroyOptions) UnmarshalVT(dAtA []byte) error

type DestroyRequest 

type DestroyRequest struct {
	Namespace string          `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Type      string          `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	Id        string          `protobuf:"bytes,3,opt,name=id,proto3" json:"id,omitempty"`
	Options   *DestroyOptions `protobuf:"bytes,4,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*DestroyRequest) Descriptor deprecated 

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

Deprecated: Use DestroyRequest.ProtoReflect.Descriptor instead.

func (*DestroyRequest) EqualMessageVT added in v0.3.0 

func (this *DestroyRequest) EqualMessageVT(thatMsg proto.Message) bool

func (*DestroyRequest) EqualVT added in v0.3.0 

func (this *DestroyRequest) EqualVT(that *DestroyRequest) bool

func (*DestroyRequest) GetId 

func (x *DestroyRequest) GetId() string

func (*DestroyRequest) GetNamespace 

func (x *DestroyRequest) GetNamespace() string

func (*DestroyRequest) GetOptions 

func (x *DestroyRequest) GetOptions() *DestroyOptions

func (*DestroyRequest) GetType 

func (x *DestroyRequest) GetType() string

func (*DestroyRequest) MarshalToSizedBufferVT 

func (m *DestroyRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*DestroyRequest) MarshalToVT 

func (m *DestroyRequest) MarshalToVT(dAtA []byte) (int, error)

func (*DestroyRequest) MarshalVT 

func (m *DestroyRequest) MarshalVT() (dAtA []byte, err error)

func (*DestroyRequest) ProtoMessage 

func (*DestroyRequest) ProtoMessage()

func (*DestroyRequest) ProtoReflect 

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

func (*DestroyRequest) Reset 

func (x *DestroyRequest) Reset()

func (*DestroyRequest) SizeVT 

func (m *DestroyRequest) SizeVT() (n int)

func (*DestroyRequest) String 

func (x *DestroyRequest) String() string

func (*DestroyRequest) UnmarshalVT 

func (m *DestroyRequest) UnmarshalVT(dAtA []byte) error

type DestroyResponse 

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

func (*DestroyResponse) Descriptor deprecated 

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

Deprecated: Use DestroyResponse.ProtoReflect.Descriptor instead.

func (*DestroyResponse) EqualMessageVT added in v0.3.0 

func (this *DestroyResponse) EqualMessageVT(thatMsg proto.Message) bool

func (*DestroyResponse) EqualVT added in v0.3.0 

func (this *DestroyResponse) EqualVT(that *DestroyResponse) bool

func (*DestroyResponse) MarshalToSizedBufferVT 

func (m *DestroyResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*DestroyResponse) MarshalToVT 

func (m *DestroyResponse) MarshalToVT(dAtA []byte) (int, error)

func (*DestroyResponse) MarshalVT 

func (m *DestroyResponse) MarshalVT() (dAtA []byte, err error)

func (*DestroyResponse) ProtoMessage 

func (*DestroyResponse) ProtoMessage()

func (*DestroyResponse) ProtoReflect 

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

func (*DestroyResponse) Reset 

func (x *DestroyResponse) Reset()

func (*DestroyResponse) SizeVT 

func (m *DestroyResponse) SizeVT() (n int)

func (*DestroyResponse) String 

func (x *DestroyResponse) String() string

func (*DestroyResponse) UnmarshalVT 

func (m *DestroyResponse) UnmarshalVT(dAtA []byte) error

type Event 

type Event struct {
	Resource  *Resource `protobuf:"bytes,1,opt,name=resource,proto3" json:"resource,omitempty"`
	Old       *Resource `protobuf:"bytes,3,opt,name=old,proto3" json:"old,omitempty"`
	Error     *string   `protobuf:"bytes,4,opt,name=error,proto3,oneof" json:"error,omitempty"`
	EventType EventType `protobuf:"varint,2,opt,name=event_type,json=eventType,proto3,enum=cosi.resource.EventType" json:"event_type,omitempty"`
	// contains filtered or unexported fields
}

Event is emitted when resource changes.

func (*Event) Descriptor deprecated 

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

Deprecated: Use Event.ProtoReflect.Descriptor instead.

func (*Event) EqualMessageVT added in v0.3.0 

func (this *Event) EqualMessageVT(thatMsg proto.Message) bool

func (*Event) EqualVT added in v0.3.0 

func (this *Event) EqualVT(that *Event) bool

func (*Event) GetError added in v0.2.0 

func (x *Event) GetError() string

func (*Event) GetEventType 

func (x *Event) GetEventType() EventType

func (*Event) GetOld 

func (x *Event) GetOld() *Resource

func (*Event) GetResource 

func (x *Event) GetResource() *Resource

func (*Event) MarshalToSizedBufferVT 

func (m *Event) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Event) MarshalToVT 

func (m *Event) MarshalToVT(dAtA []byte) (int, error)

func (*Event) MarshalVT 

func (m *Event) MarshalVT() (dAtA []byte, err error)

func (*Event) ProtoMessage 

func (*Event) ProtoMessage()

func (*Event) ProtoReflect 

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

func (*Event) Reset 

func (x *Event) Reset()

func (*Event) SizeVT 

func (m *Event) SizeVT() (n int)

func (*Event) String 

func (x *Event) String() string

func (*Event) UnmarshalVT 

func (m *Event) UnmarshalVT(dAtA []byte) error

type EventType 

type EventType int32
const (
	EventType_CREATED      EventType = 0
	EventType_UPDATED      EventType = 1
	EventType_DESTROYED    EventType = 2
	EventType_BOOTSTRAPPED EventType = 3
	EventType_ERRORED      EventType = 4
)

func (EventType) Descriptor 

func (EventType) Descriptor() protoreflect.EnumDescriptor

func (EventType) Enum 

func (x EventType) Enum() *EventType

func (EventType) EnumDescriptor deprecated 

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

Deprecated: Use EventType.Descriptor instead.

func (EventType) Number 

func (x EventType) Number() protoreflect.EnumNumber

func (EventType) String 

func (x EventType) String() string

func (EventType) Type 

func (EventType) Type() protoreflect.EnumType

type GetOptions 

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

func (*GetOptions) Descriptor deprecated 

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

Deprecated: Use GetOptions.ProtoReflect.Descriptor instead.

func (*GetOptions) EqualMessageVT added in v0.3.0 

func (this *GetOptions) EqualMessageVT(thatMsg proto.Message) bool

func (*GetOptions) EqualVT added in v0.3.0 

func (this *GetOptions) EqualVT(that *GetOptions) bool

func (*GetOptions) MarshalToSizedBufferVT 

func (m *GetOptions) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*GetOptions) MarshalToVT 

func (m *GetOptions) MarshalToVT(dAtA []byte) (int, error)

func (*GetOptions) MarshalVT 

func (m *GetOptions) MarshalVT() (dAtA []byte, err error)

func (*GetOptions) ProtoMessage 

func (*GetOptions) ProtoMessage()

func (*GetOptions) ProtoReflect 

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

func (*GetOptions) Reset 

func (x *GetOptions) Reset()

func (*GetOptions) SizeVT 

func (m *GetOptions) SizeVT() (n int)

func (*GetOptions) String 

func (x *GetOptions) String() string

func (*GetOptions) UnmarshalVT 

func (m *GetOptions) UnmarshalVT(dAtA []byte) error

type GetRequest 

type GetRequest struct {
	Namespace string      `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Type      string      `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	Id        string      `protobuf:"bytes,3,opt,name=id,proto3" json:"id,omitempty"`
	Options   *GetOptions `protobuf:"bytes,4,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*GetRequest) Descriptor deprecated 

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

Deprecated: Use GetRequest.ProtoReflect.Descriptor instead.

func (*GetRequest) EqualMessageVT added in v0.3.0 

func (this *GetRequest) EqualMessageVT(thatMsg proto.Message) bool

func (*GetRequest) EqualVT added in v0.3.0 

func (this *GetRequest) EqualVT(that *GetRequest) bool

func (*GetRequest) GetId 

func (x *GetRequest) GetId() string

func (*GetRequest) GetNamespace 

func (x *GetRequest) GetNamespace() string

func (*GetRequest) GetOptions 

func (x *GetRequest) GetOptions() *GetOptions

func (*GetRequest) GetType 

func (x *GetRequest) GetType() string

func (*GetRequest) MarshalToSizedBufferVT 

func (m *GetRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*GetRequest) MarshalToVT 

func (m *GetRequest) MarshalToVT(dAtA []byte) (int, error)

func (*GetRequest) MarshalVT 

func (m *GetRequest) MarshalVT() (dAtA []byte, err error)

func (*GetRequest) ProtoMessage 

func (*GetRequest) ProtoMessage()

func (*GetRequest) ProtoReflect 

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

func (*GetRequest) Reset 

func (x *GetRequest) Reset()

func (*GetRequest) SizeVT 

func (m *GetRequest) SizeVT() (n int)

func (*GetRequest) String 

func (x *GetRequest) String() string

func (*GetRequest) UnmarshalVT 

func (m *GetRequest) UnmarshalVT(dAtA []byte) error

type GetResponse 

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

func (*GetResponse) Descriptor deprecated 

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

Deprecated: Use GetResponse.ProtoReflect.Descriptor instead.

func (*GetResponse) EqualMessageVT added in v0.3.0 

func (this *GetResponse) EqualMessageVT(thatMsg proto.Message) bool

func (*GetResponse) EqualVT added in v0.3.0 

func (this *GetResponse) EqualVT(that *GetResponse) bool

func (*GetResponse) GetResource 

func (x *GetResponse) GetResource() *Resource

func (*GetResponse) MarshalToSizedBufferVT 

func (m *GetResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*GetResponse) MarshalToVT 

func (m *GetResponse) MarshalToVT(dAtA []byte) (int, error)

func (*GetResponse) MarshalVT 

func (m *GetResponse) MarshalVT() (dAtA []byte, err error)

func (*GetResponse) ProtoMessage 

func (*GetResponse) ProtoMessage()

func (*GetResponse) ProtoReflect 

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

func (*GetResponse) Reset 

func (x *GetResponse) Reset()

func (*GetResponse) SizeVT 

func (m *GetResponse) SizeVT() (n int)

func (*GetResponse) String 

func (x *GetResponse) String() string

func (*GetResponse) UnmarshalVT 

func (m *GetResponse) UnmarshalVT(dAtA []byte) error

type IDQuery added in v0.3.0 

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

IDQuery is a query on resource metadata ID.

func (*IDQuery) Descriptor deprecated added in v0.3.0 

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

Deprecated: Use IDQuery.ProtoReflect.Descriptor instead.

func (*IDQuery) EqualMessageVT added in v0.3.0 

func (this *IDQuery) EqualMessageVT(thatMsg proto.Message) bool

func (*IDQuery) EqualVT added in v0.3.0 

func (this *IDQuery) EqualVT(that *IDQuery) bool

func (*IDQuery) GetRegexp added in v0.3.0 

func (x *IDQuery) GetRegexp() string

func (*IDQuery) MarshalToSizedBufferVT added in v0.3.0 

func (m *IDQuery) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*IDQuery) MarshalToVT added in v0.3.0 

func (m *IDQuery) MarshalToVT(dAtA []byte) (int, error)

func (*IDQuery) MarshalVT added in v0.3.0 

func (m *IDQuery) MarshalVT() (dAtA []byte, err error)

func (*IDQuery) ProtoMessage added in v0.3.0 

func (*IDQuery) ProtoMessage()

func (*IDQuery) ProtoReflect added in v0.3.0 

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

func (*IDQuery) Reset added in v0.3.0 

func (x *IDQuery) Reset()

func (*IDQuery) SizeVT added in v0.3.0 

func (m *IDQuery) SizeVT() (n int)

func (*IDQuery) String added in v0.3.0 

func (x *IDQuery) String() string

func (*IDQuery) UnmarshalVT added in v0.3.0 

func (m *IDQuery) UnmarshalVT(dAtA []byte) error

type LabelQuery 

type LabelQuery struct {
	Terms []*LabelTerm `protobuf:"bytes,1,rep,name=terms,proto3" json:"terms,omitempty"`
	// contains filtered or unexported fields
}

LabelQuery is a query on resource metadata labels.

Terms are combined with AND.

func (*LabelQuery) Descriptor deprecated 

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

Deprecated: Use LabelQuery.ProtoReflect.Descriptor instead.

func (*LabelQuery) EqualMessageVT added in v0.3.0 

func (this *LabelQuery) EqualMessageVT(thatMsg proto.Message) bool

func (*LabelQuery) EqualVT added in v0.3.0 

func (this *LabelQuery) EqualVT(that *LabelQuery) bool

func (*LabelQuery) GetTerms 

func (x *LabelQuery) GetTerms() []*LabelTerm

func (*LabelQuery) MarshalToSizedBufferVT 

func (m *LabelQuery) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*LabelQuery) MarshalToVT 

func (m *LabelQuery) MarshalToVT(dAtA []byte) (int, error)

func (*LabelQuery) MarshalVT 

func (m *LabelQuery) MarshalVT() (dAtA []byte, err error)

func (*LabelQuery) ProtoMessage 

func (*LabelQuery) ProtoMessage()

func (*LabelQuery) ProtoReflect 

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

func (*LabelQuery) Reset 

func (x *LabelQuery) Reset()

func (*LabelQuery) SizeVT 

func (m *LabelQuery) SizeVT() (n int)

func (*LabelQuery) String 

func (x *LabelQuery) String() string

func (*LabelQuery) UnmarshalVT 

func (m *LabelQuery) UnmarshalVT(dAtA []byte) error

type LabelTerm 

type LabelTerm struct {
	Key   string              `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Op    LabelTerm_Operation `protobuf:"varint,2,opt,name=op,proto3,enum=cosi.resource.LabelTerm_Operation" json:"op,omitempty"`
	Value string              `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

LabelTerm is an expression on a label.

func (*LabelTerm) Descriptor deprecated 

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

Deprecated: Use LabelTerm.ProtoReflect.Descriptor instead.

func (*LabelTerm) EqualMessageVT added in v0.3.0 

func (this *LabelTerm) EqualMessageVT(thatMsg proto.Message) bool

func (*LabelTerm) EqualVT added in v0.3.0 

func (this *LabelTerm) EqualVT(that *LabelTerm) bool

func (*LabelTerm) GetKey 

func (x *LabelTerm) GetKey() string

func (*LabelTerm) GetOp 

func (x *LabelTerm) GetOp() LabelTerm_Operation

func (*LabelTerm) GetValue 

func (x *LabelTerm) GetValue() string

func (*LabelTerm) MarshalToSizedBufferVT 

func (m *LabelTerm) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*LabelTerm) MarshalToVT 

func (m *LabelTerm) MarshalToVT(dAtA []byte) (int, error)

func (*LabelTerm) MarshalVT 

func (m *LabelTerm) MarshalVT() (dAtA []byte, err error)

func (*LabelTerm) ProtoMessage 

func (*LabelTerm) ProtoMessage()

func (*LabelTerm) ProtoReflect 

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

func (*LabelTerm) Reset 

func (x *LabelTerm) Reset()

func (*LabelTerm) SizeVT 

func (m *LabelTerm) SizeVT() (n int)

func (*LabelTerm) String 

func (x *LabelTerm) String() string

func (*LabelTerm) UnmarshalVT 

func (m *LabelTerm) UnmarshalVT(dAtA []byte) error

type LabelTerm_Operation 

type LabelTerm_Operation int32
const (
	// Label exists.
	LabelTerm_EXISTS LabelTerm_Operation = 0
	// Label value is equal.
	LabelTerm_EQUAL LabelTerm_Operation = 1
	// Label doesn't exist.
	LabelTerm_NOT_EXISTS LabelTerm_Operation = 2
)

func (LabelTerm_Operation) Descriptor 

func (LabelTerm_Operation) Descriptor() protoreflect.EnumDescriptor

func (LabelTerm_Operation) Enum 

func (x LabelTerm_Operation) Enum() *LabelTerm_Operation

func (LabelTerm_Operation) EnumDescriptor deprecated 

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

Deprecated: Use LabelTerm_Operation.Descriptor instead.

func (LabelTerm_Operation) Number 

func (x LabelTerm_Operation) Number() protoreflect.EnumNumber

func (LabelTerm_Operation) String 

func (x LabelTerm_Operation) String() string

func (LabelTerm_Operation) Type 

func (LabelTerm_Operation) Type() protoreflect.EnumType

type ListOptions 

type ListOptions struct {
	LabelQuery *LabelQuery `protobuf:"bytes,1,opt,name=label_query,json=labelQuery,proto3" json:"label_query,omitempty"`
	IdQuery    *IDQuery    `protobuf:"bytes,2,opt,name=id_query,json=idQuery,proto3" json:"id_query,omitempty"`
	// contains filtered or unexported fields
}

func (*ListOptions) Descriptor deprecated 

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

Deprecated: Use ListOptions.ProtoReflect.Descriptor instead.

func (*ListOptions) EqualMessageVT added in v0.3.0 

func (this *ListOptions) EqualMessageVT(thatMsg proto.Message) bool

func (*ListOptions) EqualVT added in v0.3.0 

func (this *ListOptions) EqualVT(that *ListOptions) bool

func (*ListOptions) GetIdQuery added in v0.3.0 

func (x *ListOptions) GetIdQuery() *IDQuery

func (*ListOptions) GetLabelQuery 

func (x *ListOptions) GetLabelQuery() *LabelQuery

func (*ListOptions) MarshalToSizedBufferVT 

func (m *ListOptions) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ListOptions) MarshalToVT 

func (m *ListOptions) MarshalToVT(dAtA []byte) (int, error)

func (*ListOptions) MarshalVT 

func (m *ListOptions) MarshalVT() (dAtA []byte, err error)

func (*ListOptions) ProtoMessage 

func (*ListOptions) ProtoMessage()

func (*ListOptions) ProtoReflect 

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

func (*ListOptions) Reset 

func (x *ListOptions) Reset()

func (*ListOptions) SizeVT 

func (m *ListOptions) SizeVT() (n int)

func (*ListOptions) String 

func (x *ListOptions) String() string

func (*ListOptions) UnmarshalVT 

func (m *ListOptions) UnmarshalVT(dAtA []byte) error

type ListRequest 

type ListRequest struct {
	Namespace string       `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Type      string       `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	Options   *ListOptions `protobuf:"bytes,3,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*ListRequest) Descriptor deprecated 

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

Deprecated: Use ListRequest.ProtoReflect.Descriptor instead.

func (*ListRequest) EqualMessageVT added in v0.3.0 

func (this *ListRequest) EqualMessageVT(thatMsg proto.Message) bool

func (*ListRequest) EqualVT added in v0.3.0 

func (this *ListRequest) EqualVT(that *ListRequest) bool

func (*ListRequest) GetNamespace 

func (x *ListRequest) GetNamespace() string

func (*ListRequest) GetOptions 

func (x *ListRequest) GetOptions() *ListOptions

func (*ListRequest) GetType 

func (x *ListRequest) GetType() string

func (*ListRequest) MarshalToSizedBufferVT 

func (m *ListRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ListRequest) MarshalToVT 

func (m *ListRequest) MarshalToVT(dAtA []byte) (int, error)

func (*ListRequest) MarshalVT 

func (m *ListRequest) MarshalVT() (dAtA []byte, err error)

func (*ListRequest) ProtoMessage 

func (*ListRequest) ProtoMessage()

func (*ListRequest) ProtoReflect 

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

func (*ListRequest) Reset 

func (x *ListRequest) Reset()

func (*ListRequest) SizeVT 

func (m *ListRequest) SizeVT() (n int)

func (*ListRequest) String 

func (x *ListRequest) String() string

func (*ListRequest) UnmarshalVT 

func (m *ListRequest) UnmarshalVT(dAtA []byte) error

type ListResponse 

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

func (*ListResponse) Descriptor deprecated 

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

Deprecated: Use ListResponse.ProtoReflect.Descriptor instead.

func (*ListResponse) EqualMessageVT added in v0.3.0 

func (this *ListResponse) EqualMessageVT(thatMsg proto.Message) bool

func (*ListResponse) EqualVT added in v0.3.0 

func (this *ListResponse) EqualVT(that *ListResponse) bool

func (*ListResponse) GetResource 

func (x *ListResponse) GetResource() *Resource

func (*ListResponse) MarshalToSizedBufferVT 

func (m *ListResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ListResponse) MarshalToVT 

func (m *ListResponse) MarshalToVT(dAtA []byte) (int, error)

func (*ListResponse) MarshalVT 

func (m *ListResponse) MarshalVT() (dAtA []byte, err error)

func (*ListResponse) ProtoMessage 

func (*ListResponse) ProtoMessage()

func (*ListResponse) ProtoReflect 

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

func (*ListResponse) Reset 

func (x *ListResponse) Reset()

func (*ListResponse) SizeVT 

func (m *ListResponse) SizeVT() (n int)

func (*ListResponse) String 

func (x *ListResponse) String() string

func (*ListResponse) UnmarshalVT 

func (m *ListResponse) UnmarshalVT(dAtA []byte) error

type Metadata 

type Metadata struct {
	Namespace   string                 `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Type        string                 `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	Id          string                 `protobuf:"bytes,3,opt,name=id,proto3" json:"id,omitempty"`
	Version     string                 `protobuf:"bytes,4,opt,name=version,proto3" json:"version,omitempty"`
	Owner       string                 `protobuf:"bytes,5,opt,name=owner,proto3" json:"owner,omitempty"`
	Phase       string                 `protobuf:"bytes,6,opt,name=phase,proto3" json:"phase,omitempty"`
	Created     *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=created,proto3" json:"created,omitempty"`
	Updated     *timestamppb.Timestamp `protobuf:"bytes,8,opt,name=updated,proto3" json:"updated,omitempty"`
	Finalizers  []string               `protobuf:"bytes,9,rep,name=finalizers,proto3" json:"finalizers,omitempty"`
	Annotations map[string]string      `` /* 164-byte string literal not displayed */
	Labels      map[string]string      `` /* 154-byte string literal not displayed */
	// contains filtered or unexported fields
}

Metadata represents resource metadata.

(namespace, type, id) is a resource pointer. (version) is a current resource version. (owner) is filled in for controller-managed resources with controller name. (phase) indicates whether resource is going through tear down phase. (finalizers) are attached controllers blocking teardown of the resource. (labels) and (annotations) are free-form key-value pairs; labels allow queries.

func (*Metadata) Descriptor deprecated 

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

Deprecated: Use Metadata.ProtoReflect.Descriptor instead.

func (*Metadata) EqualMessageVT added in v0.3.0 

func (this *Metadata) EqualMessageVT(thatMsg proto.Message) bool

func (*Metadata) EqualVT added in v0.3.0 

func (this *Metadata) EqualVT(that *Metadata) bool

func (*Metadata) GetAnnotations added in v0.2.0 

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

func (*Metadata) GetCreated 

func (x *Metadata) GetCreated() *timestamppb.Timestamp

func (*Metadata) GetFinalizers 

func (x *Metadata) GetFinalizers() []string

func (*Metadata) GetId 

func (x *Metadata) GetId() string

func (*Metadata) GetLabels 

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

func (*Metadata) GetNamespace 

func (x *Metadata) GetNamespace() string

func (*Metadata) GetOwner 

func (x *Metadata) GetOwner() string

func (*Metadata) GetPhase 

func (x *Metadata) GetPhase() string

func (*Metadata) GetType 

func (x *Metadata) GetType() string

func (*Metadata) GetUpdated 

func (x *Metadata) GetUpdated() *timestamppb.Timestamp

func (*Metadata) GetVersion 

func (x *Metadata) GetVersion() string

func (*Metadata) MarshalToSizedBufferVT 

func (m *Metadata) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Metadata) MarshalToVT 

func (m *Metadata) MarshalToVT(dAtA []byte) (int, error)

func (*Metadata) MarshalVT 

func (m *Metadata) MarshalVT() (dAtA []byte, err error)

func (*Metadata) ProtoMessage 

func (*Metadata) ProtoMessage()

func (*Metadata) ProtoReflect 

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

func (*Metadata) Reset 

func (x *Metadata) Reset()

func (*Metadata) SizeVT 

func (m *Metadata) SizeVT() (n int)

func (*Metadata) String 

func (x *Metadata) String() string

func (*Metadata) UnmarshalVT 

func (m *Metadata) UnmarshalVT(dAtA []byte) error

type NamespaceSpec 

type NamespaceSpec struct {

	// Description of the namespace.
	Description string `protobuf:"bytes,1,opt,name=description,proto3" json:"description,omitempty"`
	// contains filtered or unexported fields
}

NamespaceSpec is the protobuf serialization of the Namespace resource.

func (*NamespaceSpec) Descriptor deprecated 

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

Deprecated: Use NamespaceSpec.ProtoReflect.Descriptor instead.

func (*NamespaceSpec) EqualMessageVT added in v0.3.0 

func (this *NamespaceSpec) EqualMessageVT(thatMsg proto.Message) bool

func (*NamespaceSpec) EqualVT added in v0.3.0 

func (this *NamespaceSpec) EqualVT(that *NamespaceSpec) bool

func (*NamespaceSpec) GetDescription 

func (x *NamespaceSpec) GetDescription() string

func (*NamespaceSpec) MarshalToSizedBufferVT 

func (m *NamespaceSpec) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*NamespaceSpec) MarshalToVT 

func (m *NamespaceSpec) MarshalToVT(dAtA []byte) (int, error)

func (*NamespaceSpec) MarshalVT 

func (m *NamespaceSpec) MarshalVT() (dAtA []byte, err error)

func (*NamespaceSpec) ProtoMessage 

func (*NamespaceSpec) ProtoMessage()

func (*NamespaceSpec) ProtoReflect 

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

func (*NamespaceSpec) Reset 

func (x *NamespaceSpec) Reset()

func (*NamespaceSpec) SizeVT 

func (m *NamespaceSpec) SizeVT() (n int)

func (*NamespaceSpec) String 

func (x *NamespaceSpec) String() string

func (*NamespaceSpec) UnmarshalVT 

func (m *NamespaceSpec) UnmarshalVT(dAtA []byte) error

type QueueReconcileRequest 

type QueueReconcileRequest struct {
	ControllerToken string `protobuf:"bytes,1,opt,name=controller_token,json=controllerToken,proto3" json:"controller_token,omitempty"`
	// contains filtered or unexported fields
}

func (*QueueReconcileRequest) Descriptor deprecated 

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

Deprecated: Use QueueReconcileRequest.ProtoReflect.Descriptor instead.

func (*QueueReconcileRequest) EqualMessageVT added in v0.3.0 

func (this *QueueReconcileRequest) EqualMessageVT(thatMsg proto.Message) bool

func (*QueueReconcileRequest) EqualVT added in v0.3.0 

func (this *QueueReconcileRequest) EqualVT(that *QueueReconcileRequest) bool

func (*QueueReconcileRequest) GetControllerToken 

func (x *QueueReconcileRequest) GetControllerToken() string

func (*QueueReconcileRequest) MarshalToSizedBufferVT 

func (m *QueueReconcileRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*QueueReconcileRequest) MarshalToVT 

func (m *QueueReconcileRequest) MarshalToVT(dAtA []byte) (int, error)

func (*QueueReconcileRequest) MarshalVT 

func (m *QueueReconcileRequest) MarshalVT() (dAtA []byte, err error)

func (*QueueReconcileRequest) ProtoMessage 

func (*QueueReconcileRequest) ProtoMessage()

func (*QueueReconcileRequest) ProtoReflect 

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

func (*QueueReconcileRequest) Reset 

func (x *QueueReconcileRequest) Reset()

func (*QueueReconcileRequest) SizeVT 

func (m *QueueReconcileRequest) SizeVT() (n int)

func (*QueueReconcileRequest) String 

func (x *QueueReconcileRequest) String() string

func (*QueueReconcileRequest) UnmarshalVT 

func (m *QueueReconcileRequest) UnmarshalVT(dAtA []byte) error

type QueueReconcileResponse 

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

func (*QueueReconcileResponse) Descriptor deprecated 

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

Deprecated: Use QueueReconcileResponse.ProtoReflect.Descriptor instead.

func (*QueueReconcileResponse) EqualMessageVT added in v0.3.0 

func (this *QueueReconcileResponse) EqualMessageVT(thatMsg proto.Message) bool

func (*QueueReconcileResponse) EqualVT added in v0.3.0 

func (this *QueueReconcileResponse) EqualVT(that *QueueReconcileResponse) bool

func (*QueueReconcileResponse) MarshalToSizedBufferVT 

func (m *QueueReconcileResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*QueueReconcileResponse) MarshalToVT 

func (m *QueueReconcileResponse) MarshalToVT(dAtA []byte) (int, error)

func (*QueueReconcileResponse) MarshalVT 

func (m *QueueReconcileResponse) MarshalVT() (dAtA []byte, err error)

func (*QueueReconcileResponse) ProtoMessage 

func (*QueueReconcileResponse) ProtoMessage()

func (*QueueReconcileResponse) ProtoReflect 

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

func (*QueueReconcileResponse) Reset 

func (x *QueueReconcileResponse) Reset()

func (*QueueReconcileResponse) SizeVT 

func (m *QueueReconcileResponse) SizeVT() (n int)

func (*QueueReconcileResponse) String 

func (x *QueueReconcileResponse) String() string

func (*QueueReconcileResponse) UnmarshalVT 

func (m *QueueReconcileResponse) UnmarshalVT(dAtA []byte) error

type ReconcileEventsRequest 

type ReconcileEventsRequest struct {
	ControllerToken string `protobuf:"bytes,1,opt,name=controller_token,json=controllerToken,proto3" json:"controller_token,omitempty"`
	// contains filtered or unexported fields
}

func (*ReconcileEventsRequest) Descriptor deprecated 

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

Deprecated: Use ReconcileEventsRequest.ProtoReflect.Descriptor instead.

func (*ReconcileEventsRequest) EqualMessageVT added in v0.3.0 

func (this *ReconcileEventsRequest) EqualMessageVT(thatMsg proto.Message) bool

func (*ReconcileEventsRequest) EqualVT added in v0.3.0 

func (this *ReconcileEventsRequest) EqualVT(that *ReconcileEventsRequest) bool

func (*ReconcileEventsRequest) GetControllerToken 

func (x *ReconcileEventsRequest) GetControllerToken() string

func (*ReconcileEventsRequest) MarshalToSizedBufferVT 

func (m *ReconcileEventsRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ReconcileEventsRequest) MarshalToVT 

func (m *ReconcileEventsRequest) MarshalToVT(dAtA []byte) (int, error)

func (*ReconcileEventsRequest) MarshalVT 

func (m *ReconcileEventsRequest) MarshalVT() (dAtA []byte, err error)

func (*ReconcileEventsRequest) ProtoMessage 

func (*ReconcileEventsRequest) ProtoMessage()

func (*ReconcileEventsRequest) ProtoReflect 

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

func (*ReconcileEventsRequest) Reset 

func (x *ReconcileEventsRequest) Reset()

func (*ReconcileEventsRequest) SizeVT 

func (m *ReconcileEventsRequest) SizeVT() (n int)

func (*ReconcileEventsRequest) String 

func (x *ReconcileEventsRequest) String() string

func (*ReconcileEventsRequest) UnmarshalVT 

func (m *ReconcileEventsRequest) UnmarshalVT(dAtA []byte) error

type ReconcileEventsResponse 

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

func (*ReconcileEventsResponse) Descriptor deprecated 

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

Deprecated: Use ReconcileEventsResponse.ProtoReflect.Descriptor instead.

func (*ReconcileEventsResponse) EqualMessageVT added in v0.3.0 

func (this *ReconcileEventsResponse) EqualMessageVT(thatMsg proto.Message) bool

func (*ReconcileEventsResponse) EqualVT added in v0.3.0 

func (this *ReconcileEventsResponse) EqualVT(that *ReconcileEventsResponse) bool

func (*ReconcileEventsResponse) MarshalToSizedBufferVT 

func (m *ReconcileEventsResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ReconcileEventsResponse) MarshalToVT 

func (m *ReconcileEventsResponse) MarshalToVT(dAtA []byte) (int, error)

func (*ReconcileEventsResponse) MarshalVT 

func (m *ReconcileEventsResponse) MarshalVT() (dAtA []byte, err error)

func (*ReconcileEventsResponse) ProtoMessage 

func (*ReconcileEventsResponse) ProtoMessage()

func (*ReconcileEventsResponse) ProtoReflect 

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

func (*ReconcileEventsResponse) Reset 

func (x *ReconcileEventsResponse) Reset()

func (*ReconcileEventsResponse) SizeVT 

func (m *ReconcileEventsResponse) SizeVT() (n int)

func (*ReconcileEventsResponse) String 

func (x *ReconcileEventsResponse) String() string

func (*ReconcileEventsResponse) UnmarshalVT 

func (m *ReconcileEventsResponse) UnmarshalVT(dAtA []byte) error

type RegisterControllerRequest 

type RegisterControllerRequest struct {
	ControllerName string              `protobuf:"bytes,1,opt,name=controller_name,json=controllerName,proto3" json:"controller_name,omitempty"`
	Inputs         []*ControllerInput  `protobuf:"bytes,2,rep,name=inputs,proto3" json:"inputs,omitempty"`
	Outputs        []*ControllerOutput `protobuf:"bytes,3,rep,name=outputs,proto3" json:"outputs,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterControllerRequest) Descriptor deprecated 

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

Deprecated: Use RegisterControllerRequest.ProtoReflect.Descriptor instead.

func (*RegisterControllerRequest) EqualMessageVT added in v0.3.0 

func (this *RegisterControllerRequest) EqualMessageVT(thatMsg proto.Message) bool

func (*RegisterControllerRequest) EqualVT added in v0.3.0 

func (this *RegisterControllerRequest) EqualVT(that *RegisterControllerRequest) bool

func (*RegisterControllerRequest) GetControllerName 

func (x *RegisterControllerRequest) GetControllerName() string

func (*RegisterControllerRequest) GetInputs 

func (x *RegisterControllerRequest) GetInputs() []*ControllerInput

func (*RegisterControllerRequest) GetOutputs 

func (x *RegisterControllerRequest) GetOutputs() []*ControllerOutput

func (*RegisterControllerRequest) MarshalToSizedBufferVT 

func (m *RegisterControllerRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*RegisterControllerRequest) MarshalToVT 

func (m *RegisterControllerRequest) MarshalToVT(dAtA []byte) (int, error)

func (*RegisterControllerRequest) MarshalVT 

func (m *RegisterControllerRequest) MarshalVT() (dAtA []byte, err error)

func (*RegisterControllerRequest) ProtoMessage 

func (*RegisterControllerRequest) ProtoMessage()

func (*RegisterControllerRequest) ProtoReflect 

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

func (*RegisterControllerRequest) Reset 

func (x *RegisterControllerRequest) Reset()

func (*RegisterControllerRequest) SizeVT 

func (m *RegisterControllerRequest) SizeVT() (n int)

func (*RegisterControllerRequest) String 

func (x *RegisterControllerRequest) String() string

func (*RegisterControllerRequest) UnmarshalVT 

func (m *RegisterControllerRequest) UnmarshalVT(dAtA []byte) error

type RegisterControllerResponse 

type RegisterControllerResponse struct {
	ControllerToken string `protobuf:"bytes,1,opt,name=controller_token,json=controllerToken,proto3" json:"controller_token,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterControllerResponse) Descriptor deprecated 

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

Deprecated: Use RegisterControllerResponse.ProtoReflect.Descriptor instead.

func (*RegisterControllerResponse) EqualMessageVT added in v0.3.0 

func (this *RegisterControllerResponse) EqualMessageVT(thatMsg proto.Message) bool

func (*RegisterControllerResponse) EqualVT added in v0.3.0 

func (this *RegisterControllerResponse) EqualVT(that *RegisterControllerResponse) bool

func (*RegisterControllerResponse) GetControllerToken 

func (x *RegisterControllerResponse) GetControllerToken() string

func (*RegisterControllerResponse) MarshalToSizedBufferVT 

func (m *RegisterControllerResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*RegisterControllerResponse) MarshalToVT 

func (m *RegisterControllerResponse) MarshalToVT(dAtA []byte) (int, error)

func (*RegisterControllerResponse) MarshalVT 

func (m *RegisterControllerResponse) MarshalVT() (dAtA []byte, err error)

func (*RegisterControllerResponse) ProtoMessage 

func (*RegisterControllerResponse) ProtoMessage()

func (*RegisterControllerResponse) ProtoReflect 

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

func (*RegisterControllerResponse) Reset 

func (x *RegisterControllerResponse) Reset()

func (*RegisterControllerResponse) SizeVT 

func (m *RegisterControllerResponse) SizeVT() (n int)

func (*RegisterControllerResponse) String 

func (x *RegisterControllerResponse) String() string

func (*RegisterControllerResponse) UnmarshalVT 

func (m *RegisterControllerResponse) UnmarshalVT(dAtA []byte) error

type Resource 

type Resource struct {
	Metadata *Metadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	Spec     *Spec     `protobuf:"bytes,2,opt,name=spec,proto3" json:"spec,omitempty"`
	// contains filtered or unexported fields
}

Resource is a combination of metadata and spec.

func (*Resource) Descriptor deprecated 

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

Deprecated: Use Resource.ProtoReflect.Descriptor instead.

func (*Resource) EqualMessageVT added in v0.3.0 

func (this *Resource) EqualMessageVT(thatMsg proto.Message) bool

func (*Resource) EqualVT added in v0.3.0 

func (this *Resource) EqualVT(that *Resource) bool

func (*Resource) GetMetadata 

func (x *Resource) GetMetadata() *Metadata

func (*Resource) GetSpec 

func (x *Resource) GetSpec() *Spec

func (*Resource) MarshalToSizedBufferVT 

func (m *Resource) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Resource) MarshalToVT 

func (m *Resource) MarshalToVT(dAtA []byte) (int, error)

func (*Resource) MarshalVT 

func (m *Resource) MarshalVT() (dAtA []byte, err error)

func (*Resource) ProtoMessage 

func (*Resource) ProtoMessage()

func (*Resource) ProtoReflect 

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

func (*Resource) Reset 

func (x *Resource) Reset()

func (*Resource) SizeVT 

func (m *Resource) SizeVT() (n int)

func (*Resource) String 

func (x *Resource) String() string

func (*Resource) UnmarshalVT 

func (m *Resource) UnmarshalVT(dAtA []byte) error

type ResourceDefinitionSpec 

type ResourceDefinitionSpec struct {

	// Canonical type name.
	ResourceType string `protobuf:"bytes,1,opt,name=resource_type,json=resourceType,proto3" json:"resource_type,omitempty"`
	// Displayed human-readable type name.
	DisplayType string `protobuf:"bytes,2,opt,name=display_type,json=displayType,proto3" json:"display_type,omitempty"`
	// Default namespace to look for the resource if no namespace is given.
	DefaultNamespace string `protobuf:"bytes,3,opt,name=default_namespace,json=defaultNamespace,proto3" json:"default_namespace,omitempty"`
	// Human-readable aliases.
	Aliases []string `protobuf:"bytes,4,rep,name=aliases,proto3" json:"aliases,omitempty"`
	// All aliases for automatic matching.
	AllAliases []string `protobuf:"bytes,5,rep,name=all_aliases,json=allAliases,proto3" json:"all_aliases,omitempty"`
	// Additional columns to print in table output.
	PrintColumns []*ResourceDefinitionSpec_PrintColumn `protobuf:"bytes,6,rep,name=print_columns,json=printColumns,proto3" json:"print_columns,omitempty"`
	// Sensitivity indicates how secret resource of this type is.
	// The empty value represents a non-sensitive resource.
	Sensitivity ResourceDefinitionSpec_Sensitivity `` /* 135-byte string literal not displayed */
	// contains filtered or unexported fields
}

ResourceDefinitionSpec is the protobuf serialization of the ResourceDefinition resource.

func (*ResourceDefinitionSpec) Descriptor deprecated 

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

Deprecated: Use ResourceDefinitionSpec.ProtoReflect.Descriptor instead.

func (*ResourceDefinitionSpec) EqualMessageVT added in v0.3.0 

func (this *ResourceDefinitionSpec) EqualMessageVT(thatMsg proto.Message) bool

func (*ResourceDefinitionSpec) EqualVT added in v0.3.0 

func (this *ResourceDefinitionSpec) EqualVT(that *ResourceDefinitionSpec) bool

func (*ResourceDefinitionSpec) GetAliases 

func (x *ResourceDefinitionSpec) GetAliases() []string

func (*ResourceDefinitionSpec) GetAllAliases 

func (x *ResourceDefinitionSpec) GetAllAliases() []string

func (*ResourceDefinitionSpec) GetDefaultNamespace 

func (x *ResourceDefinitionSpec) GetDefaultNamespace() string

func (*ResourceDefinitionSpec) GetDisplayType 

func (x *ResourceDefinitionSpec) GetDisplayType() string

func (*ResourceDefinitionSpec) GetPrintColumns 

func (x *ResourceDefinitionSpec) GetPrintColumns() []*ResourceDefinitionSpec_PrintColumn

func (*ResourceDefinitionSpec) GetResourceType 

func (x *ResourceDefinitionSpec) GetResourceType() string

func (*ResourceDefinitionSpec) GetSensitivity 

func (x *ResourceDefinitionSpec) GetSensitivity() ResourceDefinitionSpec_Sensitivity

func (*ResourceDefinitionSpec) MarshalToSizedBufferVT 

func (m *ResourceDefinitionSpec) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ResourceDefinitionSpec) MarshalToVT 

func (m *ResourceDefinitionSpec) MarshalToVT(dAtA []byte) (int, error)

func (*ResourceDefinitionSpec) MarshalVT 

func (m *ResourceDefinitionSpec) MarshalVT() (dAtA []byte, err error)

func (*ResourceDefinitionSpec) ProtoMessage 

func (*ResourceDefinitionSpec) ProtoMessage()

func (*ResourceDefinitionSpec) ProtoReflect 

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

func (*ResourceDefinitionSpec) Reset 

func (x *ResourceDefinitionSpec) Reset()

func (*ResourceDefinitionSpec) SizeVT 

func (m *ResourceDefinitionSpec) SizeVT() (n int)

func (*ResourceDefinitionSpec) String 

func (x *ResourceDefinitionSpec) String() string

func (*ResourceDefinitionSpec) UnmarshalVT 

func (m *ResourceDefinitionSpec) UnmarshalVT(dAtA []byte) error

type ResourceDefinitionSpec_PrintColumn 

type ResourceDefinitionSpec_PrintColumn struct {
	Name     string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	JsonPath string `protobuf:"bytes,2,opt,name=json_path,json=jsonPath,proto3" json:"json_path,omitempty"`
	// contains filtered or unexported fields
}

func (*ResourceDefinitionSpec_PrintColumn) Descriptor deprecated 

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

Deprecated: Use ResourceDefinitionSpec_PrintColumn.ProtoReflect.Descriptor instead.

func (*ResourceDefinitionSpec_PrintColumn) EqualMessageVT added in v0.3.0 

func (this *ResourceDefinitionSpec_PrintColumn) EqualMessageVT(thatMsg proto.Message) bool

func (*ResourceDefinitionSpec_PrintColumn) EqualVT added in v0.3.0 

func (this *ResourceDefinitionSpec_PrintColumn) EqualVT(that *ResourceDefinitionSpec_PrintColumn) bool

func (*ResourceDefinitionSpec_PrintColumn) GetJsonPath 

func (x *ResourceDefinitionSpec_PrintColumn) GetJsonPath() string

func (*ResourceDefinitionSpec_PrintColumn) GetName 

func (x *ResourceDefinitionSpec_PrintColumn) GetName() string

func (*ResourceDefinitionSpec_PrintColumn) MarshalToSizedBufferVT 

func (m *ResourceDefinitionSpec_PrintColumn) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ResourceDefinitionSpec_PrintColumn) MarshalToVT 

func (m *ResourceDefinitionSpec_PrintColumn) MarshalToVT(dAtA []byte) (int, error)

func (*ResourceDefinitionSpec_PrintColumn) MarshalVT 

func (m *ResourceDefinitionSpec_PrintColumn) MarshalVT() (dAtA []byte, err error)

func (*ResourceDefinitionSpec_PrintColumn) ProtoMessage 

func (*ResourceDefinitionSpec_PrintColumn) ProtoMessage()

func (*ResourceDefinitionSpec_PrintColumn) ProtoReflect 

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

func (*ResourceDefinitionSpec_PrintColumn) Reset 

func (x *ResourceDefinitionSpec_PrintColumn) Reset()

func (*ResourceDefinitionSpec_PrintColumn) SizeVT 

func (m *ResourceDefinitionSpec_PrintColumn) SizeVT() (n int)

func (*ResourceDefinitionSpec_PrintColumn) String 

func (x *ResourceDefinitionSpec_PrintColumn) String() string

func (*ResourceDefinitionSpec_PrintColumn) UnmarshalVT 

func (m *ResourceDefinitionSpec_PrintColumn) UnmarshalVT(dAtA []byte) error

type ResourceDefinitionSpec_Sensitivity 

type ResourceDefinitionSpec_Sensitivity int32
const (
	ResourceDefinitionSpec_NON_SENSITIVE ResourceDefinitionSpec_Sensitivity = 0
	ResourceDefinitionSpec_SENSITIVE     ResourceDefinitionSpec_Sensitivity = 1
)

func (ResourceDefinitionSpec_Sensitivity) Descriptor 

func (ResourceDefinitionSpec_Sensitivity) Descriptor() protoreflect.EnumDescriptor

func (ResourceDefinitionSpec_Sensitivity) Enum 

func (x ResourceDefinitionSpec_Sensitivity) Enum() *ResourceDefinitionSpec_Sensitivity

func (ResourceDefinitionSpec_Sensitivity) EnumDescriptor deprecated 

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

Deprecated: Use ResourceDefinitionSpec_Sensitivity.Descriptor instead.

func (ResourceDefinitionSpec_Sensitivity) Number 

func (x ResourceDefinitionSpec_Sensitivity) Number() protoreflect.EnumNumber

func (ResourceDefinitionSpec_Sensitivity) String 

func (x ResourceDefinitionSpec_Sensitivity) String() string

func (ResourceDefinitionSpec_Sensitivity) Type 

func (ResourceDefinitionSpec_Sensitivity) Type() protoreflect.EnumType

type RuntimeAddFinalizerRequest 

type RuntimeAddFinalizerRequest struct {
	ControllerToken string   `protobuf:"bytes,1,opt,name=controller_token,json=controllerToken,proto3" json:"controller_token,omitempty"`
	Namespace       string   `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Type            string   `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
	Id              string   `protobuf:"bytes,4,opt,name=id,proto3" json:"id,omitempty"`
	Finalizers      []string `protobuf:"bytes,5,rep,name=finalizers,proto3" json:"finalizers,omitempty"`
	// contains filtered or unexported fields
}

func (*RuntimeAddFinalizerRequest) Descriptor deprecated 

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

Deprecated: Use RuntimeAddFinalizerRequest.ProtoReflect.Descriptor instead.

func (*RuntimeAddFinalizerRequest) EqualMessageVT added in v0.3.0 

func (this *RuntimeAddFinalizerRequest) EqualMessageVT(thatMsg proto.Message) bool

func (*RuntimeAddFinalizerRequest) EqualVT added in v0.3.0 

func (this *RuntimeAddFinalizerRequest) EqualVT(that *RuntimeAddFinalizerRequest) bool

func (*RuntimeAddFinalizerRequest) GetControllerToken 

func (x *RuntimeAddFinalizerRequest) GetControllerToken() string

func (*RuntimeAddFinalizerRequest) GetFinalizers 

func (x *RuntimeAddFinalizerRequest) GetFinalizers() []string

func (*RuntimeAddFinalizerRequest) GetId 

func (x *RuntimeAddFinalizerRequest) GetId() string

func (*RuntimeAddFinalizerRequest) GetNamespace 

func (x *RuntimeAddFinalizerRequest) GetNamespace() string

func (*RuntimeAddFinalizerRequest) GetType 

func (x *RuntimeAddFinalizerRequest) GetType() string

func (*RuntimeAddFinalizerRequest) MarshalToSizedBufferVT 

func (m *RuntimeAddFinalizerRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*RuntimeAddFinalizerRequest) MarshalToVT 

func (m *RuntimeAddFinalizerRequest) MarshalToVT(dAtA []byte) (int, error)

func (*RuntimeAddFinalizerRequest) MarshalVT 

func (m *RuntimeAddFinalizerRequest) MarshalVT() (dAtA []byte, err error)

func (*RuntimeAddFinalizerRequest) ProtoMessage 

func (*RuntimeAddFinalizerRequest) ProtoMessage()

func (*RuntimeAddFinalizerRequest) ProtoReflect 

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

func (*RuntimeAddFinalizerRequest) Reset 

func (x *RuntimeAddFinalizerRequest) Reset()

func (*RuntimeAddFinalizerRequest) SizeVT 

func (m *RuntimeAddFinalizerRequest) SizeVT() (n int)

func (*RuntimeAddFinalizerRequest) String 

func (x *RuntimeAddFinalizerRequest) String() string

func (*RuntimeAddFinalizerRequest) UnmarshalVT 

func (m *RuntimeAddFinalizerRequest) UnmarshalVT(dAtA []byte) error

type RuntimeAddFinalizerResponse 

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

func (*RuntimeAddFinalizerResponse) Descriptor deprecated 

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

Deprecated: Use RuntimeAddFinalizerResponse.ProtoReflect.Descriptor instead.

func (*RuntimeAddFinalizerResponse) EqualMessageVT added in v0.3.0 

func (this *RuntimeAddFinalizerResponse) EqualMessageVT(thatMsg proto.Message) bool

func (*RuntimeAddFinalizerResponse) EqualVT added in v0.3.0 

func (this *RuntimeAddFinalizerResponse) EqualVT(that *RuntimeAddFinalizerResponse) bool

func (*RuntimeAddFinalizerResponse) MarshalToSizedBufferVT 

func (m *RuntimeAddFinalizerResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*RuntimeAddFinalizerResponse) MarshalToVT 

func (m *RuntimeAddFinalizerResponse) MarshalToVT(dAtA []byte) (int, error)

func (*RuntimeAddFinalizerResponse) MarshalVT 

func (m *RuntimeAddFinalizerResponse) MarshalVT() (dAtA []byte, err error)

func (*RuntimeAddFinalizerResponse) ProtoMessage 

func (*RuntimeAddFinalizerResponse) ProtoMessage()

func (*RuntimeAddFinalizerResponse) ProtoReflect 

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

func (*RuntimeAddFinalizerResponse) Reset 

func (x *RuntimeAddFinalizerResponse) Reset()

func (*RuntimeAddFinalizerResponse) SizeVT 

func (m *RuntimeAddFinalizerResponse) SizeVT() (n int)

func (*RuntimeAddFinalizerResponse) String 

func (x *RuntimeAddFinalizerResponse) String() string

func (*RuntimeAddFinalizerResponse) UnmarshalVT 

func (m *RuntimeAddFinalizerResponse) UnmarshalVT(dAtA []byte) error

type RuntimeCreateRequest 

type RuntimeCreateRequest struct {
	ControllerToken string    `protobuf:"bytes,1,opt,name=controller_token,json=controllerToken,proto3" json:"controller_token,omitempty"`
	Resource        *Resource `protobuf:"bytes,2,opt,name=resource,proto3" json:"resource,omitempty"`
	// contains filtered or unexported fields
}

func (*RuntimeCreateRequest) Descriptor deprecated 

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

Deprecated: Use RuntimeCreateRequest.ProtoReflect.Descriptor instead.

func (*RuntimeCreateRequest) EqualMessageVT added in v0.3.0 

func (this *RuntimeCreateRequest) EqualMessageVT(thatMsg proto.Message) bool

func (*RuntimeCreateRequest) EqualVT added in v0.3.0 

func (this *RuntimeCreateRequest) EqualVT(that *RuntimeCreateRequest) bool

func (*RuntimeCreateRequest) GetControllerToken 

func (x *RuntimeCreateRequest) GetControllerToken() string

func (*RuntimeCreateRequest) GetResource 

func (x *RuntimeCreateRequest) GetResource() *Resource

func (*RuntimeCreateRequest) MarshalToSizedBufferVT 

func (m *RuntimeCreateRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*RuntimeCreateRequest) MarshalToVT 

func (m *RuntimeCreateRequest) MarshalToVT(dAtA []byte) (int, error)

func (*RuntimeCreateRequest) MarshalVT 

func (m *RuntimeCreateRequest) MarshalVT() (dAtA []byte, err error)

func (*RuntimeCreateRequest) ProtoMessage 

func (*RuntimeCreateRequest) ProtoMessage()

func (*RuntimeCreateRequest) ProtoReflect 

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

func (*RuntimeCreateRequest) Reset 

func (x *RuntimeCreateRequest) Reset()

func (*RuntimeCreateRequest) SizeVT 

func (m *RuntimeCreateRequest) SizeVT() (n int)

func (*RuntimeCreateRequest) String 

func (x *RuntimeCreateRequest) String() string

func (*RuntimeCreateRequest) UnmarshalVT 

func (m *RuntimeCreateRequest) UnmarshalVT(dAtA []byte) error

type RuntimeCreateResponse 

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

func (*RuntimeCreateResponse) Descriptor deprecated 

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

Deprecated: Use RuntimeCreateResponse.ProtoReflect.Descriptor instead.

func (*RuntimeCreateResponse) EqualMessageVT added in v0.3.0 

func (this *RuntimeCreateResponse) EqualMessageVT(thatMsg proto.Message) bool

func (*RuntimeCreateResponse) EqualVT added in v0.3.0 

func (this *RuntimeCreateResponse) EqualVT(that *RuntimeCreateResponse) bool

func (*RuntimeCreateResponse) GetResource added in v0.2.0 

func (x *RuntimeCreateResponse) GetResource() *Resource

func (*RuntimeCreateResponse) MarshalToSizedBufferVT 

func (m *RuntimeCreateResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*RuntimeCreateResponse) MarshalToVT 

func (m *RuntimeCreateResponse) MarshalToVT(dAtA []byte) (int, error)

func (*RuntimeCreateResponse) MarshalVT 

func (m *RuntimeCreateResponse) MarshalVT() (dAtA []byte, err error)

func (*RuntimeCreateResponse) ProtoMessage 

func (*RuntimeCreateResponse) ProtoMessage()

func (*RuntimeCreateResponse) ProtoReflect 

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

func (*RuntimeCreateResponse) Reset 

func (x *RuntimeCreateResponse) Reset()

func (*RuntimeCreateResponse) SizeVT 

func (m *RuntimeCreateResponse) SizeVT() (n int)

func (*RuntimeCreateResponse) String 

func (x *RuntimeCreateResponse) String() string

func (*RuntimeCreateResponse) UnmarshalVT 

func (m *RuntimeCreateResponse) UnmarshalVT(dAtA []byte) error

type RuntimeDestroyRequest 

type RuntimeDestroyRequest struct {
	ControllerToken string `protobuf:"bytes,1,opt,name=controller_token,json=controllerToken,proto3" json:"controller_token,omitempty"`
	Namespace       string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Type            string `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
	Id              string `protobuf:"bytes,4,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*RuntimeDestroyRequest) Descriptor deprecated 

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

Deprecated: Use RuntimeDestroyRequest.ProtoReflect.Descriptor instead.

func (*RuntimeDestroyRequest) EqualMessageVT added in v0.3.0 

func (this *RuntimeDestroyRequest) EqualMessageVT(thatMsg proto.Message) bool

func (*RuntimeDestroyRequest) EqualVT added in v0.3.0 

func (this *RuntimeDestroyRequest) EqualVT(that *RuntimeDestroyRequest) bool

func (*RuntimeDestroyRequest) GetControllerToken 

func (x *RuntimeDestroyRequest) GetControllerToken() string

func (*RuntimeDestroyRequest) GetId 

func (x *RuntimeDestroyRequest) GetId() string

func (*RuntimeDestroyRequest) GetNamespace 

func (x *RuntimeDestroyRequest) GetNamespace() string

func (*RuntimeDestroyRequest) GetType 

func (x *RuntimeDestroyRequest) GetType() string

func (*RuntimeDestroyRequest) MarshalToSizedBufferVT 

func (m *RuntimeDestroyRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*RuntimeDestroyRequest) MarshalToVT 

func (m *RuntimeDestroyRequest) MarshalToVT(dAtA []byte) (int, error)

func (*RuntimeDestroyRequest) MarshalVT 

func (m *RuntimeDestroyRequest) MarshalVT() (dAtA []byte, err error)

func (*RuntimeDestroyRequest) ProtoMessage 

func (*RuntimeDestroyRequest) ProtoMessage()

func (*RuntimeDestroyRequest) ProtoReflect 

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

func (*RuntimeDestroyRequest) Reset 

func (x *RuntimeDestroyRequest) Reset()

func (*RuntimeDestroyRequest) SizeVT 

func (m *RuntimeDestroyRequest) SizeVT() (n int)

func (*RuntimeDestroyRequest) String 

func (x *RuntimeDestroyRequest) String() string

func (*RuntimeDestroyRequest) UnmarshalVT 

func (m *RuntimeDestroyRequest) UnmarshalVT(dAtA []byte) error

type RuntimeDestroyResponse 

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

func (*RuntimeDestroyResponse) Descriptor deprecated 

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

Deprecated: Use RuntimeDestroyResponse.ProtoReflect.Descriptor instead.

func (*RuntimeDestroyResponse) EqualMessageVT added in v0.3.0 

func (this *RuntimeDestroyResponse) EqualMessageVT(thatMsg proto.Message) bool

func (*RuntimeDestroyResponse) EqualVT added in v0.3.0 

func (this *RuntimeDestroyResponse) EqualVT(that *RuntimeDestroyResponse) bool

func (*RuntimeDestroyResponse) MarshalToSizedBufferVT 

func (m *RuntimeDestroyResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*RuntimeDestroyResponse) MarshalToVT 

func (m *RuntimeDestroyResponse) MarshalToVT(dAtA []byte) (int, error)

func (*RuntimeDestroyResponse) MarshalVT 

func (m *RuntimeDestroyResponse) MarshalVT() (dAtA []byte, err error)

func (*RuntimeDestroyResponse) ProtoMessage 

func (*RuntimeDestroyResponse) ProtoMessage()

func (*RuntimeDestroyResponse) ProtoReflect 

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

func (*RuntimeDestroyResponse) Reset 

func (x *RuntimeDestroyResponse) Reset()

func (*RuntimeDestroyResponse) SizeVT 

func (m *RuntimeDestroyResponse) SizeVT() (n int)

func (*RuntimeDestroyResponse) String 

func (x *RuntimeDestroyResponse) String() string

func (*RuntimeDestroyResponse) UnmarshalVT 

func (m *RuntimeDestroyResponse) UnmarshalVT(dAtA []byte) error

type RuntimeGetRequest 

type RuntimeGetRequest struct {
	ControllerToken string `protobuf:"bytes,1,opt,name=controller_token,json=controllerToken,proto3" json:"controller_token,omitempty"`
	Namespace       string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Type            string `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
	Id              string `protobuf:"bytes,4,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*RuntimeGetRequest) Descriptor deprecated 

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

Deprecated: Use RuntimeGetRequest.ProtoReflect.Descriptor instead.

func (*RuntimeGetRequest) EqualMessageVT added in v0.3.0 

func (this *RuntimeGetRequest) EqualMessageVT(thatMsg proto.Message) bool

func (*RuntimeGetRequest) EqualVT added in v0.3.0 

func (this *RuntimeGetRequest) EqualVT(that *RuntimeGetRequest) bool

func (*RuntimeGetRequest) GetControllerToken 

func (x *RuntimeGetRequest) GetControllerToken() string

func (*RuntimeGetRequest) GetId 

func (x *RuntimeGetRequest) GetId() string

func (*RuntimeGetRequest) GetNamespace 

func (x *RuntimeGetRequest) GetNamespace() string

func (*RuntimeGetRequest) GetType 

func (x *RuntimeGetRequest) GetType() string

func (*RuntimeGetRequest) MarshalToSizedBufferVT 

func (m *RuntimeGetRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*RuntimeGetRequest) MarshalToVT 

func (m *RuntimeGetRequest) MarshalToVT(dAtA []byte) (int, error)

func (*RuntimeGetRequest) MarshalVT 

func (m *RuntimeGetRequest) MarshalVT() (dAtA []byte, err error)

func (*RuntimeGetRequest) ProtoMessage 

func (*RuntimeGetRequest) ProtoMessage()

func (*RuntimeGetRequest) ProtoReflect 

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

func (*RuntimeGetRequest) Reset 

func (x *RuntimeGetRequest) Reset()

func (*RuntimeGetRequest) SizeVT 

func (m *RuntimeGetRequest) SizeVT() (n int)

func (*RuntimeGetRequest) String 

func (x *RuntimeGetRequest) String() string

func (*RuntimeGetRequest) UnmarshalVT 

func (m *RuntimeGetRequest) UnmarshalVT(dAtA []byte) error

type RuntimeGetResponse 

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

func (*RuntimeGetResponse) Descriptor deprecated 

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

Deprecated: Use RuntimeGetResponse.ProtoReflect.Descriptor instead.

func (*RuntimeGetResponse) EqualMessageVT added in v0.3.0 

func (this *RuntimeGetResponse) EqualMessageVT(thatMsg proto.Message) bool

func (*RuntimeGetResponse) EqualVT added in v0.3.0 

func (this *RuntimeGetResponse) EqualVT(that *RuntimeGetResponse) bool

func (*RuntimeGetResponse) GetResource 

func (x *RuntimeGetResponse) GetResource() *Resource

func (*RuntimeGetResponse) MarshalToSizedBufferVT 

func (m *RuntimeGetResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*RuntimeGetResponse) MarshalToVT 

func (m *RuntimeGetResponse) MarshalToVT(dAtA []byte) (int, error)

func (*RuntimeGetResponse) MarshalVT 

func (m *RuntimeGetResponse) MarshalVT() (dAtA []byte, err error)

func (*RuntimeGetResponse) ProtoMessage 

func (*RuntimeGetResponse) ProtoMessage()

func (*RuntimeGetResponse) ProtoReflect 

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

func (*RuntimeGetResponse) Reset 

func (x *RuntimeGetResponse) Reset()

func (*RuntimeGetResponse) SizeVT 

func (m *RuntimeGetResponse) SizeVT() (n int)

func (*RuntimeGetResponse) String 

func (x *RuntimeGetResponse) String() string

func (*RuntimeGetResponse) UnmarshalVT 

func (m *RuntimeGetResponse) UnmarshalVT(dAtA []byte) error

type RuntimeListOptions 

type RuntimeListOptions struct {
	LabelQuery *LabelQuery `protobuf:"bytes,1,opt,name=label_query,json=labelQuery,proto3" json:"label_query,omitempty"`
	// contains filtered or unexported fields
}

func (*RuntimeListOptions) Descriptor deprecated 

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

Deprecated: Use RuntimeListOptions.ProtoReflect.Descriptor instead.

func (*RuntimeListOptions) EqualMessageVT added in v0.3.0 

func (this *RuntimeListOptions) EqualMessageVT(thatMsg proto.Message) bool

func (*RuntimeListOptions) EqualVT added in v0.3.0 

func (this *RuntimeListOptions) EqualVT(that *RuntimeListOptions) bool

func (*RuntimeListOptions) GetLabelQuery 

func (x *RuntimeListOptions) GetLabelQuery() *LabelQuery

func (*RuntimeListOptions) MarshalToSizedBufferVT 

func (m *RuntimeListOptions) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*RuntimeListOptions) MarshalToVT 

func (m *RuntimeListOptions) MarshalToVT(dAtA []byte) (int, error)

func (*RuntimeListOptions) MarshalVT 

func (m *RuntimeListOptions) MarshalVT() (dAtA []byte, err error)

func (*RuntimeListOptions) ProtoMessage 

func (*RuntimeListOptions) ProtoMessage()

func (*RuntimeListOptions) ProtoReflect 

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

func (*RuntimeListOptions) Reset 

func (x *RuntimeListOptions) Reset()

func (*RuntimeListOptions) SizeVT 

func (m *RuntimeListOptions) SizeVT() (n int)

func (*RuntimeListOptions) String 

func (x *RuntimeListOptions) String() string

func (*RuntimeListOptions) UnmarshalVT 

func (m *RuntimeListOptions) UnmarshalVT(dAtA []byte) error

type RuntimeListRequest 

type RuntimeListRequest struct {
	ControllerToken string              `protobuf:"bytes,1,opt,name=controller_token,json=controllerToken,proto3" json:"controller_token,omitempty"`
	Namespace       string              `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Type            string              `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
	Options         *RuntimeListOptions `protobuf:"bytes,4,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*RuntimeListRequest) Descriptor deprecated 

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

Deprecated: Use RuntimeListRequest.ProtoReflect.Descriptor instead.

func (*RuntimeListRequest) EqualMessageVT added in v0.3.0 

func (this *RuntimeListRequest) EqualMessageVT(thatMsg proto.Message) bool

func (*RuntimeListRequest) EqualVT added in v0.3.0 

func (this *RuntimeListRequest) EqualVT(that *RuntimeListRequest) bool

func (*RuntimeListRequest) GetControllerToken 

func (x *RuntimeListRequest) GetControllerToken() string

func (*RuntimeListRequest) GetNamespace 

func (x *RuntimeListRequest) GetNamespace() string

func (*RuntimeListRequest) GetOptions 

func (x *RuntimeListRequest) GetOptions() *RuntimeListOptions

func (*RuntimeListRequest) GetType 

func (x *RuntimeListRequest) GetType() string

func (*RuntimeListRequest) MarshalToSizedBufferVT 

func (m *RuntimeListRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*RuntimeListRequest) MarshalToVT 

func (m *RuntimeListRequest) MarshalToVT(dAtA []byte) (int, error)

func (*RuntimeListRequest) MarshalVT 

func (m *RuntimeListRequest) MarshalVT() (dAtA []byte, err error)

func (*RuntimeListRequest) ProtoMessage 

func (*RuntimeListRequest) ProtoMessage()

func (*RuntimeListRequest) ProtoReflect 

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

func (*RuntimeListRequest) Reset 

func (x *RuntimeListRequest) Reset()

func (*RuntimeListRequest) SizeVT 

func (m *RuntimeListRequest) SizeVT() (n int)

func (*RuntimeListRequest) String 

func (x *RuntimeListRequest) String() string

func (*RuntimeListRequest) UnmarshalVT 

func (m *RuntimeListRequest) UnmarshalVT(dAtA []byte) error

type RuntimeListResponse 

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

func (*RuntimeListResponse) Descriptor deprecated 

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

Deprecated: Use RuntimeListResponse.ProtoReflect.Descriptor instead.

func (*RuntimeListResponse) EqualMessageVT added in v0.3.0 

func (this *RuntimeListResponse) EqualMessageVT(thatMsg proto.Message) bool

func (*RuntimeListResponse) EqualVT added in v0.3.0 

func (this *RuntimeListResponse) EqualVT(that *RuntimeListResponse) bool

func (*RuntimeListResponse) GetResource 

func (x *RuntimeListResponse) GetResource() *Resource

func (*RuntimeListResponse) MarshalToSizedBufferVT 

func (m *RuntimeListResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*RuntimeListResponse) MarshalToVT 

func (m *RuntimeListResponse) MarshalToVT(dAtA []byte) (int, error)

func (*RuntimeListResponse) MarshalVT 

func (m *RuntimeListResponse) MarshalVT() (dAtA []byte, err error)

func (*RuntimeListResponse) ProtoMessage 

func (*RuntimeListResponse) ProtoMessage()

func (*RuntimeListResponse) ProtoReflect 

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

func (*RuntimeListResponse) Reset 

func (x *RuntimeListResponse) Reset()

func (*RuntimeListResponse) SizeVT 

func (m *RuntimeListResponse) SizeVT() (n int)

func (*RuntimeListResponse) String 

func (x *RuntimeListResponse) String() string

func (*RuntimeListResponse) UnmarshalVT 

func (m *RuntimeListResponse) UnmarshalVT(dAtA []byte) error

type RuntimeRemoveFinalizerRequest 

type RuntimeRemoveFinalizerRequest struct {
	ControllerToken string   `protobuf:"bytes,1,opt,name=controller_token,json=controllerToken,proto3" json:"controller_token,omitempty"`
	Namespace       string   `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Type            string   `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
	Id              string   `protobuf:"bytes,4,opt,name=id,proto3" json:"id,omitempty"`
	Finalizers      []string `protobuf:"bytes,5,rep,name=finalizers,proto3" json:"finalizers,omitempty"`
	// contains filtered or unexported fields
}

func (*RuntimeRemoveFinalizerRequest) Descriptor deprecated 

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

Deprecated: Use RuntimeRemoveFinalizerRequest.ProtoReflect.Descriptor instead.

func (*RuntimeRemoveFinalizerRequest) EqualMessageVT added in v0.3.0 

func (this *RuntimeRemoveFinalizerRequest) EqualMessageVT(thatMsg proto.Message) bool

func (*RuntimeRemoveFinalizerRequest) EqualVT added in v0.3.0 

func (this *RuntimeRemoveFinalizerRequest) EqualVT(that *RuntimeRemoveFinalizerRequest) bool

func (*RuntimeRemoveFinalizerRequest) GetControllerToken 

func (x *RuntimeRemoveFinalizerRequest) GetControllerToken() string

func (*RuntimeRemoveFinalizerRequest) GetFinalizers 

func (x *RuntimeRemoveFinalizerRequest) GetFinalizers() []string

func (*RuntimeRemoveFinalizerRequest) GetId 

func (x *RuntimeRemoveFinalizerRequest) GetId() string

func (*RuntimeRemoveFinalizerRequest) GetNamespace 

func (x *RuntimeRemoveFinalizerRequest) GetNamespace() string

func (*RuntimeRemoveFinalizerRequest) GetType 

func (x *RuntimeRemoveFinalizerRequest) GetType() string

func (*RuntimeRemoveFinalizerRequest) MarshalToSizedBufferVT 

func (m *RuntimeRemoveFinalizerRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*RuntimeRemoveFinalizerRequest) MarshalToVT 

func (m *RuntimeRemoveFinalizerRequest) MarshalToVT(dAtA []byte) (int, error)

func (*RuntimeRemoveFinalizerRequest) MarshalVT 

func (m *RuntimeRemoveFinalizerRequest) MarshalVT() (dAtA []byte, err error)

func (*RuntimeRemoveFinalizerRequest) ProtoMessage 

func (*RuntimeRemoveFinalizerRequest) ProtoMessage()

func (*RuntimeRemoveFinalizerRequest) ProtoReflect 

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

func (*RuntimeRemoveFinalizerRequest) Reset 

func (x *RuntimeRemoveFinalizerRequest) Reset()

func (*RuntimeRemoveFinalizerRequest) SizeVT 

func (m *RuntimeRemoveFinalizerRequest) SizeVT() (n int)

func (*RuntimeRemoveFinalizerRequest) String 

func (x *RuntimeRemoveFinalizerRequest) String() string

func (*RuntimeRemoveFinalizerRequest) UnmarshalVT 

func (m *RuntimeRemoveFinalizerRequest) UnmarshalVT(dAtA []byte) error

type RuntimeRemoveFinalizerResponse 

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

func (*RuntimeRemoveFinalizerResponse) Descriptor deprecated 

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

Deprecated: Use RuntimeRemoveFinalizerResponse.ProtoReflect.Descriptor instead.

func (*RuntimeRemoveFinalizerResponse) EqualMessageVT added in v0.3.0 

func (this *RuntimeRemoveFinalizerResponse) EqualMessageVT(thatMsg proto.Message) bool

func (*RuntimeRemoveFinalizerResponse) EqualVT added in v0.3.0 

func (this *RuntimeRemoveFinalizerResponse) EqualVT(that *RuntimeRemoveFinalizerResponse) bool

func (*RuntimeRemoveFinalizerResponse) MarshalToSizedBufferVT 

func (m *RuntimeRemoveFinalizerResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*RuntimeRemoveFinalizerResponse) MarshalToVT 

func (m *RuntimeRemoveFinalizerResponse) MarshalToVT(dAtA []byte) (int, error)

func (*RuntimeRemoveFinalizerResponse) MarshalVT 

func (m *RuntimeRemoveFinalizerResponse) MarshalVT() (dAtA []byte, err error)

func (*RuntimeRemoveFinalizerResponse) ProtoMessage 

func (*RuntimeRemoveFinalizerResponse) ProtoMessage()

func (*RuntimeRemoveFinalizerResponse) ProtoReflect 

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

func (*RuntimeRemoveFinalizerResponse) Reset 

func (x *RuntimeRemoveFinalizerResponse) Reset()

func (*RuntimeRemoveFinalizerResponse) SizeVT 

func (m *RuntimeRemoveFinalizerResponse) SizeVT() (n int)

func (*RuntimeRemoveFinalizerResponse) String 

func (x *RuntimeRemoveFinalizerResponse) String() string

func (*RuntimeRemoveFinalizerResponse) UnmarshalVT 

func (m *RuntimeRemoveFinalizerResponse) UnmarshalVT(dAtA []byte) error

type RuntimeTeardownRequest 

type RuntimeTeardownRequest struct {
	ControllerToken string `protobuf:"bytes,1,opt,name=controller_token,json=controllerToken,proto3" json:"controller_token,omitempty"`
	Namespace       string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Type            string `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
	Id              string `protobuf:"bytes,4,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*RuntimeTeardownRequest) Descriptor deprecated 

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

Deprecated: Use RuntimeTeardownRequest.ProtoReflect.Descriptor instead.

func (*RuntimeTeardownRequest) EqualMessageVT added in v0.3.0 

func (this *RuntimeTeardownRequest) EqualMessageVT(thatMsg proto.Message) bool

func (*RuntimeTeardownRequest) EqualVT added in v0.3.0 

func (this *RuntimeTeardownRequest) EqualVT(that *RuntimeTeardownRequest) bool

func (*RuntimeTeardownRequest) GetControllerToken 

func (x *RuntimeTeardownRequest) GetControllerToken() string

func (*RuntimeTeardownRequest) GetId 

func (x *RuntimeTeardownRequest) GetId() string

func (*RuntimeTeardownRequest) GetNamespace 

func (x *RuntimeTeardownRequest) GetNamespace() string

func (*RuntimeTeardownRequest) GetType 

func (x *RuntimeTeardownRequest) GetType() string

func (*RuntimeTeardownRequest) MarshalToSizedBufferVT 

func (m *RuntimeTeardownRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*RuntimeTeardownRequest) MarshalToVT 

func (m *RuntimeTeardownRequest) MarshalToVT(dAtA []byte) (int, error)

func (*RuntimeTeardownRequest) MarshalVT 

func (m *RuntimeTeardownRequest) MarshalVT() (dAtA []byte, err error)

func (*RuntimeTeardownRequest) ProtoMessage 

func (*RuntimeTeardownRequest) ProtoMessage()

func (*RuntimeTeardownRequest) ProtoReflect 

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

func (*RuntimeTeardownRequest) Reset 

func (x *RuntimeTeardownRequest) Reset()

func (*RuntimeTeardownRequest) SizeVT 

func (m *RuntimeTeardownRequest) SizeVT() (n int)

func (*RuntimeTeardownRequest) String 

func (x *RuntimeTeardownRequest) String() string

func (*RuntimeTeardownRequest) UnmarshalVT 

func (m *RuntimeTeardownRequest) UnmarshalVT(dAtA []byte) error

type RuntimeTeardownResponse 

type RuntimeTeardownResponse struct {
	Ready bool `protobuf:"varint,1,opt,name=ready,proto3" json:"ready,omitempty"`
	// contains filtered or unexported fields
}

func (*RuntimeTeardownResponse) Descriptor deprecated 

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

Deprecated: Use RuntimeTeardownResponse.ProtoReflect.Descriptor instead.

func (*RuntimeTeardownResponse) EqualMessageVT added in v0.3.0 

func (this *RuntimeTeardownResponse) EqualMessageVT(thatMsg proto.Message) bool

func (*RuntimeTeardownResponse) EqualVT added in v0.3.0 

func (this *RuntimeTeardownResponse) EqualVT(that *RuntimeTeardownResponse) bool

func (*RuntimeTeardownResponse) GetReady 

func (x *RuntimeTeardownResponse) GetReady() bool

func (*RuntimeTeardownResponse) MarshalToSizedBufferVT 

func (m *RuntimeTeardownResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*RuntimeTeardownResponse) MarshalToVT 

func (m *RuntimeTeardownResponse) MarshalToVT(dAtA []byte) (int, error)

func (*RuntimeTeardownResponse) MarshalVT 

func (m *RuntimeTeardownResponse) MarshalVT() (dAtA []byte, err error)

func (*RuntimeTeardownResponse) ProtoMessage 

func (*RuntimeTeardownResponse) ProtoMessage()

func (*RuntimeTeardownResponse) ProtoReflect 

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

func (*RuntimeTeardownResponse) Reset 

func (x *RuntimeTeardownResponse) Reset()

func (*RuntimeTeardownResponse) SizeVT 

func (m *RuntimeTeardownResponse) SizeVT() (n int)

func (*RuntimeTeardownResponse) String 

func (x *RuntimeTeardownResponse) String() string

func (*RuntimeTeardownResponse) UnmarshalVT 

func (m *RuntimeTeardownResponse) UnmarshalVT(dAtA []byte) error

type RuntimeUpdateRequest 

type RuntimeUpdateRequest struct {
	ControllerToken string    `protobuf:"bytes,1,opt,name=controller_token,json=controllerToken,proto3" json:"controller_token,omitempty"`
	NewResource     *Resource `protobuf:"bytes,3,opt,name=new_resource,json=newResource,proto3" json:"new_resource,omitempty"`
	// contains filtered or unexported fields
}

func (*RuntimeUpdateRequest) Descriptor deprecated 

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

Deprecated: Use RuntimeUpdateRequest.ProtoReflect.Descriptor instead.

func (*RuntimeUpdateRequest) EqualMessageVT added in v0.3.0 

func (this *RuntimeUpdateRequest) EqualMessageVT(thatMsg proto.Message) bool

func (*RuntimeUpdateRequest) EqualVT added in v0.3.0 

func (this *RuntimeUpdateRequest) EqualVT(that *RuntimeUpdateRequest) bool

func (*RuntimeUpdateRequest) GetControllerToken 

func (x *RuntimeUpdateRequest) GetControllerToken() string

func (*RuntimeUpdateRequest) GetNewResource 

func (x *RuntimeUpdateRequest) GetNewResource() *Resource

func (*RuntimeUpdateRequest) MarshalToSizedBufferVT 

func (m *RuntimeUpdateRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*RuntimeUpdateRequest) MarshalToVT 

func (m *RuntimeUpdateRequest) MarshalToVT(dAtA []byte) (int, error)

func (*RuntimeUpdateRequest) MarshalVT 

func (m *RuntimeUpdateRequest) MarshalVT() (dAtA []byte, err error)

func (*RuntimeUpdateRequest) ProtoMessage 

func (*RuntimeUpdateRequest) ProtoMessage()

func (*RuntimeUpdateRequest) ProtoReflect 

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

func (*RuntimeUpdateRequest) Reset 

func (x *RuntimeUpdateRequest) Reset()

func (*RuntimeUpdateRequest) SizeVT 

func (m *RuntimeUpdateRequest) SizeVT() (n int)

func (*RuntimeUpdateRequest) String 

func (x *RuntimeUpdateRequest) String() string

func (*RuntimeUpdateRequest) UnmarshalVT 

func (m *RuntimeUpdateRequest) UnmarshalVT(dAtA []byte) error

type RuntimeUpdateResponse 

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

func (*RuntimeUpdateResponse) Descriptor deprecated 

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

Deprecated: Use RuntimeUpdateResponse.ProtoReflect.Descriptor instead.

func (*RuntimeUpdateResponse) EqualMessageVT added in v0.3.0 

func (this *RuntimeUpdateResponse) EqualMessageVT(thatMsg proto.Message) bool

func (*RuntimeUpdateResponse) EqualVT added in v0.3.0 

func (this *RuntimeUpdateResponse) EqualVT(that *RuntimeUpdateResponse) bool

func (*RuntimeUpdateResponse) GetResource added in v0.2.0 

func (x *RuntimeUpdateResponse) GetResource() *Resource

func (*RuntimeUpdateResponse) MarshalToSizedBufferVT 

func (m *RuntimeUpdateResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*RuntimeUpdateResponse) MarshalToVT 

func (m *RuntimeUpdateResponse) MarshalToVT(dAtA []byte) (int, error)

func (*RuntimeUpdateResponse) MarshalVT 

func (m *RuntimeUpdateResponse) MarshalVT() (dAtA []byte, err error)

func (*RuntimeUpdateResponse) ProtoMessage 

func (*RuntimeUpdateResponse) ProtoMessage()

func (*RuntimeUpdateResponse) ProtoReflect 

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

func (*RuntimeUpdateResponse) Reset 

func (x *RuntimeUpdateResponse) Reset()

func (*RuntimeUpdateResponse) SizeVT 

func (m *RuntimeUpdateResponse) SizeVT() (n int)

func (*RuntimeUpdateResponse) String 

func (x *RuntimeUpdateResponse) String() string

func (*RuntimeUpdateResponse) UnmarshalVT 

func (m *RuntimeUpdateResponse) UnmarshalVT(dAtA []byte) error

type RuntimeWatchForRequest 

type RuntimeWatchForRequest struct {
	ControllerToken string                    `protobuf:"bytes,1,opt,name=controller_token,json=controllerToken,proto3" json:"controller_token,omitempty"`
	Namespace       string                    `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Type            string                    `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
	Id              string                    `protobuf:"bytes,4,opt,name=id,proto3" json:"id,omitempty"`
	FinalizersEmpty *ConditionFinalizersEmpty `protobuf:"bytes,5,opt,name=finalizers_empty,json=finalizersEmpty,proto3" json:"finalizers_empty,omitempty"`
	// contains filtered or unexported fields
}

func (*RuntimeWatchForRequest) Descriptor deprecated 

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

Deprecated: Use RuntimeWatchForRequest.ProtoReflect.Descriptor instead.

func (*RuntimeWatchForRequest) EqualMessageVT added in v0.3.0 

func (this *RuntimeWatchForRequest) EqualMessageVT(thatMsg proto.Message) bool

func (*RuntimeWatchForRequest) EqualVT added in v0.3.0 

func (this *RuntimeWatchForRequest) EqualVT(that *RuntimeWatchForRequest) bool

func (*RuntimeWatchForRequest) GetControllerToken 

func (x *RuntimeWatchForRequest) GetControllerToken() string

func (*RuntimeWatchForRequest) GetFinalizersEmpty 

func (x *RuntimeWatchForRequest) GetFinalizersEmpty() *ConditionFinalizersEmpty

func (*RuntimeWatchForRequest) GetId 

func (x *RuntimeWatchForRequest) GetId() string

func (*RuntimeWatchForRequest) GetNamespace 

func (x *RuntimeWatchForRequest) GetNamespace() string

func (*RuntimeWatchForRequest) GetType 

func (x *RuntimeWatchForRequest) GetType() string

func (*RuntimeWatchForRequest) MarshalToSizedBufferVT 

func (m *RuntimeWatchForRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*RuntimeWatchForRequest) MarshalToVT 

func (m *RuntimeWatchForRequest) MarshalToVT(dAtA []byte) (int, error)

func (*RuntimeWatchForRequest) MarshalVT 

func (m *RuntimeWatchForRequest) MarshalVT() (dAtA []byte, err error)

func (*RuntimeWatchForRequest) ProtoMessage 

func (*RuntimeWatchForRequest) ProtoMessage()

func (*RuntimeWatchForRequest) ProtoReflect 

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

func (*RuntimeWatchForRequest) Reset 

func (x *RuntimeWatchForRequest) Reset()

func (*RuntimeWatchForRequest) SizeVT 

func (m *RuntimeWatchForRequest) SizeVT() (n int)

func (*RuntimeWatchForRequest) String 

func (x *RuntimeWatchForRequest) String() string

func (*RuntimeWatchForRequest) UnmarshalVT 

func (m *RuntimeWatchForRequest) UnmarshalVT(dAtA []byte) error

type RuntimeWatchForResponse 

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

func (*RuntimeWatchForResponse) Descriptor deprecated 

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

Deprecated: Use RuntimeWatchForResponse.ProtoReflect.Descriptor instead.

func (*RuntimeWatchForResponse) EqualMessageVT added in v0.3.0 

func (this *RuntimeWatchForResponse) EqualMessageVT(thatMsg proto.Message) bool

func (*RuntimeWatchForResponse) EqualVT added in v0.3.0 

func (this *RuntimeWatchForResponse) EqualVT(that *RuntimeWatchForResponse) bool

func (*RuntimeWatchForResponse) GetResource 

func (x *RuntimeWatchForResponse) GetResource() *Resource

func (*RuntimeWatchForResponse) MarshalToSizedBufferVT 

func (m *RuntimeWatchForResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*RuntimeWatchForResponse) MarshalToVT 

func (m *RuntimeWatchForResponse) MarshalToVT(dAtA []byte) (int, error)

func (*RuntimeWatchForResponse) MarshalVT 

func (m *RuntimeWatchForResponse) MarshalVT() (dAtA []byte, err error)

func (*RuntimeWatchForResponse) ProtoMessage 

func (*RuntimeWatchForResponse) ProtoMessage()

func (*RuntimeWatchForResponse) ProtoReflect 

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

func (*RuntimeWatchForResponse) Reset 

func (x *RuntimeWatchForResponse) Reset()

func (*RuntimeWatchForResponse) SizeVT 

func (m *RuntimeWatchForResponse) SizeVT() (n int)

func (*RuntimeWatchForResponse) String 

func (x *RuntimeWatchForResponse) String() string

func (*RuntimeWatchForResponse) UnmarshalVT 

func (m *RuntimeWatchForResponse) UnmarshalVT(dAtA []byte) error

type Spec 

type Spec struct {

	// Protobuf-serialized representation of the resource.
	ProtoSpec []byte `protobuf:"bytes,1,opt,name=proto_spec,json=protoSpec,proto3" json:"proto_spec,omitempty"`
	// YAML representation of the spec (optional).
	YamlSpec string `protobuf:"bytes,2,opt,name=yaml_spec,json=yamlSpec,proto3" json:"yaml_spec,omitempty"`
	// contains filtered or unexported fields
}

Spec defines content of the resource.

func (*Spec) Descriptor deprecated 

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

Deprecated: Use Spec.ProtoReflect.Descriptor instead.

func (*Spec) EqualMessageVT added in v0.3.0 

func (this *Spec) EqualMessageVT(thatMsg proto.Message) bool

func (*Spec) EqualVT added in v0.3.0 

func (this *Spec) EqualVT(that *Spec) bool

func (*Spec) GetProtoSpec 

func (x *Spec) GetProtoSpec() []byte

func (*Spec) GetYamlSpec 

func (x *Spec) GetYamlSpec() string

func (*Spec) MarshalToSizedBufferVT 

func (m *Spec) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Spec) MarshalToVT 

func (m *Spec) MarshalToVT(dAtA []byte) (int, error)

func (*Spec) MarshalVT 

func (m *Spec) MarshalVT() (dAtA []byte, err error)

func (*Spec) ProtoMessage 

func (*Spec) ProtoMessage()

func (*Spec) ProtoReflect 

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

func (*Spec) Reset 

func (x *Spec) Reset()

func (*Spec) SizeVT 

func (m *Spec) SizeVT() (n int)

func (*Spec) String 

func (x *Spec) String() string

func (*Spec) UnmarshalVT 

func (m *Spec) UnmarshalVT(dAtA []byte) error

type StartRequest 

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

func (*StartRequest) Descriptor deprecated 

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

Deprecated: Use StartRequest.ProtoReflect.Descriptor instead.

func (*StartRequest) EqualMessageVT added in v0.3.0 

func (this *StartRequest) EqualMessageVT(thatMsg proto.Message) bool

func (*StartRequest) EqualVT added in v0.3.0 

func (this *StartRequest) EqualVT(that *StartRequest) bool

func (*StartRequest) MarshalToSizedBufferVT 

func (m *StartRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*StartRequest) MarshalToVT 

func (m *StartRequest) MarshalToVT(dAtA []byte) (int, error)

func (*StartRequest) MarshalVT 

func (m *StartRequest) MarshalVT() (dAtA []byte, err error)

func (*StartRequest) ProtoMessage 

func (*StartRequest) ProtoMessage()

func (*StartRequest) ProtoReflect 

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

func (*StartRequest) Reset 

func (x *StartRequest) Reset()

func (*StartRequest) SizeVT 

func (m *StartRequest) SizeVT() (n int)

func (*StartRequest) String 

func (x *StartRequest) String() string

func (*StartRequest) UnmarshalVT 

func (m *StartRequest) UnmarshalVT(dAtA []byte) error

type StartResponse 

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

func (*StartResponse) Descriptor deprecated 

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

Deprecated: Use StartResponse.ProtoReflect.Descriptor instead.

func (*StartResponse) EqualMessageVT added in v0.3.0 

func (this *StartResponse) EqualMessageVT(thatMsg proto.Message) bool

func (*StartResponse) EqualVT added in v0.3.0 

func (this *StartResponse) EqualVT(that *StartResponse) bool

func (*StartResponse) MarshalToSizedBufferVT 

func (m *StartResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*StartResponse) MarshalToVT 

func (m *StartResponse) MarshalToVT(dAtA []byte) (int, error)

func (*StartResponse) MarshalVT 

func (m *StartResponse) MarshalVT() (dAtA []byte, err error)

func (*StartResponse) ProtoMessage 

func (*StartResponse) ProtoMessage()

func (*StartResponse) ProtoReflect 

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

func (*StartResponse) Reset 

func (x *StartResponse) Reset()

func (*StartResponse) SizeVT 

func (m *StartResponse) SizeVT() (n int)

func (*StartResponse) String 

func (x *StartResponse) String() string

func (*StartResponse) UnmarshalVT 

func (m *StartResponse) UnmarshalVT(dAtA []byte) error

type StateClient 

type StateClient interface {
	// Get a resource by type and ID.
	//
	// If a resource is not found, error is returned.
	Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error)
	// List resources by type.
	List(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (State_ListClient, error)
	// Create a resource.
	//
	// If a resource already exists, Create returns an error.
	Create(ctx context.Context, in *CreateRequest, opts ...grpc.CallOption) (*CreateResponse, error)
	// Update a resource.
	//
	// If a resource doesn't exist, error is returned.
	// On update current version of resource `new` in the state should match
	// curVersion, otherwise conflict error is returned.
	Update(ctx context.Context, in *UpdateRequest, opts ...grpc.CallOption) (*UpdateResponse, error)
	// Destroy a resource.
	//
	// If a resource doesn't exist, error is returned.
	// If a resource has pending finalizers, error is returned.
	Destroy(ctx context.Context, in *DestroyRequest, opts ...grpc.CallOption) (*DestroyResponse, error)
	// Watch state of a resource by (namespace, type) or a specific resource by (namespace, type, id).
	//
	// It's fine to watch for a resource which doesn't exist yet.
	// Watch is canceled when context gets canceled.
	// Watch sends initial resource state as the very first event on the channel,
	// and then sends any updates to the resource as events.
	Watch(ctx context.Context, in *WatchRequest, opts ...grpc.CallOption) (State_WatchClient, error)
}

StateClient is the client API for State 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 NewStateClient 

func NewStateClient(cc grpc.ClientConnInterface) StateClient

type StateServer 

type StateServer interface {
	// Get a resource by type and ID.
	//
	// If a resource is not found, error is returned.
	Get(context.Context, *GetRequest) (*GetResponse, error)
	// List resources by type.
	List(*ListRequest, State_ListServer) error
	// Create a resource.
	//
	// If a resource already exists, Create returns an error.
	Create(context.Context, *CreateRequest) (*CreateResponse, error)
	// Update a resource.
	//
	// If a resource doesn't exist, error is returned.
	// On update current version of resource `new` in the state should match
	// curVersion, otherwise conflict error is returned.
	Update(context.Context, *UpdateRequest) (*UpdateResponse, error)
	// Destroy a resource.
	//
	// If a resource doesn't exist, error is returned.
	// If a resource has pending finalizers, error is returned.
	Destroy(context.Context, *DestroyRequest) (*DestroyResponse, error)
	// Watch state of a resource by (namespace, type) or a specific resource by (namespace, type, id).
	//
	// It's fine to watch for a resource which doesn't exist yet.
	// Watch is canceled when context gets canceled.
	// Watch sends initial resource state as the very first event on the channel,
	// and then sends any updates to the resource as events.
	Watch(*WatchRequest, State_WatchServer) error
	// contains filtered or unexported methods
}

StateServer is the server API for State service. All implementations must embed UnimplementedStateServer for forward compatibility

type State_ListClient 

type State_ListClient interface {
	Recv() (*ListResponse, error)
	grpc.ClientStream
}

type State_ListServer 

type State_ListServer interface {
	Send(*ListResponse) error
	grpc.ServerStream
}

type State_WatchClient 

type State_WatchClient interface {
	Recv() (*WatchResponse, error)
	grpc.ClientStream
}

type State_WatchServer 

type State_WatchServer interface {
	Send(*WatchResponse) error
	grpc.ServerStream
}

type StopRequest 

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

func (*StopRequest) Descriptor deprecated 

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

Deprecated: Use StopRequest.ProtoReflect.Descriptor instead.

func (*StopRequest) EqualMessageVT added in v0.3.0 

func (this *StopRequest) EqualMessageVT(thatMsg proto.Message) bool

func (*StopRequest) EqualVT added in v0.3.0 

func (this *StopRequest) EqualVT(that *StopRequest) bool

func (*StopRequest) MarshalToSizedBufferVT 

func (m *StopRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*StopRequest) MarshalToVT 

func (m *StopRequest) MarshalToVT(dAtA []byte) (int, error)

func (*StopRequest) MarshalVT 

func (m *StopRequest) MarshalVT() (dAtA []byte, err error)

func (*StopRequest) ProtoMessage 

func (*StopRequest) ProtoMessage()

func (*StopRequest) ProtoReflect 

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

func (*StopRequest) Reset 

func (x *StopRequest) Reset()

func (*StopRequest) SizeVT 

func (m *StopRequest) SizeVT() (n int)

func (*StopRequest) String 

func (x *StopRequest) String() string

func (*StopRequest) UnmarshalVT 

func (m *StopRequest) UnmarshalVT(dAtA []byte) error

type StopResponse 

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

func (*StopResponse) Descriptor deprecated 

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

Deprecated: Use StopResponse.ProtoReflect.Descriptor instead.

func (*StopResponse) EqualMessageVT added in v0.3.0 

func (this *StopResponse) EqualMessageVT(thatMsg proto.Message) bool

func (*StopResponse) EqualVT added in v0.3.0 

func (this *StopResponse) EqualVT(that *StopResponse) bool

func (*StopResponse) MarshalToSizedBufferVT 

func (m *StopResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*StopResponse) MarshalToVT 

func (m *StopResponse) MarshalToVT(dAtA []byte) (int, error)

func (*StopResponse) MarshalVT 

func (m *StopResponse) MarshalVT() (dAtA []byte, err error)

func (*StopResponse) ProtoMessage 

func (*StopResponse) ProtoMessage()

func (*StopResponse) ProtoReflect 

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

func (*StopResponse) Reset 

func (x *StopResponse) Reset()

func (*StopResponse) SizeVT 

func (m *StopResponse) SizeVT() (n int)

func (*StopResponse) String 

func (x *StopResponse) String() string

func (*StopResponse) UnmarshalVT 

func (m *StopResponse) UnmarshalVT(dAtA []byte) error

type UnimplementedControllerAdapterServer 

type UnimplementedControllerAdapterServer struct {
}

UnimplementedControllerAdapterServer must be embedded to have forward compatible implementations.

func (UnimplementedControllerAdapterServer) AddFinalizer 

func (UnimplementedControllerAdapterServer) AddFinalizer(context.Context, *RuntimeAddFinalizerRequest) (*RuntimeAddFinalizerResponse, error)

func (UnimplementedControllerAdapterServer) Create 

func (UnimplementedControllerAdapterServer) Create(context.Context, *RuntimeCreateRequest) (*RuntimeCreateResponse, error)

func (UnimplementedControllerAdapterServer) Destroy 

func (UnimplementedControllerAdapterServer) Destroy(context.Context, *RuntimeDestroyRequest) (*RuntimeDestroyResponse, error)

func (UnimplementedControllerAdapterServer) Get 

func (UnimplementedControllerAdapterServer) Get(context.Context, *RuntimeGetRequest) (*RuntimeGetResponse, error)

func (UnimplementedControllerAdapterServer) List 

func (UnimplementedControllerAdapterServer) List(*RuntimeListRequest, ControllerAdapter_ListServer) error

func (UnimplementedControllerAdapterServer) QueueReconcile 

func (UnimplementedControllerAdapterServer) QueueReconcile(context.Context, *QueueReconcileRequest) (*QueueReconcileResponse, error)

func (UnimplementedControllerAdapterServer) ReconcileEvents 

func (UnimplementedControllerAdapterServer) ReconcileEvents(*ReconcileEventsRequest, ControllerAdapter_ReconcileEventsServer) error

func (UnimplementedControllerAdapterServer) RemoveFinalizer 

func (UnimplementedControllerAdapterServer) RemoveFinalizer(context.Context, *RuntimeRemoveFinalizerRequest) (*RuntimeRemoveFinalizerResponse, error)

func (UnimplementedControllerAdapterServer) Teardown 

func (UnimplementedControllerAdapterServer) Teardown(context.Context, *RuntimeTeardownRequest) (*RuntimeTeardownResponse, error)

func (UnimplementedControllerAdapterServer) Update 

func (UnimplementedControllerAdapterServer) Update(context.Context, *RuntimeUpdateRequest) (*RuntimeUpdateResponse, error)

func (UnimplementedControllerAdapterServer) UpdateInputs 

func (UnimplementedControllerAdapterServer) UpdateInputs(context.Context, *UpdateInputsRequest) (*UpdateInputsResponse, error)

func (UnimplementedControllerAdapterServer) WatchFor 

func (UnimplementedControllerAdapterServer) WatchFor(context.Context, *RuntimeWatchForRequest) (*RuntimeWatchForResponse, error)

type UnimplementedControllerRuntimeServer 

type UnimplementedControllerRuntimeServer struct {
}

UnimplementedControllerRuntimeServer must be embedded to have forward compatible implementations.

func (UnimplementedControllerRuntimeServer) RegisterController 

func (UnimplementedControllerRuntimeServer) RegisterController(context.Context, *RegisterControllerRequest) (*RegisterControllerResponse, error)

func (UnimplementedControllerRuntimeServer) Start 

func (UnimplementedControllerRuntimeServer) Start(context.Context, *StartRequest) (*StartResponse, error)

func (UnimplementedControllerRuntimeServer) Stop 

func (UnimplementedControllerRuntimeServer) Stop(context.Context, *StopRequest) (*StopResponse, error)

type UnimplementedStateServer 

type UnimplementedStateServer struct {
}

UnimplementedStateServer must be embedded to have forward compatible implementations.

func (UnimplementedStateServer) Create 

func (UnimplementedStateServer) Create(context.Context, *CreateRequest) (*CreateResponse, error)

func (UnimplementedStateServer) Destroy 

func (UnimplementedStateServer) Destroy(context.Context, *DestroyRequest) (*DestroyResponse, error)

func (UnimplementedStateServer) Get 

func (UnimplementedStateServer) Get(context.Context, *GetRequest) (*GetResponse, error)

func (UnimplementedStateServer) List 

func (UnimplementedStateServer) List(*ListRequest, State_ListServer) error

func (UnimplementedStateServer) Update 

func (UnimplementedStateServer) Update(context.Context, *UpdateRequest) (*UpdateResponse, error)

func (UnimplementedStateServer) Watch 

func (UnimplementedStateServer) Watch(*WatchRequest, State_WatchServer) error

type UnsafeControllerAdapterServer 

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

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

type UnsafeControllerRuntimeServer 

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

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

type UnsafeStateServer 

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

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

type UpdateInputsRequest 

type UpdateInputsRequest struct {
	ControllerToken string             `protobuf:"bytes,1,opt,name=controller_token,json=controllerToken,proto3" json:"controller_token,omitempty"`
	Inputs          []*ControllerInput `protobuf:"bytes,2,rep,name=inputs,proto3" json:"inputs,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateInputsRequest) Descriptor deprecated 

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

Deprecated: Use UpdateInputsRequest.ProtoReflect.Descriptor instead.

func (*UpdateInputsRequest) EqualMessageVT added in v0.3.0 

func (this *UpdateInputsRequest) EqualMessageVT(thatMsg proto.Message) bool

func (*UpdateInputsRequest) EqualVT added in v0.3.0 

func (this *UpdateInputsRequest) EqualVT(that *UpdateInputsRequest) bool

func (*UpdateInputsRequest) GetControllerToken 

func (x *UpdateInputsRequest) GetControllerToken() string

func (*UpdateInputsRequest) GetInputs 

func (x *UpdateInputsRequest) GetInputs() []*ControllerInput

func (*UpdateInputsRequest) MarshalToSizedBufferVT 

func (m *UpdateInputsRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*UpdateInputsRequest) MarshalToVT 

func (m *UpdateInputsRequest) MarshalToVT(dAtA []byte) (int, error)

func (*UpdateInputsRequest) MarshalVT 

func (m *UpdateInputsRequest) MarshalVT() (dAtA []byte, err error)

func (*UpdateInputsRequest) ProtoMessage 

func (*UpdateInputsRequest) ProtoMessage()

func (*UpdateInputsRequest) ProtoReflect 

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

func (*UpdateInputsRequest) Reset 

func (x *UpdateInputsRequest) Reset()

func (*UpdateInputsRequest) SizeVT 

func (m *UpdateInputsRequest) SizeVT() (n int)

func (*UpdateInputsRequest) String 

func (x *UpdateInputsRequest) String() string

func (*UpdateInputsRequest) UnmarshalVT 

func (m *UpdateInputsRequest) UnmarshalVT(dAtA []byte) error

type UpdateInputsResponse 

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

func (*UpdateInputsResponse) Descriptor deprecated 

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

Deprecated: Use UpdateInputsResponse.ProtoReflect.Descriptor instead.

func (*UpdateInputsResponse) EqualMessageVT added in v0.3.0 

func (this *UpdateInputsResponse) EqualMessageVT(thatMsg proto.Message) bool

func (*UpdateInputsResponse) EqualVT added in v0.3.0 

func (this *UpdateInputsResponse) EqualVT(that *UpdateInputsResponse) bool

func (*UpdateInputsResponse) MarshalToSizedBufferVT 

func (m *UpdateInputsResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*UpdateInputsResponse) MarshalToVT 

func (m *UpdateInputsResponse) MarshalToVT(dAtA []byte) (int, error)

func (*UpdateInputsResponse) MarshalVT 

func (m *UpdateInputsResponse) MarshalVT() (dAtA []byte, err error)

func (*UpdateInputsResponse) ProtoMessage 

func (*UpdateInputsResponse) ProtoMessage()

func (*UpdateInputsResponse) ProtoReflect 

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

func (*UpdateInputsResponse) Reset 

func (x *UpdateInputsResponse) Reset()

func (*UpdateInputsResponse) SizeVT 

func (m *UpdateInputsResponse) SizeVT() (n int)

func (*UpdateInputsResponse) String 

func (x *UpdateInputsResponse) String() string

func (*UpdateInputsResponse) UnmarshalVT 

func (m *UpdateInputsResponse) UnmarshalVT(dAtA []byte) error

type UpdateOptions 

type UpdateOptions struct {
	Owner         string  `protobuf:"bytes,1,opt,name=owner,proto3" json:"owner,omitempty"`
	ExpectedPhase *string `protobuf:"bytes,2,opt,name=expected_phase,json=expectedPhase,proto3,oneof" json:"expected_phase,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateOptions) Descriptor deprecated 

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

Deprecated: Use UpdateOptions.ProtoReflect.Descriptor instead.

func (*UpdateOptions) EqualMessageVT added in v0.3.0 

func (this *UpdateOptions) EqualMessageVT(thatMsg proto.Message) bool

func (*UpdateOptions) EqualVT added in v0.3.0 

func (this *UpdateOptions) EqualVT(that *UpdateOptions) bool

func (*UpdateOptions) GetExpectedPhase 

func (x *UpdateOptions) GetExpectedPhase() string

func (*UpdateOptions) GetOwner 

func (x *UpdateOptions) GetOwner() string

func (*UpdateOptions) MarshalToSizedBufferVT 

func (m *UpdateOptions) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*UpdateOptions) MarshalToVT 

func (m *UpdateOptions) MarshalToVT(dAtA []byte) (int, error)

func (*UpdateOptions) MarshalVT 

func (m *UpdateOptions) MarshalVT() (dAtA []byte, err error)

func (*UpdateOptions) ProtoMessage 

func (*UpdateOptions) ProtoMessage()

func (*UpdateOptions) ProtoReflect 

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

func (*UpdateOptions) Reset 

func (x *UpdateOptions) Reset()

func (*UpdateOptions) SizeVT 

func (m *UpdateOptions) SizeVT() (n int)

func (*UpdateOptions) String 

func (x *UpdateOptions) String() string

func (*UpdateOptions) UnmarshalVT 

func (m *UpdateOptions) UnmarshalVT(dAtA []byte) error

type UpdateRequest 

type UpdateRequest struct {
	NewResource *Resource      `protobuf:"bytes,2,opt,name=new_resource,json=newResource,proto3" json:"new_resource,omitempty"`
	Options     *UpdateOptions `protobuf:"bytes,3,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateRequest) Descriptor deprecated 

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

Deprecated: Use UpdateRequest.ProtoReflect.Descriptor instead.

func (*UpdateRequest) EqualMessageVT added in v0.3.0 

func (this *UpdateRequest) EqualMessageVT(thatMsg proto.Message) bool

func (*UpdateRequest) EqualVT added in v0.3.0 

func (this *UpdateRequest) EqualVT(that *UpdateRequest) bool

func (*UpdateRequest) GetNewResource 

func (x *UpdateRequest) GetNewResource() *Resource

func (*UpdateRequest) GetOptions 

func (x *UpdateRequest) GetOptions() *UpdateOptions

func (*UpdateRequest) MarshalToSizedBufferVT 

func (m *UpdateRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*UpdateRequest) MarshalToVT 

func (m *UpdateRequest) MarshalToVT(dAtA []byte) (int, error)

func (*UpdateRequest) MarshalVT 

func (m *UpdateRequest) MarshalVT() (dAtA []byte, err error)

func (*UpdateRequest) ProtoMessage 

func (*UpdateRequest) ProtoMessage()

func (*UpdateRequest) ProtoReflect 

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

func (*UpdateRequest) Reset 

func (x *UpdateRequest) Reset()

func (*UpdateRequest) SizeVT 

func (m *UpdateRequest) SizeVT() (n int)

func (*UpdateRequest) String 

func (x *UpdateRequest) String() string

func (*UpdateRequest) UnmarshalVT 

func (m *UpdateRequest) UnmarshalVT(dAtA []byte) error

type UpdateResponse 

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

func (*UpdateResponse) Descriptor deprecated 

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

Deprecated: Use UpdateResponse.ProtoReflect.Descriptor instead.

func (*UpdateResponse) EqualMessageVT added in v0.3.0 

func (this *UpdateResponse) EqualMessageVT(thatMsg proto.Message) bool

func (*UpdateResponse) EqualVT added in v0.3.0 

func (this *UpdateResponse) EqualVT(that *UpdateResponse) bool

func (*UpdateResponse) GetResource added in v0.2.0 

func (x *UpdateResponse) GetResource() *Resource

func (*UpdateResponse) MarshalToSizedBufferVT 

func (m *UpdateResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*UpdateResponse) MarshalToVT 

func (m *UpdateResponse) MarshalToVT(dAtA []byte) (int, error)

func (*UpdateResponse) MarshalVT 

func (m *UpdateResponse) MarshalVT() (dAtA []byte, err error)

func (*UpdateResponse) ProtoMessage 

func (*UpdateResponse) ProtoMessage()

func (*UpdateResponse) ProtoReflect 

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

func (*UpdateResponse) Reset 

func (x *UpdateResponse) Reset()

func (*UpdateResponse) SizeVT 

func (m *UpdateResponse) SizeVT() (n int)

func (*UpdateResponse) String 

func (x *UpdateResponse) String() string

func (*UpdateResponse) UnmarshalVT 

func (m *UpdateResponse) UnmarshalVT(dAtA []byte) error

type WatchOptions 

type WatchOptions struct {
	BootstrapContents bool        `protobuf:"varint,1,opt,name=bootstrap_contents,json=bootstrapContents,proto3" json:"bootstrap_contents,omitempty"`
	TailEvents        int32       `protobuf:"varint,2,opt,name=tail_events,json=tailEvents,proto3" json:"tail_events,omitempty"`
	LabelQuery        *LabelQuery `protobuf:"bytes,3,opt,name=label_query,json=labelQuery,proto3" json:"label_query,omitempty"`
	IdQuery           *IDQuery    `protobuf:"bytes,4,opt,name=id_query,json=idQuery,proto3" json:"id_query,omitempty"`
	// contains filtered or unexported fields
}

func (*WatchOptions) Descriptor deprecated 

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

Deprecated: Use WatchOptions.ProtoReflect.Descriptor instead.

func (*WatchOptions) EqualMessageVT added in v0.3.0 

func (this *WatchOptions) EqualMessageVT(thatMsg proto.Message) bool

func (*WatchOptions) EqualVT added in v0.3.0 

func (this *WatchOptions) EqualVT(that *WatchOptions) bool

func (*WatchOptions) GetBootstrapContents 

func (x *WatchOptions) GetBootstrapContents() bool

func (*WatchOptions) GetIdQuery added in v0.3.0 

func (x *WatchOptions) GetIdQuery() *IDQuery

func (*WatchOptions) GetLabelQuery 

func (x *WatchOptions) GetLabelQuery() *LabelQuery

func (*WatchOptions) GetTailEvents 

func (x *WatchOptions) GetTailEvents() int32

func (*WatchOptions) MarshalToSizedBufferVT 

func (m *WatchOptions) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*WatchOptions) MarshalToVT 

func (m *WatchOptions) MarshalToVT(dAtA []byte) (int, error)

func (*WatchOptions) MarshalVT 

func (m *WatchOptions) MarshalVT() (dAtA []byte, err error)

func (*WatchOptions) ProtoMessage 

func (*WatchOptions) ProtoMessage()

func (*WatchOptions) ProtoReflect 

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

func (*WatchOptions) Reset 

func (x *WatchOptions) Reset()

func (*WatchOptions) SizeVT 

func (m *WatchOptions) SizeVT() (n int)

func (*WatchOptions) String 

func (x *WatchOptions) String() string

func (*WatchOptions) UnmarshalVT 

func (m *WatchOptions) UnmarshalVT(dAtA []byte) error

type WatchRequest 

type WatchRequest struct {
	Namespace string        `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Type      string        `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	Id        *string       `protobuf:"bytes,3,opt,name=id,proto3,oneof" json:"id,omitempty"`
	Options   *WatchOptions `protobuf:"bytes,4,opt,name=options,proto3" json:"options,omitempty"`
	// Supported API versions:
	// 0 (not set): event types Created,Updated,Deleted
	// 1: additional event types Bootstrapped,Errored
	ApiVersion int32 `protobuf:"varint,5,opt,name=api_version,json=apiVersion,proto3" json:"api_version,omitempty"`
	// contains filtered or unexported fields
}

func (*WatchRequest) Descriptor deprecated 

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

Deprecated: Use WatchRequest.ProtoReflect.Descriptor instead.

func (*WatchRequest) EqualMessageVT added in v0.3.0 

func (this *WatchRequest) EqualMessageVT(thatMsg proto.Message) bool

func (*WatchRequest) EqualVT added in v0.3.0 

func (this *WatchRequest) EqualVT(that *WatchRequest) bool

func (*WatchRequest) GetApiVersion added in v0.2.0 

func (x *WatchRequest) GetApiVersion() int32

func (*WatchRequest) GetId 

func (x *WatchRequest) GetId() string

func (*WatchRequest) GetNamespace 

func (x *WatchRequest) GetNamespace() string

func (*WatchRequest) GetOptions 

func (x *WatchRequest) GetOptions() *WatchOptions

func (*WatchRequest) GetType 

func (x *WatchRequest) GetType() string

func (*WatchRequest) MarshalToSizedBufferVT 

func (m *WatchRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*WatchRequest) MarshalToVT 

func (m *WatchRequest) MarshalToVT(dAtA []byte) (int, error)

func (*WatchRequest) MarshalVT 

func (m *WatchRequest) MarshalVT() (dAtA []byte, err error)

func (*WatchRequest) ProtoMessage 

func (*WatchRequest) ProtoMessage()

func (*WatchRequest) ProtoReflect 

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

func (*WatchRequest) Reset 

func (x *WatchRequest) Reset()

func (*WatchRequest) SizeVT 

func (m *WatchRequest) SizeVT() (n int)

func (*WatchRequest) String 

func (x *WatchRequest) String() string

func (*WatchRequest) UnmarshalVT 

func (m *WatchRequest) UnmarshalVT(dAtA []byte) error

type WatchResponse 

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

func (*WatchResponse) Descriptor deprecated 

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

Deprecated: Use WatchResponse.ProtoReflect.Descriptor instead.

func (*WatchResponse) EqualMessageVT added in v0.3.0 

func (this *WatchResponse) EqualMessageVT(thatMsg proto.Message) bool

func (*WatchResponse) EqualVT added in v0.3.0 

func (this *WatchResponse) EqualVT(that *WatchResponse) bool

func (*WatchResponse) GetEvent 

func (x *WatchResponse) GetEvent() *Event

func (*WatchResponse) MarshalToSizedBufferVT 

func (m *WatchResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*WatchResponse) MarshalToVT 

func (m *WatchResponse) MarshalToVT(dAtA []byte) (int, error)

func (*WatchResponse) MarshalVT 

func (m *WatchResponse) MarshalVT() (dAtA []byte, err error)

func (*WatchResponse) ProtoMessage 

func (*WatchResponse) ProtoMessage()

func (*WatchResponse) ProtoReflect 

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

func (*WatchResponse) Reset 

func (x *WatchResponse) Reset()

func (*WatchResponse) SizeVT 

func (m *WatchResponse) SizeVT() (n int)

func (*WatchResponse) String 

func (x *WatchResponse) String() string

func (*WatchResponse) UnmarshalVT 

func (m *WatchResponse) UnmarshalVT(dAtA []byte) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.