v1alpha1

package
v0.3.10 Latest Latest
Warning

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

Go to latest
Published: Sep 28, 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

View Source
const (
	ControllerRuntime_RegisterController_FullMethodName = "/cosi.runtime.ControllerRuntime/RegisterController"
	ControllerRuntime_Start_FullMethodName              = "/cosi.runtime.ControllerRuntime/Start"
	ControllerRuntime_Stop_FullMethodName               = "/cosi.runtime.ControllerRuntime/Stop"
)
View Source
const (
	ControllerAdapter_ReconcileEvents_FullMethodName = "/cosi.runtime.ControllerAdapter/ReconcileEvents"
	ControllerAdapter_QueueReconcile_FullMethodName  = "/cosi.runtime.ControllerAdapter/QueueReconcile"
	ControllerAdapter_UpdateInputs_FullMethodName    = "/cosi.runtime.ControllerAdapter/UpdateInputs"
	ControllerAdapter_Get_FullMethodName             = "/cosi.runtime.ControllerAdapter/Get"
	ControllerAdapter_List_FullMethodName            = "/cosi.runtime.ControllerAdapter/List"
	ControllerAdapter_WatchFor_FullMethodName        = "/cosi.runtime.ControllerAdapter/WatchFor"
	ControllerAdapter_Create_FullMethodName          = "/cosi.runtime.ControllerAdapter/Create"
	ControllerAdapter_Update_FullMethodName          = "/cosi.runtime.ControllerAdapter/Update"
	ControllerAdapter_Teardown_FullMethodName        = "/cosi.runtime.ControllerAdapter/Teardown"
	ControllerAdapter_Destroy_FullMethodName         = "/cosi.runtime.ControllerAdapter/Destroy"
	ControllerAdapter_AddFinalizer_FullMethodName    = "/cosi.runtime.ControllerAdapter/AddFinalizer"
	ControllerAdapter_RemoveFinalizer_FullMethodName = "/cosi.runtime.ControllerAdapter/RemoveFinalizer"
)
View Source
const (
	State_Get_FullMethodName     = "/cosi.resource.State/Get"
	State_List_FullMethodName    = "/cosi.resource.State/List"
	State_Create_FullMethodName  = "/cosi.resource.State/Create"
	State_Update_FullMethodName  = "/cosi.resource.State/Update"
	State_Destroy_FullMethodName = "/cosi.resource.State/Destroy"
	State_Watch_FullMethodName   = "/cosi.resource.State/Watch"
)

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",
		3: "IN",
		4: "LT",
		5: "LTE",
		6: "LT_NUMERIC",
		7: "LTE_NUMERIC",
	}
	LabelTerm_Operation_value = map[string]int32{
		"EXISTS":      0,
		"EQUAL":       1,
		"NOT_EXISTS":  2,
		"IN":          3,
		"LT":          4,
		"LTE":         5,
		"LT_NUMERIC":  6,
		"LTE_NUMERIC": 7,
	}
)

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) CloneMessageVT added in v0.3.1

func (m *ConditionFinalizersEmpty) CloneMessageVT() proto.Message

func (*ConditionFinalizersEmpty) CloneVT added in v0.3.1

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 (*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.

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) CloneMessageVT added in v0.3.1

func (m *ControllerInput) CloneMessageVT() proto.Message

func (*ControllerInput) CloneVT added in v0.3.1

func (m *ControllerInput) CloneVT() *ControllerInput

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) Enum

func (ControllerInputKind) EnumDescriptor deprecated

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

Deprecated: Use ControllerInputKind.Descriptor instead.

func (ControllerInputKind) Number

func (ControllerInputKind) String

func (x ControllerInputKind) String() string

func (ControllerInputKind) Type

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) CloneMessageVT added in v0.3.1

func (m *ControllerOutput) CloneMessageVT() proto.Message

func (*ControllerOutput) CloneVT added in v0.3.1

func (m *ControllerOutput) CloneVT() *ControllerOutput

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 (*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) Enum

func (ControllerOutputKind) EnumDescriptor deprecated

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

Deprecated: Use ControllerOutputKind.Descriptor instead.

func (ControllerOutputKind) Number

func (ControllerOutputKind) String

