resource

package
v1.2.9 Latest Latest
Warning

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

Go to latest
Published: Mar 10, 2023 License: MPL-2.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

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

Enum value maps for EventType.

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 File_resource_resource_proto protoreflect.FileDescriptor
View Source
var ResourceService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "resource.ResourceService",
	HandlerType: (*ResourceServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Get",
			Handler:    _ResourceService_Get_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "List",
			Handler:       _ResourceService_List_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "Watch",
			Handler:       _ResourceService_Watch_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "resource/resource.proto",
}

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

Functions

func RegisterResourceServiceServer deprecated

func RegisterResourceServiceServer(s grpc.ServiceRegistrar, srv ResourceServiceServer)

Deprecated: Do not use.

Types

type EventType

type EventType int32
const (
	EventType_CREATED   EventType = 0
	EventType_UPDATED   EventType = 1
	EventType_DESTROYED EventType = 2
)

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 Get

type Get struct {
	Metadata   *common.Metadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	Definition *Resource        `protobuf:"bytes,2,opt,name=definition,proto3" json:"definition,omitempty"`
	Resource   *Resource        `protobuf:"bytes,3,opt,name=resource,proto3" json:"resource,omitempty"`
	// contains filtered or unexported fields
}

The GetResponse message contains the Resource returned.

func (*Get) Descriptor deprecated

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

Deprecated: Use Get.ProtoReflect.Descriptor instead.

func (*Get) GetDefinition

func (x *Get) GetDefinition() *Resource

func (*Get) GetMetadata

func (x *Get) GetMetadata() *common.Metadata

func (*Get) GetResource

func (x *Get) GetResource() *Resource

func (*Get) MarshalToSizedBufferVT added in v0.12.0

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

func (*Get) MarshalToVT added in v0.12.0

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

func (*Get) MarshalVT added in v0.12.0

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

func (*Get) ProtoMessage

func (*Get) ProtoMessage()

func (*Get) ProtoReflect

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

func (*Get) Reset

func (x *Get) Reset()

func (*Get) SizeVT added in v0.12.0

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

func (*Get) String

func (x *Get) String() string

func (*Get) UnmarshalVT added in v0.12.0

func (m *Get) 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"`
	// contains filtered or unexported fields
}

rpc Get

func (*GetRequest) Descriptor deprecated

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

Deprecated: Use GetRequest.ProtoReflect.Descriptor instead.

func (*GetRequest) GetId

func (x *GetRequest) GetId() string

func (*GetRequest) GetNamespace

func (x *GetRequest) GetNamespace() string

func (*GetRequest) GetType

func (x *GetRequest) GetType() string

func (*GetRequest) MarshalToSizedBufferVT added in v0.12.0

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

func (*GetRequest) MarshalToVT added in v0.12.0

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

func (*GetRequest) MarshalVT added in v0.12.0

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

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

func (*GetRequest) String

func (x *GetRequest) String() string

func (*GetRequest) UnmarshalVT added in v0.12.0

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

type GetResponse

type GetResponse struct {
	Messages []*Get `protobuf:"bytes,1,rep,name=messages,proto3" json:"messages,omitempty"`
	// contains filtered or unexported fields
}

func (*GetResponse) Descriptor deprecated

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

Deprecated: Use GetResponse.ProtoReflect.Descriptor instead.

func (*GetResponse) GetMessages

func (x *GetResponse) GetMessages() []*Get

func (*GetResponse) MarshalToSizedBufferVT added in v0.12.0

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

func (*GetResponse) MarshalToVT added in v0.12.0

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

func (*GetResponse) MarshalVT added in v0.12.0

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

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

func (*GetResponse) String

func (x *GetResponse) String() string

func (*GetResponse) UnmarshalVT added in v0.12.0

func (m *GetResponse) 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"`
	// contains filtered or unexported fields
}

rpc List The ListResponse message contains the Resource returned.

func (*ListRequest) Descriptor deprecated

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

Deprecated: Use ListRequest.ProtoReflect.Descriptor instead.

