v1alpha1

package
v0.5.0 Latest Latest
Warning

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

 Go to latest Published: Jun 25, 2024 License: MPL-2.0 Imports: 19 Imported by: 7

Documentation

Overview

Package v1alpha1 is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

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 (
	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 File_v1alpha1_meta_proto protoreflect.FileDescriptor
View Source 
var File_v1alpha1_resource_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 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 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 

func (EventType) Type() protoreflect.EnumType

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: Marked as deprecated in v1alpha1/resource.proto.
	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) Descriptor() protoreflect.EnumDescriptor

func (LabelTerm_Operation) Enum 

func (x LabelTerm_Operation) Enum() *LabelTerm_Operation

func (LabelTerm_Operation) EnumDescriptor deprecated 

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

Deprecated: Use LabelTerm_Operation.Descriptor instead.

func (LabelTerm_Operation) Number 

func (x LabelTerm_Operation) Number() protoreflect.EnumNumber

func (LabelTerm_Operation) String 

func (x LabelTerm_Operation) String() string

func (LabelTerm_Operation) Type 

func (LabelTerm_Operation) Type() protoreflect.EnumType

type ListOptions 

type ListOptions struct {
	LabelQuery []*LabelQuery `protobuf:"bytes,1,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 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 (m *ResourceDefinitionSpec) CloneVT() *ResourceDefinitionSpec

func (*ResourceDefinitionSpec) Descriptor deprecated 

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

Deprecated: Use ResourceDefinitionSpec.ProtoReflect.Descriptor instead.

func (*ResourceDefinitionSpec) EqualMessageVT added in v0.3.0 

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

func (*ResourceDefinitionSpec) EqualVT added in v0.3.0 

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

func (*ResourceDefinitionSpec) GetAliases 

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

func (*ResourceDefinitionSpec) GetAllAliases 

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

func (*ResourceDefinitionSpec) GetDefaultNamespace 

func (x *ResourceDefinitionSpec) GetDefaultNamespace() string

func (*ResourceDefinitionSpec) GetDisplayType 

func (x *ResourceDefinitionSpec) GetDisplayType() string

func (*ResourceDefinitionSpec) GetPrintColumns 

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

func (*ResourceDefinitionSpec) GetResourceType 

func (x *ResourceDefinitionSpec) GetResourceType() string

func (*ResourceDefinitionSpec) GetSensitivity 

func (x *ResourceDefinitionSpec) GetSensitivity() ResourceDefinitionSpec_Sensitivity

func (*ResourceDefinitionSpec) MarshalToSizedBufferVT 

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

func (*ResourceDefinitionSpec) MarshalToVT 

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

func (*ResourceDefinitionSpec) MarshalVT 

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

func (*ResourceDefinitionSpec) ProtoMessage 

func (*ResourceDefinitionSpec) ProtoMessage()

func (*ResourceDefinitionSpec) ProtoReflect 

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

func (*ResourceDefinitionSpec) Reset 

func (x *ResourceDefinitionSpec) Reset()

func (*ResourceDefinitionSpec) SizeVT 

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

func (*ResourceDefinitionSpec) String 

func (x *ResourceDefinitionSpec) String() string

func (*ResourceDefinitionSpec) UnmarshalVT 

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

type ResourceDefinitionSpec_PrintColumn 

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

func (*ResourceDefinitionSpec_PrintColumn) CloneMessageVT added in v0.3.1 

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

func (*ResourceDefinitionSpec_PrintColumn) CloneVT added in v0.3.1 

func (m *ResourceDefinitionSpec_PrintColumn) CloneVT() *ResourceDefinitionSpec_PrintColumn

func (*ResourceDefinitionSpec_PrintColumn) Descriptor deprecated 

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

Deprecated: Use ResourceDefinitionSpec_PrintColumn.ProtoReflect.Descriptor instead.

func (*ResourceDefinitionSpec_PrintColumn) EqualMessageVT added in v0.3.0 

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

func (*ResourceDefinitionSpec_PrintColumn) EqualVT added in v0.3.0 

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

func (*ResourceDefinitionSpec_PrintColumn) GetJsonPath 

func (x *ResourceDefinitionSpec_PrintColumn) GetJsonPath() string

func (*ResourceDefinitionSpec_PrintColumn) GetName 

func (x *ResourceDefinitionSpec_PrintColumn) GetName() string

func (*ResourceDefinitionSpec_PrintColumn) MarshalToSizedBufferVT 

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

func (*ResourceDefinitionSpec_PrintColumn) MarshalToVT 

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

func (*ResourceDefinitionSpec_PrintColumn) MarshalVT 

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

func (*ResourceDefinitionSpec_PrintColumn) ProtoMessage 

func (*ResourceDefinitionSpec_PrintColumn) ProtoMessage()

func (*ResourceDefinitionSpec_PrintColumn) ProtoReflect 

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

func (*ResourceDefinitionSpec_PrintColumn) Reset 

func (x *ResourceDefinitionSpec_PrintColumn) Reset()

func (*ResourceDefinitionSpec_PrintColumn) SizeVT 

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

func (*ResourceDefinitionSpec_PrintColumn) String 

func (x *ResourceDefinitionSpec_PrintColumn) String() string

func (*ResourceDefinitionSpec_PrintColumn) UnmarshalVT 

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

type ResourceDefinitionSpec_Sensitivity 

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

func (ResourceDefinitionSpec_Sensitivity) Descriptor 

func (ResourceDefinitionSpec_Sensitivity) Descriptor() protoreflect.EnumDescriptor

func (ResourceDefinitionSpec_Sensitivity) Enum 

func (x ResourceDefinitionSpec_Sensitivity) Enum() *ResourceDefinitionSpec_Sensitivity

func (ResourceDefinitionSpec_Sensitivity) EnumDescriptor deprecated 

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

Deprecated: Use ResourceDefinitionSpec_Sensitivity.Descriptor instead.

func (ResourceDefinitionSpec_Sensitivity) Number 

func (x ResourceDefinitionSpec_Sensitivity) Number() protoreflect.EnumNumber

func (ResourceDefinitionSpec_Sensitivity) String 

func (x ResourceDefinitionSpec_Sensitivity) String() string

func (ResourceDefinitionSpec_Sensitivity) Type 

func (ResourceDefinitionSpec_Sensitivity) Type() protoreflect.EnumType

type 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 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 UnimplementedStateServer 

type UnimplementedStateServer struct {
}

UnimplementedStateServer must be embedded to have forward compatible implementations.

func (UnimplementedStateServer) Create 

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

func (UnimplementedStateServer) Destroy 

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

func (UnimplementedStateServer) Get 

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

func (UnimplementedStateServer) List 

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

func (UnimplementedStateServer) Update 

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

func (UnimplementedStateServer) Watch 

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

type 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 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

Source Files

View all Source files

Jump to

Keyboard shortcuts

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