func (x ControllerOutputKind) String() string

func (ControllerOutputKind) Type

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.

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) CloneMessageVT added in v0.3.1

func (m *CreateOptions) CloneMessageVT() proto.Message

func (*CreateOptions) CloneVT added in v0.3.1

func (m *CreateOptions) CloneVT() *CreateOptions

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) CloneMessageVT added in v0.3.1

func (m *CreateRequest) CloneMessageVT() proto.Message

func (*CreateRequest) CloneVT added in v0.3.1

func (m *CreateRequest) CloneVT() *CreateRequest

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) CloneMessageVT added in v0.3.1

func (m *CreateResponse) CloneMessageVT() proto.Message

func (*CreateResponse) CloneVT added in v0.3.1

func (m *CreateResponse) CloneVT() *CreateResponse

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) CloneMessageVT added in v0.3.1

func (m *DestroyOptions) CloneMessageVT() proto.Message

func (*DestroyOptions) CloneVT added in v0.3.1

func (m *DestroyOptions) CloneVT() *DestroyOptions

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) CloneMessageVT added in v0.3.1

func (m *DestroyRequest) CloneMessageVT() proto.Message

func (*DestroyRequest) CloneVT added in v0.3.1

func (m *DestroyRequest) CloneVT() *DestroyRequest

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) CloneMessageVT added in v0.3.1

func (m *DestroyResponse) CloneMessageVT() proto.Message

func (*DestroyResponse) CloneVT added in v0.3.1

func (m *DestroyResponse) CloneVT() *DestroyResponse

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) CloneMessageVT added in v0.3.1

func (m *Event) CloneMessageVT() proto.Message

func (*Event) CloneVT added in v0.3.1

func (m *Event) CloneVT() *Event

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

type GetOptions

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

func (*GetOptions) CloneMessageVT added in v0.3.1

func (m *GetOptions) CloneMessageVT() proto.Message

func (*GetOptions) CloneVT added in v0.3.1

func (m *GetOptions) CloneVT() *GetOptions

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) CloneMessageVT added in v0.3.1

func (m *GetRequest) CloneMessageVT() proto.Message

func (*GetRequest) CloneVT added in v0.3.1

func (m *GetRequest) CloneVT() *GetRequest

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) CloneMessageVT added in v0.3.1

func (m *GetResponse) CloneMessageVT() proto.Message

func (*GetResponse) CloneVT added in v0.3.1

func (m *GetResponse) CloneVT() *GetResponse

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) CloneMessageVT added in v0.3.1

func (m *IDQuery) CloneMessageVT() proto.Message

func (*IDQuery) CloneVT added in v0.3.1

func (m *IDQuery) CloneVT() *IDQuery

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) CloneMessageVT added in v0.3.1

func (m *LabelQuery) CloneMessageVT() proto.Message

func (*LabelQuery) CloneVT added in v0.3.1

func (m *LabelQuery) CloneVT() *LabelQuery

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,rep,name=value,proto3" json:"value,omitempty"`
	// Inverts the condition.
	Invert bool `protobuf:"varint,5,opt,name=invert,proto3" json:"invert,omitempty"`
	// contains filtered or unexported fields
}

LabelTerm is an expression on a label.

func (*LabelTerm) CloneMessageVT added in v0.3.1

func (m *LabelTerm) CloneMessageVT() proto.Message

func (*LabelTerm) CloneVT added in v0.3.1

func (m *LabelTerm) CloneVT() *LabelTerm

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) GetInvert added in v0.3.2

func (x *LabelTerm) GetInvert() 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.
	//
	// Deprecated: Do not use.
	LabelTerm_NOT_EXISTS LabelTerm_Operation = 2
	// Label value is in the set.
	LabelTerm_IN LabelTerm_Operation = 3
	// Label value is less.
	LabelTerm_LT LabelTerm_Operation = 4
	// Label value is less or equal.
	LabelTerm_LTE LabelTerm_Operation = 5
	// Label value is less than number.
	LabelTerm_LT_NUMERIC LabelTerm_Operation = 6
	// Label value is less or equal numeric.
	LabelTerm_LTE_NUMERIC LabelTerm_Operation = 7
)

