v1alpha1

package
v0.3.20 Latest Latest
Warning

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

Go to latest
Published: Dec 18, 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.

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

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

func (UnimplementedStateServer) Get

func (UnimplementedStateServer) List

func (UnimplementedStateServer) Update

func (UnimplementedStateServer) Watch

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

Jump to

Keyboard shortcuts

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