resource

package
Version: v0.12.2 Latest Latest
Warning

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

Go to latest
Published: Sep 17, 2021 License: MPL-2.0 Imports: 14 Imported by: 3

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

This method has been 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

This method has been 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

This method has been 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

This method has been 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

This method has been 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

This method has been 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

This method has been 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

This method has been 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.

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

This method has been 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

This method has been 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

This method has been 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
t or T : Toggle theme light dark auto
y or Y : Canonical URL