func (LabelTerm_Operation) Descriptor

func (LabelTerm_Operation) Enum

func (LabelTerm_Operation) EnumDescriptor deprecated

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

Deprecated: Use LabelTerm_Operation.Descriptor instead.

func (LabelTerm_Operation) Number

func (LabelTerm_Operation) String

func (x LabelTerm_Operation) String() string

func (LabelTerm_Operation) Type

type ListOptions

type ListOptions struct {
	LabelQuery []*LabelQuery `protobuf:"bytes,1,rep,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) CloneMessageVT added in v0.3.1

func (m *ListOptions) CloneMessageVT() proto.Message

func (*ListOptions) CloneVT added in v0.3.1

func (m *ListOptions) CloneVT() *ListOptions

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) CloneMessageVT added in v0.3.1

func (m *ListRequest) CloneMessageVT() proto.Message

func (*ListRequest) CloneVT added in v0.3.1

func (m *ListRequest) CloneVT() *ListRequest

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) CloneMessageVT added in v0.3.1

func (m *ListResponse) CloneMessageVT() proto.Message

func (*ListResponse) CloneVT added in v0.3.1

func (m *ListResponse) CloneVT() *ListResponse

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) CloneMessageVT added in v0.3.1

func (m *Metadata) CloneMessageVT() proto.Message

func (*Metadata) CloneVT added in v0.3.1

func (m *Metadata) CloneVT() *Metadata

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) CloneMessageVT added in v0.3.1

func (m *NamespaceSpec) CloneMessageVT() proto.Message

func (*NamespaceSpec) CloneVT added in v0.3.1

func (m *NamespaceSpec) CloneVT() *NamespaceSpec

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 Options added in v0.3.1

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

func (*Options) CloneMessageVT added in v0.3.1

func (m *Options) CloneMessageVT() proto.Message

func (*Options) CloneVT added in v0.3.1

func (m *Options) CloneVT() *Options

func (*Options) Descriptor deprecated added in v0.3.1

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

Deprecated: Use Options.ProtoReflect.Descriptor instead.

func (*Options) EqualMessageVT added in v0.3.1

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

func (*Options) EqualVT added in v0.3.1

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

func (*Options) GetOwner added in v0.3.1

func (x *Options) GetOwner() string

func (*Options) MarshalToSizedBufferVT added in v0.3.1

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

func (*Options) MarshalToVT added in v0.3.1

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

func (*Options) MarshalVT added in v0.3.1

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

func (*Options) ProtoMessage added in v0.3.1

func (*Options) ProtoMessage()

func (*Options) ProtoReflect added in v0.3.1

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

func (*Options) Reset added in v0.3.1

func (x *Options) Reset()

func (*Options) SizeVT added in v0.3.1

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

func (*Options) String added in v0.3.1

func (x *Options) String() string

func (*Options) UnmarshalVT added in v0.3.1

func (m *Options) 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) CloneMessageVT added in v0.3.1

func (m *QueueReconcileRequest) CloneMessageVT() proto.Message

func (*QueueReconcileRequest) CloneVT added in v0.3.1

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) CloneMessageVT added in v0.3.1

func (m *QueueReconcileResponse) CloneMessageVT() proto.Message

func (*QueueReconcileResponse) CloneVT added in v0.3.1

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) CloneMessageVT added in v0.3.1

func (m *ReconcileEventsRequest) CloneMessageVT() proto.Message

func (*ReconcileEventsRequest) CloneVT added in v0.3.1

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) CloneMessageVT added in v0.3.1

func (m *ReconcileEventsResponse) CloneMessageVT() proto.Message

func (*ReconcileEventsResponse) CloneVT added in v0.3.1

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 (*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) CloneMessageVT added in v0.3.1

func (m *RegisterControllerRequest) CloneMessageVT() proto.Message

func (*RegisterControllerRequest) CloneVT added in v0.3.1

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 (*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 (*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) CloneMessageVT added in v0.3.1

func (m *RegisterControllerResponse) CloneMessageVT() proto.Message

func (*RegisterControllerResponse) CloneVT added in v0.3.1

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 (*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 (*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) CloneMessageVT added in v0.3.1

func (m *Resource) CloneMessageVT() proto.Message

func (*Resource) CloneVT added in v0.3.1

func (m *Resource) CloneVT() *Resource

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) CloneMessageVT added in v0.3.1

func (m *ResourceDefinitionSpec) CloneMessageVT() proto.Message

func (*ResourceDefinitionSpec) CloneVT added in v0.3.1

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 (*ResourceDefinitionSpec) GetResourceType

func (x *ResourceDefinitionSpec) GetResourceType() string

func (*ResourceDefinitionSpec) GetSensitivity

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) CloneMessageVT added in v0.3.1

func (m *ResourceDefinitionSpec_PrintColumn) CloneMessageVT() proto.Message

func (*ResourceDefinitionSpec_PrintColumn) CloneVT added in v0.3.1

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 (*ResourceDefinitionSpec_PrintColumn) GetJsonPath

func (x *ResourceDefinitionSpec_PrintColumn) GetJsonPath() string

func (*ResourceDefinitionSpec_PrintColumn) GetName

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 (*ResourceDefinitionSpec_PrintColumn) Reset

func (*ResourceDefinitionSpec_PrintColumn) SizeVT

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

func (*ResourceDefinitionSpec_PrintColumn) 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) Enum

func (ResourceDefinitionSpec_Sensitivity) EnumDescriptor deprecated

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

Deprecated: Use ResourceDefinitionSpec_Sensitivity.Descriptor instead.

func (ResourceDefinitionSpec_Sensitivity) Number

func (ResourceDefinitionSpec_Sensitivity) String

func (ResourceDefinitionSpec_Sensitivity) Type

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) CloneMessageVT added in v0.3.1

func (m *RuntimeAddFinalizerRequest) CloneMessageVT() proto.Message

func (*RuntimeAddFinalizerRequest) CloneVT added in v0.3.1

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 (*RuntimeAddFinalizerRequest) GetControllerToken

func (x *RuntimeAddFinalizerRequest) GetControllerToken() string

func (*RuntimeAddFinalizerRequest) GetFinalizers

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

func (*RuntimeAddFinalizerRequest) GetId

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 (*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) CloneMessageVT added in v0.3.1

func (m *RuntimeAddFinalizerResponse) CloneMessageVT() proto.Message

func (*RuntimeAddFinalizerResponse) CloneVT added in v0.3.1

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 (*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 (*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) CloneMessageVT added in v0.3.1

func (m *RuntimeCreateRequest) CloneMessageVT() proto.Message

func (*RuntimeCreateRequest) CloneVT added in v0.3.1

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) CloneMessageVT added in v0.3.1

func (m *RuntimeCreateResponse) CloneMessageVT() proto.Message

func (*RuntimeCreateResponse) CloneVT added in v0.3.1

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"`
	Options         *Options `protobuf:"bytes,5,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*RuntimeDestroyRequest) CloneMessageVT added in v0.3.1

func (m *RuntimeDestroyRequest) CloneMessageVT() proto.Message

func (*RuntimeDestroyRequest) CloneVT added in v0.3.1

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) GetOptions added in v0.3.1

func (x *RuntimeDestroyRequest) GetOptions() *Options

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) CloneMessageVT added in v0.3.1

func (m *RuntimeDestroyResponse) CloneMessageVT() proto.Message

func (*RuntimeDestroyResponse) CloneVT added in v0.3.1

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) CloneMessageVT added in v0.3.1

func (m *RuntimeGetRequest) CloneMessageVT() proto.Message

func (*RuntimeGetRequest) CloneVT added in v0.3.1

func (m *RuntimeGetRequest) CloneVT() *RuntimeGetRequest

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) CloneMessageVT added in v0.3.1

func (m *RuntimeGetResponse) CloneMessageVT() proto.Message

func (*RuntimeGetResponse) CloneVT added in v0.3.1

func (m *RuntimeGetResponse) CloneVT() *RuntimeGetResponse

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,rep,name=label_query,json=labelQuery,proto3" json:"label_query,omitempty"`
	// contains filtered or unexported fields
}

