resource

package
v1.3.0-beta.2 Latest Latest
Warning

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

 Go to latest Published: Dec 9, 2022 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 

func (EventType) Type() protoreflect.EnumType

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 

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

func (*Get) MarshalToVT 

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

func (*Get) MarshalVT 

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 

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

func (*Get) String 

func (x *Get) String() string

func (*Get) UnmarshalVT 

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 

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

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

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

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,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 */
	Annotations map[string]string      `` /* 164-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) GetAnnotations 

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

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

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 UnimplementedResourceServiceServer 

type UnimplementedResourceServiceServer struct {
}

UnimplementedResourceServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedResourceServiceServer) Get 

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

func (UnimplementedResourceServiceServer) List 

func (UnimplementedResourceServiceServer) List(*ListRequest, ResourceService_ListServer) error

func (UnimplementedResourceServiceServer) Watch 

func (UnimplementedResourceServiceServer) Watch(*WatchRequest, ResourceService_WatchServer) error

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 

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

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

Directories

Path Synopsis
definitions
cluster
cri
enums
etcd
extensions
files
hardware
k8s
kubeaccess
kubespan
network
perf
proto
runtime
secrets
time
v1alpha1

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.