func (*ListRequest) GetNamespace

func (x *ListRequest) GetNamespace() string

func (*ListRequest) GetType

func (x *ListRequest) GetType() string

func (*ListRequest) MarshalToSizedBufferVT added in v0.12.0

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

func (*ListRequest) MarshalToVT added in v0.12.0

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

func (*ListRequest) MarshalVT added in v0.12.0

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

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

func (*ListRequest) String

func (x *ListRequest) String() string

func (*ListRequest) UnmarshalVT added in v0.12.0

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

type ListResponse

type ListResponse struct {
	Metadata   *common.Metadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	Definition *Resource        `protobuf:"bytes,2,opt,name=definition,proto3" json:"definition,omitempty"`
	Resource   *Resource        `protobuf:"bytes,3,opt,name=resource,proto3" json:"resource,omitempty"`
	// contains filtered or unexported fields
}

func (*ListResponse) Descriptor deprecated

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

Deprecated: Use ListResponse.ProtoReflect.Descriptor instead.

func (*ListResponse) GetDefinition

func (x *ListResponse) GetDefinition() *Resource

func (*ListResponse) GetMetadata

func (x *ListResponse) GetMetadata() *common.Metadata

func (*ListResponse) GetResource

func (x *ListResponse) GetResource() *Resource

func (*ListResponse) MarshalToSizedBufferVT added in v0.12.0

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

func (*ListResponse) MarshalToVT added in v0.12.0

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

func (*ListResponse) MarshalVT added in v0.12.0

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

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

func (*ListResponse) String

func (x *ListResponse) String() string