func (*RuntimeListOptions) CloneMessageVT added in v0.3.1

func (m *RuntimeListOptions) CloneMessageVT() proto.Message

func (*RuntimeListOptions) CloneVT added in v0.3.1

func (m *RuntimeListOptions) CloneVT() *RuntimeListOptions

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) CloneMessageVT added in v0.3.1

func (m *RuntimeListRequest) CloneMessageVT() proto.Message

func (*RuntimeListRequest) CloneVT added in v0.3.1

func (m *RuntimeListRequest) CloneVT() *RuntimeListRequest

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) CloneMessageVT added in v0.3.1

func (m *RuntimeListResponse) CloneMessageVT() proto.Message

func (*RuntimeListResponse) CloneVT added in v0.3.1

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) CloneMessageVT added in v0.3.1

func (m *RuntimeRemoveFinalizerRequest) CloneMessageVT() proto.Message

func (*RuntimeRemoveFinalizerRequest) CloneVT added in v0.3.1

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 (*RuntimeRemoveFinalizerRequest) GetControllerToken

func (x *RuntimeRemoveFinalizerRequest) GetControllerToken() string

func (*RuntimeRemoveFinalizerRequest) GetFinalizers

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

func (*RuntimeRemoveFinalizerRequest) GetId

func (*RuntimeRemoveFinalizerRequest) GetNamespace

