resource

package
v0.15.0-alpha.2 Latest Latest
Warning

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

 Go to latest Published: Feb 11, 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 

func RegisterResourceServiceServer(s grpc.ServiceRegistrar, srv ResourceServiceServer)

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 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"`
	// 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) 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 

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.

func NewResourceServiceClient 

func NewResourceServiceClient(cc grpc.ClientConnInterface) ResourceServiceClient

type ResourceServiceServer 

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

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

Source Files

View all Source files

Directories

Path Synopsis

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.