func (*ListResponse) UnmarshalVT added in v0.12.0

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,7,opt,name=owner,proto3" json:"owner,omitempty"`
	Phase      string                 `protobuf:"bytes,5,opt,name=phase,proto3" json:"phase,omitempty"`
	Created    *timestamppb.Timestamp `protobuf:"bytes,8,opt,name=created,proto3" json:"created,omitempty"`
	Updated    *timestamppb.Timestamp `protobuf:"bytes,9,opt,name=updated,proto3" json:"updated,omitempty"`
	Finalizers []string               `protobuf:"bytes,6,rep,name=finalizers,proto3" json:"finalizers,omitempty"`
	Labels     map[string]string      `` /* 154-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Metadata) Descriptor deprecated

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

Deprecated: Use Metadata.ProtoReflect.Descriptor instead.

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 added in v1.2.0

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

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

func (*Metadata) MarshalToVT added in v0.12.0

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

func (*Metadata) MarshalVT added in v0.12.0

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

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

func (*Metadata) String

func (x *Metadata) String() string

func (*Metadata) UnmarshalVT added in v0.12.0

func (m *Metadata) 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
}

func (*Resource) Descriptor deprecated

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

Deprecated: Use Resource.ProtoReflect.Descriptor instead.

func (*Resource) GetMetadata

func (x *Resource) GetMetadata() *Metadata

func (*Resource) GetSpec

func (x *Resource) GetSpec() *Spec

func (*Resource) MarshalToSizedBufferVT added in v0.12.0

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

func (*Resource) MarshalToVT added in v0.12.0

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

func (*Resource) MarshalVT added in v0.12.0

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

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

func (*Resource) String

func (x *Resource) String() string

func (*Resource) UnmarshalVT added in v0.12.0

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

type ResourceServiceClient deprecated

type ResourceServiceClient interface {
	Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error)
	List(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (ResourceService_ListClient, error)
	Watch(ctx context.Context, in *WatchRequest, opts ...grpc.CallOption) (ResourceService_WatchClient, error)
}

ResourceServiceClient is the client API for ResourceService 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.

Deprecated: Do not use.

func NewResourceServiceClient deprecated

func NewResourceServiceClient(cc grpc.ClientConnInterface) ResourceServiceClient

Deprecated: Do not use.

type ResourceServiceServer deprecated

type ResourceServiceServer interface {
	Get(context.Context, *GetRequest) (*GetResponse, error)
	List(*ListRequest, ResourceService_ListServer) error
	Watch(*WatchRequest, ResourceService_WatchServer) error
	// contains filtered or unexported methods
}

ResourceServiceServer is the server API for ResourceService service. All implementations must embed UnimplementedResourceServiceServer for forward compatibility

Deprecated: Do not use.

type ResourceService_ListClient

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

type ResourceService_ListServer

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

type ResourceService_WatchClient

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

type ResourceService_WatchServer

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

type Spec

type Spec struct {
	Yaml []byte `protobuf:"bytes,1,opt,name=yaml,proto3" json:"yaml,omitempty"`
	// contains filtered or unexported fields
}

func (*Spec) Descriptor deprecated

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

Deprecated: Use Spec.ProtoReflect.Descriptor instead.

func (*Spec) GetYaml

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

func (*Spec) MarshalToSizedBufferVT added in v0.12.0

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

func (*Spec) MarshalToVT added in v0.12.0

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

func (*Spec) MarshalVT added in v0.12.0

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

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

func (*Spec) String

func (x *Spec) String() string

func (*Spec) UnmarshalVT added in v0.12.0

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

type UnimplementedResourceServiceServer

type UnimplementedResourceServiceServer struct {
}

UnimplementedResourceServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedResourceServiceServer) Get

func (UnimplementedResourceServiceServer) List

func (UnimplementedResourceServiceServer) Watch

type UnsafeResourceServiceServer

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

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

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" json:"id,omitempty"`
	TailEvents uint32 `protobuf:"varint,4,opt,name=tail_events,json=tailEvents,proto3" json:"tail_events,omitempty"`
	// contains filtered or unexported fields
}

rpc Watch The WatchResponse message contains the Resource returned.

func (*WatchRequest) Descriptor deprecated

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

Deprecated: Use WatchRequest.ProtoReflect.Descriptor instead.

func (*WatchRequest) GetId

func (x *WatchRequest) GetId() string

func (*WatchRequest) GetNamespace

func (x *WatchRequest) GetNamespace() string

func (*WatchRequest) GetTailEvents

func (x *WatchRequest) GetTailEvents() uint32

func (*WatchRequest) GetType

func (x *WatchRequest) GetType() string

func (*WatchRequest) MarshalToSizedBufferVT added in v0.12.0

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

func (*WatchRequest) MarshalToVT added in v0.12.0

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

func (*WatchRequest) MarshalVT added in v0.12.0

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

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

func (*WatchRequest) String

func (x *WatchRequest) String() string

func (*WatchRequest) UnmarshalVT added in v0.12.0

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

type WatchResponse

type WatchResponse struct {
	Metadata   *common.Metadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	EventType  EventType        `protobuf:"varint,2,opt,name=event_type,json=eventType,proto3,enum=resource.EventType" json:"event_type,omitempty"`
	Definition *Resource        `protobuf:"bytes,3,opt,name=definition,proto3" json:"definition,omitempty"`
	Resource   *Resource        `protobuf:"bytes,4,opt,name=resource,proto3" json:"resource,omitempty"`
	// contains filtered or unexported fields
}

func (*WatchResponse) Descriptor deprecated

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

Deprecated: Use WatchResponse.ProtoReflect.Descriptor instead.

func (*WatchResponse) GetDefinition

func (x *WatchResponse) GetDefinition() *Resource

func (*WatchResponse) GetEventType

func (x *WatchResponse) GetEventType() EventType

func (*WatchResponse) GetMetadata

func (x *WatchResponse) GetMetadata() *common.Metadata

func (*WatchResponse) GetResource

func (x *WatchResponse) GetResource() *Resource

func (*WatchResponse) MarshalToSizedBufferVT added in v0.12.0

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

func (*WatchResponse) MarshalToVT added in v0.12.0

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

func (*WatchResponse) MarshalVT added in v0.12.0

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

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

func (*WatchResponse) String

func (x *WatchResponse) String() string

func (*WatchResponse) UnmarshalVT added in v0.12.0

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

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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