discoverypb

package
v0.0.8 Latest Latest
Warning

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

 Go to latest Published: Oct 4, 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) Get(context.Context, *Get_Request) (*Get_Response, error)

func (UnimplementedDiscoveryServer) Watch 

func (UnimplementedDiscoveryServer) Watch(*Watch_Request, Discovery_WatchServer) error

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) Descriptor() protoreflect.EnumDescriptor

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 (x Watch_EventType) Number() protoreflect.EnumNumber

func (Watch_EventType) String 

func (x Watch_EventType) String() string

func (Watch_EventType) Type 

func (Watch_EventType) Type() protoreflect.EnumType

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

Source Files

View all Source files

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.