discoverypb

package
v0.0.5 Latest Latest
Warning

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

Go to latest
Published: Oct 1, 2024 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	Watch_EventType_name = map[int32]string{
		0: "ERROR",
		1: "ADDED",
		2: "MODIFIED",
		3: "DELETED",
		4: "BOOKMARK",
	}
	Watch_EventType_value = map[string]int32{
		"ERROR":    0,
		"ADDED":    1,
		"MODIFIED": 2,
		"DELETED":  3,
		"BOOKMARK": 4,
	}
)

Enum value maps for Watch_EventType.

View Source
var Discovery_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "discoverypb.Discovery",
	HandlerType: (*DiscoveryServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Get",
			Handler:    _Discovery_Get_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Watch",
			Handler:       _Discovery_Watch_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "discovery.proto",
}

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

View Source
var File_discovery_proto protoreflect.FileDescriptor

Functions

func RegisterDiscoveryServer

func RegisterDiscoveryServer(s grpc.ServiceRegistrar, srv DiscoveryServer)

Types

type APIResource

type APIResource struct {
	Resource   string   `protobuf:"bytes,1,opt,name=resource,proto3" json:"resource,omitempty"` // this resource name (plural)
	Group      string   `protobuf:"bytes,2,opt,name=group,proto3" json:"group,omitempty"`
	Version    string   `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
	Kind       string   `protobuf:"bytes,4,opt,name=kind,proto3" json:"kind,omitempty"`
	ListKind   string   `protobuf:"bytes,5,opt,name=listKind,proto3" json:"listKind,omitempty"`
	Namespaced bool     `protobuf:"varint,6,opt,name=namespaced,proto3" json:"namespaced,omitempty"`
	Categories []string `protobuf:"bytes,7,rep,name=categories,proto3" json:"categories,omitempty"`
	// contains filtered or unexported fields
}

func (*APIResource) Descriptor deprecated

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

Deprecated: Use APIResource.ProtoReflect.Descriptor instead.

func (*APIResource) GetCategories

func (x *APIResource) GetCategories() []string

func (*APIResource) GetGroup

func (x *APIResource) GetGroup() string

func (*APIResource) GetKind

func (x *APIResource) GetKind() string

func (*APIResource) GetListKind

func (x *APIResource) GetListKind() string

func (*APIResource) GetNamespaced

func (x *APIResource) GetNamespaced() bool

func (*APIResource) GetResource

func (x *APIResource) GetResource() string

func (*APIResource) GetVersion

func (x *APIResource) GetVersion() string

func (*APIResource) ProtoMessage

func (*APIResource) ProtoMessage()

func (*APIResource) ProtoReflect

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

func (*APIResource) Reset

func (x *APIResource) Reset()

func (*APIResource) String

func (x *APIResource) String() string

type DiscoveryClient

type DiscoveryClient interface {
	Get(ctx context.Context, in *Get_Request, opts ...grpc.CallOption) (*Get_Response, error)
	Watch(ctx context.Context, in *Watch_Request, opts ...grpc.CallOption) (Discovery_WatchClient, error)
}

DiscoveryClient is the client API for Discovery 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 NewDiscoveryClient

func NewDiscoveryClient(cc grpc.ClientConnInterface) DiscoveryClient

type DiscoveryServer

type DiscoveryServer interface {
	Get(context.Context, *Get_Request) (*Get_Response, error)
	Watch(*Watch_Request, Discovery_WatchServer) error
	// contains filtered or unexported methods
}

DiscoveryServer is the server API for Discovery service. All implementations must embed UnimplementedDiscoveryServer for forward compatibility

type Discovery_WatchClient

type Discovery_WatchClient interface {
	Recv() (*Watch_Response, error)
	grpc.ClientStream
}

type Discovery_WatchServer

type Discovery_WatchServer interface {
	Send(*Watch_Response) error
	grpc.ServerStream
}

type Get

type Get struct {
	// contains filtered or unexported fields
}

func (*Get) Descriptor deprecated

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

Deprecated: Use Get.ProtoReflect.Descriptor instead.

func (*Get) ProtoMessage

func (*Get) ProtoMessage()

func (*Get) ProtoReflect

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

func (*Get) Reset

func (x *Get) Reset()

func (*Get) String

func (x *Get) String() string

type Get_Request

type Get_Request struct {
	Branch string `protobuf:"bytes,1,opt,name=branch,proto3" json:"branch,omitempty"`
	Ref    string `protobuf:"bytes,2,opt,name=ref,proto3" json:"ref,omitempty"`
	// contains filtered or unexported fields
}

func (*Get_Request) Descriptor deprecated

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

Deprecated: Use Get_Request.ProtoReflect.Descriptor instead.

func (*Get_Request) GetBranch

func (x *Get_Request) GetBranch() string

func (*Get_Request) GetRef

func (x *Get_Request) GetRef() string

func (*Get_Request) ProtoMessage

func (*Get_Request) ProtoMessage()

func (*Get_Request) ProtoReflect

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

func (*Get_Request) Reset

func (x *Get_Request) Reset()

func (*Get_Request) String

func (x *Get_Request) String() string

type Get_Response

type Get_Response struct {
	Apiresources []*APIResource `protobuf:"bytes,1,rep,name=apiresources,proto3" json:"apiresources,omitempty"`
	// contains filtered or unexported fields
}

func (*Get_Response) Descriptor deprecated

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

Deprecated: Use Get_Response.ProtoReflect.Descriptor instead.

func (*Get_Response) GetApiresources

func (x *Get_Response) GetApiresources() []*APIResource

func (*Get_Response) ProtoMessage

func (*Get_Response) ProtoMessage()

func (*Get_Response) ProtoReflect

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

func (*Get_Response) Reset

func (x *Get_Response) Reset()

func (*Get_Response) String

func (x *Get_Response) String() string

type UnimplementedDiscoveryServer

type UnimplementedDiscoveryServer struct {
}

UnimplementedDiscoveryServer must be embedded to have forward compatible implementations.

func (UnimplementedDiscoveryServer) Get

func (UnimplementedDiscoveryServer) Watch

type UnsafeDiscoveryServer

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

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

type Watch

type Watch struct {
	// contains filtered or unexported fields
}

func (*Watch) Descriptor deprecated

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

Deprecated: Use Watch.ProtoReflect.Descriptor instead.

func (*Watch) ProtoMessage

func (*Watch) ProtoMessage()

func (*Watch) ProtoReflect

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

func (*Watch) Reset

func (x *Watch) Reset()

func (*Watch) String

func (x *Watch) String() string

type Watch_EventType

type Watch_EventType int32
const (
	Watch_ERROR    Watch_EventType = 0
	Watch_ADDED    Watch_EventType = 1
	Watch_MODIFIED Watch_EventType = 2
	Watch_DELETED  Watch_EventType = 3
	Watch_BOOKMARK Watch_EventType = 4
)

func (Watch_EventType) Descriptor

func (Watch_EventType) Enum

func (x Watch_EventType) Enum() *Watch_EventType

func (Watch_EventType) EnumDescriptor deprecated

func (Watch_EventType) EnumDescriptor() ([]byte, []int)

Deprecated: Use Watch_EventType.Descriptor instead.

func (Watch_EventType) Number

func (Watch_EventType) String

func (x Watch_EventType) String() string

func (Watch_EventType) Type

type Watch_Options

type Watch_Options struct {
	Watch  bool   `protobuf:"varint,1,opt,name=watch,proto3" json:"watch,omitempty"` // indicate watch only, otherwise list and watch is used
	Trace  string `protobuf:"bytes,2,opt,name=trace,proto3" json:"trace,omitempty"`
	Origin string `protobuf:"bytes,3,opt,name=origin,proto3" json:"origin,omitempty"`
	// contains filtered or unexported fields
}

func (*Watch_Options) Descriptor deprecated

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

Deprecated: Use Watch_Options.ProtoReflect.Descriptor instead.

func (*Watch_Options) GetOrigin

func (x *Watch_Options) GetOrigin() string

func (*Watch_Options) GetTrace

func (x *Watch_Options) GetTrace() string

func (*Watch_Options) GetWatch

func (x *Watch_Options) GetWatch() bool

func (*Watch_Options) ProtoMessage

func (*Watch_Options) ProtoMessage()

func (*Watch_Options) ProtoReflect

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

func (*Watch_Options) Reset

func (x *Watch_Options) Reset()

func (*Watch_Options) String

func (x *Watch_Options) String() string

type Watch_Request

type Watch_Request struct {
	Branch  string         `protobuf:"bytes,1,opt,name=branch,proto3" json:"branch,omitempty"`
	Ref     string         `protobuf:"bytes,2,opt,name=ref,proto3" json:"ref,omitempty"`
	Options *Watch_Options `protobuf:"bytes,3,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*Watch_Request) Descriptor deprecated

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

Deprecated: Use Watch_Request.ProtoReflect.Descriptor instead.

func (*Watch_Request) GetBranch

func (x *Watch_Request) GetBranch() string

func (*Watch_Request) GetOptions

func (x *Watch_Request) GetOptions() *Watch_Options

func (*Watch_Request) GetRef

func (x *Watch_Request) GetRef() string

func (*Watch_Request) ProtoMessage

func (*Watch_Request) ProtoMessage()

func (*Watch_Request) ProtoReflect

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

func (*Watch_Request) Reset

func (x *Watch_Request) Reset()

func (*Watch_Request) String

func (x *Watch_Request) String() string

type Watch_Response

type Watch_Response struct {
	ApiResource *APIResource    `protobuf:"bytes,1,opt,name=apiResource,proto3" json:"apiResource,omitempty"`
	EventType   Watch_EventType `protobuf:"varint,2,opt,name=eventType,proto3,enum=discoverypb.Watch_EventType" json:"eventType,omitempty"`
	// contains filtered or unexported fields
}

func (*Watch_Response) Descriptor deprecated

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

Deprecated: Use Watch_Response.ProtoReflect.Descriptor instead.

func (*Watch_Response) GetApiResource

func (x *Watch_Response) GetApiResource() *APIResource

func (*Watch_Response) GetEventType

func (x *Watch_Response) GetEventType() Watch_EventType

func (*Watch_Response) ProtoMessage

func (*Watch_Response) ProtoMessage()

func (*Watch_Response) ProtoReflect

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

func (*Watch_Response) Reset

func (x *Watch_Response) Reset()

func (*Watch_Response) String

func (x *Watch_Response) String() string

Jump to

Keyboard shortcuts

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