func (x *RuntimeRemoveFinalizerRequest) GetNamespace() string

func (*RuntimeRemoveFinalizerRequest) GetType

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 (*RuntimeRemoveFinalizerRequest) Reset

func (x *RuntimeRemoveFinalizerRequest) Reset()

func (*RuntimeRemoveFinalizerRequest) SizeVT

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

func (*RuntimeRemoveFinalizerRequest) String

func (*RuntimeRemoveFinalizerRequest) UnmarshalVT

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

type RuntimeRemoveFinalizerResponse

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

func (*RuntimeRemoveFinalizerResponse) CloneMessageVT added in v0.3.1

func (m *RuntimeRemoveFinalizerResponse) CloneMessageVT() proto.Message

func (*RuntimeRemoveFinalizerResponse) CloneVT added in v0.3.1

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 (*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 (*RuntimeRemoveFinalizerResponse) Reset

func (x *RuntimeRemoveFinalizerResponse) Reset()

func (*RuntimeRemoveFinalizerResponse) SizeVT

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

func (*RuntimeRemoveFinalizerResponse) 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"`
	Options         *Options `protobuf:"bytes,5,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*RuntimeTeardownRequest) CloneMessageVT added in v0.3.1

func (m *RuntimeTeardownRequest) CloneMessageVT() proto.Message

func (*RuntimeTeardownRequest) CloneVT added in v0.3.1

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) GetOptions added in v0.3.1

func (x *RuntimeTeardownRequest) GetOptions() *Options

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) CloneMessageVT added in v0.3.1

func (m *RuntimeTeardownResponse) CloneMessageVT() proto.Message

func (*RuntimeTeardownResponse) CloneVT added in v0.3.1

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 (*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) CloneMessageVT added in v0.3.1

func (m *RuntimeUpdateRequest) CloneMessageVT() proto.Message

func (*RuntimeUpdateRequest) CloneVT added in v0.3.1

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) CloneMessageVT added in v0.3.1

func (m *RuntimeUpdateResponse) CloneMessageVT() proto.Message

func (*RuntimeUpdateResponse) CloneVT added in v0.3.1

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) CloneMessageVT added in v0.3.1

func (m *RuntimeWatchForRequest) CloneMessageVT() proto.Message

func (*RuntimeWatchForRequest) CloneVT added in v0.3.1

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) CloneMessageVT added in v0.3.1

func (m *RuntimeWatchForResponse) CloneMessageVT() proto.Message

func (*RuntimeWatchForResponse) CloneVT added in v0.3.1

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 (*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) CloneMessageVT added in v0.3.1

func (m *Spec) CloneMessageVT() proto.Message

func (*Spec) CloneVT added in v0.3.1

func (m *Spec) CloneVT() *Spec

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) CloneMessageVT added in v0.3.1

func (m *StartRequest) CloneMessageVT() proto.Message

func (*StartRequest) CloneVT added in v0.3.1

func (m *StartRequest) CloneVT() *StartRequest

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) CloneMessageVT added in v0.3.1

func (m *StartResponse) CloneMessageVT() proto.Message

func (*StartResponse) CloneVT added in v0.3.1

func (m *StartResponse) CloneVT() *StartResponse

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) CloneMessageVT added in v0.3.1

func (m *StopRequest) CloneMessageVT() proto.Message

func (*StopRequest) CloneVT added in v0.3.1

func (m *StopRequest) CloneVT() *StopRequest

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) CloneMessageVT added in v0.3.1

func (m *StopResponse) CloneMessageVT() proto.Message

func (*StopResponse) CloneVT added in v0.3.1

func (m *StopResponse) CloneVT() *StopResponse

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) Create

func (UnimplementedControllerAdapterServer) Destroy

func (UnimplementedControllerAdapterServer) Get

func (UnimplementedControllerAdapterServer) List

func (UnimplementedControllerAdapterServer) QueueReconcile

func (UnimplementedControllerAdapterServer) Teardown

func (UnimplementedControllerAdapterServer) Update

func (UnimplementedControllerAdapterServer) UpdateInputs

func (UnimplementedControllerAdapterServer) WatchFor

type UnimplementedControllerRuntimeServer

type UnimplementedControllerRuntimeServer struct {
}

UnimplementedControllerRuntimeServer must be embedded to have forward compatible implementations.

func (UnimplementedControllerRuntimeServer) RegisterController

func (UnimplementedControllerRuntimeServer) Start

func (UnimplementedControllerRuntimeServer) Stop

type UnimplementedStateServer

type UnimplementedStateServer struct {
}

UnimplementedStateServer must be embedded to have forward compatible implementations.

func (UnimplementedStateServer) Create

func (UnimplementedStateServer) Destroy

func (UnimplementedStateServer) Get

func (UnimplementedStateServer) List

func (UnimplementedStateServer) Update

func (UnimplementedStateServer) Watch

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) CloneMessageVT added in v0.3.1

func (m *UpdateInputsRequest) CloneMessageVT() proto.Message

func (*UpdateInputsRequest) CloneVT added in v0.3.1

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) CloneMessageVT added in v0.3.1

func (m *UpdateInputsResponse) CloneMessageVT() proto.Message

func (*UpdateInputsResponse) CloneVT added in v0.3.1

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) CloneMessageVT added in v0.3.1

func (m *UpdateOptions) CloneMessageVT() proto.Message

func (*UpdateOptions) CloneVT added in v0.3.1

func (m *UpdateOptions) CloneVT() *UpdateOptions

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) CloneMessageVT added in v0.3.1

func (m *UpdateRequest) CloneMessageVT() proto.Message

func (*UpdateRequest) CloneVT added in v0.3.1

func (m *UpdateRequest) CloneVT() *UpdateRequest

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) CloneMessageVT added in v0.3.1

func (m *UpdateResponse) CloneMessageVT() proto.Message

func (*UpdateResponse) CloneVT added in v0.3.1

func (m *UpdateResponse) CloneVT() *UpdateResponse

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,rep,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"`
	Aggregated        bool          `protobuf:"varint,5,opt,name=aggregated,proto3" json:"aggregated,omitempty"`
	// contains filtered or unexported fields
}

func (*WatchOptions) CloneMessageVT added in v0.3.1

func (m *WatchOptions) CloneMessageVT() proto.Message

func (*WatchOptions) CloneVT added in v0.3.1

func (m *WatchOptions) CloneVT() *WatchOptions

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) GetAggregated added in v0.3.0

func (x *WatchOptions) GetAggregated() 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) CloneMessageVT added in v0.3.1

func (m *WatchRequest) CloneMessageVT() proto.Message

func (*WatchRequest) CloneVT added in v0.3.1

func (m *WatchRequest) CloneVT() *WatchRequest

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,rep,name=event,proto3" json:"event,omitempty"`
	// contains filtered or unexported fields
}

func (*WatchResponse) CloneMessageVT added in v0.3.1

func (m *WatchResponse) CloneMessageVT() proto.Message

func (*WatchResponse) CloneVT added in v0.3.1

func (m *WatchResponse) CloneVT() *WatchResponse

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

Jump to

Keyboard shortcuts

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