mirror of
https://github.com/status-im/consul.git
synced 2025-01-09 13:26:07 +00:00
77f44fa878
TLDR with many modules the versions included in each diverged quite a bit. Attempting to use Go Workspaces produces a bunch of errors. This commit: 1. Fixes envoy-library-references.sh to work again 2. Ensures we are pulling in go-control-plane@v0.11.0 everywhere (previously it was at that version in some modules and others were much older) 3. Remove one usage of golang/protobuf that caused us to have a direct dependency on it. 4. Remove deprecated usage of the Endpoint field in the grpc resolver.Target struct. The current version of grpc (v1.55.0) has removed that field and recommended replacement with URL.Opaque and calls to the Endpoint() func when needing to consume the previous field. 4. `go work init <all the paths to go.mod files>` && `go work sync`. This syncrhonized versions of dependencies from the main workspace/root module to all submodules 5. Updated .gitignore to ignore the go.work and go.work.sum files. This seems to be standard practice at the moment. 6. Update doc comments in protoc-gen-consul-rate-limit to be go fmt compatible 7. Upgraded makefile infra to perform linting, testing and go mod tidy on all modules in a flexible manner. 8. Updated linter rules to prevent usage of golang/protobuf 9. Updated a leader peering test to account for an extra colon in a grpc error message.
1221 lines
46 KiB
Go
1221 lines
46 KiB
Go
// Copyright (c) HashiCorp, Inc.
|
|
// SPDX-License-Identifier: MPL-2.0
|
|
|
|
//
|
|
// Package event provides a service for subscribing to state change events.
|
|
|
|
// Code generated by protoc-gen-go. DO NOT EDIT.
|
|
// versions:
|
|
// protoc-gen-go v1.30.0
|
|
// protoc (unknown)
|
|
// source: private/pbsubscribe/subscribe.proto
|
|
|
|
// TODO: ideally we would have prefixed this package as
|
|
// "hashicorp.consul.internal.subscribe" before releasing but now correcting this will
|
|
// require a grpc passthrough service shim since the package name is part of
|
|
// the rpc method dispatch and editing it naively would break backwards
|
|
// compatibility.
|
|
|
|
package pbsubscribe
|
|
|
|
import (
|
|
_ "github.com/hashicorp/consul/proto-public/annotations/ratelimit"
|
|
pbcommon "github.com/hashicorp/consul/proto/private/pbcommon"
|
|
pbconfigentry "github.com/hashicorp/consul/proto/private/pbconfigentry"
|
|
pbservice "github.com/hashicorp/consul/proto/private/pbservice"
|
|
protoreflect "google.golang.org/protobuf/reflect/protoreflect"
|
|
protoimpl "google.golang.org/protobuf/runtime/protoimpl"
|
|
reflect "reflect"
|
|
sync "sync"
|
|
)
|
|
|
|
const (
|
|
// Verify that this generated code is sufficiently up-to-date.
|
|
_ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
|
|
// Verify that runtime/protoimpl is sufficiently up-to-date.
|
|
_ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
|
|
)
|
|
|
|
// Topic enumerates the supported event topics.
|
|
type Topic int32
|
|
|
|
const (
|
|
Topic_Unknown Topic = 0
|
|
// ServiceHealth topic contains events for any changes to service health.
|
|
Topic_ServiceHealth Topic = 1
|
|
// ServiceHealthConnect topic contains events for any changes to service
|
|
// health for connect-enabled services.
|
|
Topic_ServiceHealthConnect Topic = 2
|
|
// MeshConfig topic contains events for changes to the global mesh config.
|
|
Topic_MeshConfig Topic = 3
|
|
// ServiceResolver topic contains events for changes to a service resolver.
|
|
Topic_ServiceResolver Topic = 4
|
|
// IngressGateway topic contains events for changes to an ingress gateway.
|
|
Topic_IngressGateway Topic = 5
|
|
// ServiceIntentions topic contains events for changes to service intentions.
|
|
Topic_ServiceIntentions Topic = 6
|
|
// ServiceList topic contains events about services (not service instances)
|
|
// getting registered/deregistered. It can be used to materialize a list of
|
|
// the services in the given datacenter.
|
|
//
|
|
// Note: WildcardSubject is the only supported Subject on this topic.
|
|
Topic_ServiceList Topic = 7
|
|
// ServiceDefaults topic contains events for changes to service-defaults.
|
|
Topic_ServiceDefaults Topic = 8
|
|
// APIGateway topic contains events for changes to api-gateways.
|
|
Topic_APIGateway Topic = 9
|
|
// TCPRoute topic contains events for changes to tcp-routes.
|
|
Topic_TCPRoute Topic = 10
|
|
// HTTPRoute topic contains events for changes to http-routes.
|
|
Topic_HTTPRoute Topic = 11
|
|
// InlineCertificate topic contains events for changes to inline-certificates.
|
|
Topic_InlineCertificate Topic = 12
|
|
// BoundAPIGateway topic contains events for changes to bound-api-gateways.
|
|
Topic_BoundAPIGateway Topic = 13
|
|
// IPRateLimit topic contains events for changes to control-plane-request-limit
|
|
Topic_IPRateLimit Topic = 14
|
|
// SamenessGroup topic contains events for changes to Sameness Groups
|
|
Topic_SamenessGroup Topic = 15
|
|
// JWTProvider topic contains events for changes to jwt-provider
|
|
Topic_JWTProvider Topic = 16
|
|
)
|
|
|
|
// Enum value maps for Topic.
|
|
var (
|
|
Topic_name = map[int32]string{
|
|
0: "Unknown",
|
|
1: "ServiceHealth",
|
|
2: "ServiceHealthConnect",
|
|
3: "MeshConfig",
|
|
4: "ServiceResolver",
|
|
5: "IngressGateway",
|
|
6: "ServiceIntentions",
|
|
7: "ServiceList",
|
|
8: "ServiceDefaults",
|
|
9: "APIGateway",
|
|
10: "TCPRoute",
|
|
11: "HTTPRoute",
|
|
12: "InlineCertificate",
|
|
13: "BoundAPIGateway",
|
|
14: "IPRateLimit",
|
|
15: "SamenessGroup",
|
|
16: "JWTProvider",
|
|
}
|
|
Topic_value = map[string]int32{
|
|
"Unknown": 0,
|
|
"ServiceHealth": 1,
|
|
"ServiceHealthConnect": 2,
|
|
"MeshConfig": 3,
|
|
"ServiceResolver": 4,
|
|
"IngressGateway": 5,
|
|
"ServiceIntentions": 6,
|
|
"ServiceList": 7,
|
|
"ServiceDefaults": 8,
|
|
"APIGateway": 9,
|
|
"TCPRoute": 10,
|
|
"HTTPRoute": 11,
|
|
"InlineCertificate": 12,
|
|
"BoundAPIGateway": 13,
|
|
"IPRateLimit": 14,
|
|
"SamenessGroup": 15,
|
|
"JWTProvider": 16,
|
|
}
|
|
)
|
|
|
|
func (x Topic) Enum() *Topic {
|
|
p := new(Topic)
|
|
*p = x
|
|
return p
|
|
}
|
|
|
|
func (x Topic) String() string {
|
|
return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
|
|
}
|
|
|
|
func (Topic) Descriptor() protoreflect.EnumDescriptor {
|
|
return file_private_pbsubscribe_subscribe_proto_enumTypes[0].Descriptor()
|
|
}
|
|
|
|
func (Topic) Type() protoreflect.EnumType {
|
|
return &file_private_pbsubscribe_subscribe_proto_enumTypes[0]
|
|
}
|
|
|
|
func (x Topic) Number() protoreflect.EnumNumber {
|
|
return protoreflect.EnumNumber(x)
|
|
}
|
|
|
|
// Deprecated: Use Topic.Descriptor instead.
|
|
func (Topic) EnumDescriptor() ([]byte, []int) {
|
|
return file_private_pbsubscribe_subscribe_proto_rawDescGZIP(), []int{0}
|
|
}
|
|
|
|
type CatalogOp int32
|
|
|
|
const (
|
|
CatalogOp_Register CatalogOp = 0
|
|
CatalogOp_Deregister CatalogOp = 1
|
|
)
|
|
|
|
// Enum value maps for CatalogOp.
|
|
var (
|
|
CatalogOp_name = map[int32]string{
|
|
0: "Register",
|
|
1: "Deregister",
|
|
}
|
|
CatalogOp_value = map[string]int32{
|
|
"Register": 0,
|
|
"Deregister": 1,
|
|
}
|
|
)
|
|
|
|
func (x CatalogOp) Enum() *CatalogOp {
|
|
p := new(CatalogOp)
|
|
*p = x
|
|
return p
|
|
}
|
|
|
|
func (x CatalogOp) String() string {
|
|
return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
|
|
}
|
|
|
|
func (CatalogOp) Descriptor() protoreflect.EnumDescriptor {
|
|
return file_private_pbsubscribe_subscribe_proto_enumTypes[1].Descriptor()
|
|
}
|
|
|
|
func (CatalogOp) Type() protoreflect.EnumType {
|
|
return &file_private_pbsubscribe_subscribe_proto_enumTypes[1]
|
|
}
|
|
|
|
func (x CatalogOp) Number() protoreflect.EnumNumber {
|
|
return protoreflect.EnumNumber(x)
|
|
}
|
|
|
|
// Deprecated: Use CatalogOp.Descriptor instead.
|
|
func (CatalogOp) EnumDescriptor() ([]byte, []int) {
|
|
return file_private_pbsubscribe_subscribe_proto_rawDescGZIP(), []int{1}
|
|
}
|
|
|
|
type ConfigEntryUpdate_UpdateOp int32
|
|
|
|
const (
|
|
ConfigEntryUpdate_Upsert ConfigEntryUpdate_UpdateOp = 0
|
|
ConfigEntryUpdate_Delete ConfigEntryUpdate_UpdateOp = 1
|
|
)
|
|
|
|
// Enum value maps for ConfigEntryUpdate_UpdateOp.
|
|
var (
|
|
ConfigEntryUpdate_UpdateOp_name = map[int32]string{
|
|
0: "Upsert",
|
|
1: "Delete",
|
|
}
|
|
ConfigEntryUpdate_UpdateOp_value = map[string]int32{
|
|
"Upsert": 0,
|
|
"Delete": 1,
|
|
}
|
|
)
|
|
|
|
func (x ConfigEntryUpdate_UpdateOp) Enum() *ConfigEntryUpdate_UpdateOp {
|
|
p := new(ConfigEntryUpdate_UpdateOp)
|
|
*p = x
|
|
return p
|
|
}
|
|
|
|
func (x ConfigEntryUpdate_UpdateOp) String() string {
|
|
return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
|
|
}
|
|
|
|
func (ConfigEntryUpdate_UpdateOp) Descriptor() protoreflect.EnumDescriptor {
|
|
return file_private_pbsubscribe_subscribe_proto_enumTypes[2].Descriptor()
|
|
}
|
|
|
|
func (ConfigEntryUpdate_UpdateOp) Type() protoreflect.EnumType {
|
|
return &file_private_pbsubscribe_subscribe_proto_enumTypes[2]
|
|
}
|
|
|
|
func (x ConfigEntryUpdate_UpdateOp) Number() protoreflect.EnumNumber {
|
|
return protoreflect.EnumNumber(x)
|
|
}
|
|
|
|
// Deprecated: Use ConfigEntryUpdate_UpdateOp.Descriptor instead.
|
|
func (ConfigEntryUpdate_UpdateOp) EnumDescriptor() ([]byte, []int) {
|
|
return file_private_pbsubscribe_subscribe_proto_rawDescGZIP(), []int{5, 0}
|
|
}
|
|
|
|
type NamedSubject struct {
|
|
state protoimpl.MessageState
|
|
sizeCache protoimpl.SizeCache
|
|
unknownFields protoimpl.UnknownFields
|
|
|
|
// Key is a topic-specific identifier that restricts the scope of the
|
|
// subscription to only events pertaining to that identifier. For example,
|
|
// to receive events for a single service, the service's name is specified
|
|
// as the key.
|
|
Key string `protobuf:"bytes,1,opt,name=Key,proto3" json:"Key,omitempty"`
|
|
// Namespace which contains the resources. If Namespace is not specified the
|
|
// default namespace will be used.
|
|
//
|
|
// Namespace is an enterprise-only feature.
|
|
Namespace string `protobuf:"bytes,2,opt,name=Namespace,proto3" json:"Namespace,omitempty"`
|
|
// Partition which contains the resources. If Partition is not specified the
|
|
// default partition will be used.
|
|
//
|
|
// Partition is an enterprise-only feature.
|
|
Partition string `protobuf:"bytes,3,opt,name=Partition,proto3" json:"Partition,omitempty"`
|
|
// PeerName is the name of the peer that the requested service was imported from.
|
|
PeerName string `protobuf:"bytes,4,opt,name=PeerName,proto3" json:"PeerName,omitempty"`
|
|
}
|
|
|
|
func (x *NamedSubject) Reset() {
|
|
*x = NamedSubject{}
|
|
if protoimpl.UnsafeEnabled {
|
|
mi := &file_private_pbsubscribe_subscribe_proto_msgTypes[0]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
}
|
|
|
|
func (x *NamedSubject) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*NamedSubject) ProtoMessage() {}
|
|
|
|
func (x *NamedSubject) ProtoReflect() protoreflect.Message {
|
|
mi := &file_private_pbsubscribe_subscribe_proto_msgTypes[0]
|
|
if protoimpl.UnsafeEnabled && x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use NamedSubject.ProtoReflect.Descriptor instead.
|
|
func (*NamedSubject) Descriptor() ([]byte, []int) {
|
|
return file_private_pbsubscribe_subscribe_proto_rawDescGZIP(), []int{0}
|
|
}
|
|
|
|
func (x *NamedSubject) GetKey() string {
|
|
if x != nil {
|
|
return x.Key
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *NamedSubject) GetNamespace() string {
|
|
if x != nil {
|
|
return x.Namespace
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *NamedSubject) GetPartition() string {
|
|
if x != nil {
|
|
return x.Partition
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *NamedSubject) GetPeerName() string {
|
|
if x != nil {
|
|
return x.PeerName
|
|
}
|
|
return ""
|
|
}
|
|
|
|
// SubscribeRequest used to subscribe to a topic.
|
|
type SubscribeRequest struct {
|
|
state protoimpl.MessageState
|
|
sizeCache protoimpl.SizeCache
|
|
unknownFields protoimpl.UnknownFields
|
|
|
|
// Topic identifies the set of events the subscriber is interested in.
|
|
Topic Topic `protobuf:"varint,1,opt,name=Topic,proto3,enum=subscribe.Topic" json:"Topic,omitempty"`
|
|
// Deprecated: use NamedSubject.Key instead.
|
|
Key string `protobuf:"bytes,2,opt,name=Key,proto3" json:"Key,omitempty"`
|
|
// Token is the ACL token to authenticate the request. The token must have
|
|
// sufficient privileges to read the requested information otherwise events
|
|
// will be filtered, possibly resulting in an empty snapshot and no further
|
|
// updates sent.
|
|
Token string `protobuf:"bytes,3,opt,name=Token,proto3" json:"Token,omitempty"`
|
|
// Index is the raft index the subscriber has already observed up to. This
|
|
// is zero on an initial streaming call, but then can be provided by a
|
|
// client on subsequent re-connections such that the full snapshot doesn't
|
|
// need to be resent if the client is up to date.
|
|
Index uint64 `protobuf:"varint,4,opt,name=Index,proto3" json:"Index,omitempty"`
|
|
// Datacenter specifies the Consul datacenter the request is targeted at.
|
|
// If it's not the local DC the server will forward the request to
|
|
// the remote DC and proxy the results back to the subscriber. An empty
|
|
// string defaults to the local datacenter.
|
|
Datacenter string `protobuf:"bytes,5,opt,name=Datacenter,proto3" json:"Datacenter,omitempty"`
|
|
// Deprecated: use NamedSubject.Namespace instead.
|
|
Namespace string `protobuf:"bytes,6,opt,name=Namespace,proto3" json:"Namespace,omitempty"`
|
|
// Deprecated: use NamedSubject.Partition instead.
|
|
Partition string `protobuf:"bytes,7,opt,name=Partition,proto3" json:"Partition,omitempty"`
|
|
// Deprecated: use NamedSubject.PeerName instead.
|
|
PeerName string `protobuf:"bytes,8,opt,name=PeerName,proto3" json:"PeerName,omitempty"`
|
|
// Subject identifies a portion of a topic for which the subscriber wishes to
|
|
// receive events (e.g. health events for a particular service).
|
|
//
|
|
// Types that are assignable to Subject:
|
|
//
|
|
// *SubscribeRequest_WildcardSubject
|
|
// *SubscribeRequest_NamedSubject
|
|
Subject isSubscribeRequest_Subject `protobuf_oneof:"Subject"`
|
|
}
|
|
|
|
func (x *SubscribeRequest) Reset() {
|
|
*x = SubscribeRequest{}
|
|
if protoimpl.UnsafeEnabled {
|
|
mi := &file_private_pbsubscribe_subscribe_proto_msgTypes[1]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
}
|
|
|
|
func (x *SubscribeRequest) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*SubscribeRequest) ProtoMessage() {}
|
|
|
|
func (x *SubscribeRequest) ProtoReflect() protoreflect.Message {
|
|
mi := &file_private_pbsubscribe_subscribe_proto_msgTypes[1]
|
|
if protoimpl.UnsafeEnabled && x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use SubscribeRequest.ProtoReflect.Descriptor instead.
|
|
func (*SubscribeRequest) Descriptor() ([]byte, []int) {
|
|
return file_private_pbsubscribe_subscribe_proto_rawDescGZIP(), []int{1}
|
|
}
|
|
|
|
func (x *SubscribeRequest) GetTopic() Topic {
|
|
if x != nil {
|
|
return x.Topic
|
|
}
|
|
return Topic_Unknown
|
|
}
|
|
|
|
func (x *SubscribeRequest) GetKey() string {
|
|
if x != nil {
|
|
return x.Key
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *SubscribeRequest) GetToken() string {
|
|
if x != nil {
|
|
return x.Token
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *SubscribeRequest) GetIndex() uint64 {
|
|
if x != nil {
|
|
return x.Index
|
|
}
|
|
return 0
|
|
}
|
|
|
|
func (x *SubscribeRequest) GetDatacenter() string {
|
|
if x != nil {
|
|
return x.Datacenter
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *SubscribeRequest) GetNamespace() string {
|
|
if x != nil {
|
|
return x.Namespace
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *SubscribeRequest) GetPartition() string {
|
|
if x != nil {
|
|
return x.Partition
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *SubscribeRequest) GetPeerName() string {
|
|
if x != nil {
|
|
return x.PeerName
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (m *SubscribeRequest) GetSubject() isSubscribeRequest_Subject {
|
|
if m != nil {
|
|
return m.Subject
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *SubscribeRequest) GetWildcardSubject() bool {
|
|
if x, ok := x.GetSubject().(*SubscribeRequest_WildcardSubject); ok {
|
|
return x.WildcardSubject
|
|
}
|
|
return false
|
|
}
|
|
|
|
func (x *SubscribeRequest) GetNamedSubject() *NamedSubject {
|
|
if x, ok := x.GetSubject().(*SubscribeRequest_NamedSubject); ok {
|
|
return x.NamedSubject
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type isSubscribeRequest_Subject interface {
|
|
isSubscribeRequest_Subject()
|
|
}
|
|
|
|
type SubscribeRequest_WildcardSubject struct {
|
|
// WildcardSubject is used to subscribe to all events published on the topic
|
|
// if it is supported.
|
|
WildcardSubject bool `protobuf:"varint,9,opt,name=WildcardSubject,proto3,oneof"`
|
|
}
|
|
|
|
type SubscribeRequest_NamedSubject struct {
|
|
// NamedSubject is used to subscribe to events pertaining to a specific
|
|
// resource (e.g. a particular service or config entry).
|
|
NamedSubject *NamedSubject `protobuf:"bytes,10,opt,name=NamedSubject,proto3,oneof"`
|
|
}
|
|
|
|
func (*SubscribeRequest_WildcardSubject) isSubscribeRequest_Subject() {}
|
|
|
|
func (*SubscribeRequest_NamedSubject) isSubscribeRequest_Subject() {}
|
|
|
|
// Event describes a streaming update on a subscription. Events are used both to
|
|
// describe the current "snapshot" of the result as well as ongoing mutations to
|
|
// that snapshot.
|
|
type Event struct {
|
|
state protoimpl.MessageState
|
|
sizeCache protoimpl.SizeCache
|
|
unknownFields protoimpl.UnknownFields
|
|
|
|
// Index is the raft index at which the mutation took place. At the top
|
|
// level of a subscription there will always be at most one Event per index.
|
|
// If multiple events are published to the same topic in a single raft
|
|
// transaction then the batch of events will be encoded inside a single
|
|
// top-level event to ensure they are delivered atomically to clients.
|
|
Index uint64 `protobuf:"varint,1,opt,name=Index,proto3" json:"Index,omitempty"`
|
|
// Payload is the actual event content.
|
|
//
|
|
// Types that are assignable to Payload:
|
|
//
|
|
// *Event_EndOfSnapshot
|
|
// *Event_NewSnapshotToFollow
|
|
// *Event_EventBatch
|
|
// *Event_ServiceHealth
|
|
// *Event_ConfigEntry
|
|
// *Event_Service
|
|
Payload isEvent_Payload `protobuf_oneof:"Payload"`
|
|
}
|
|
|
|
func (x *Event) Reset() {
|
|
*x = Event{}
|
|
if protoimpl.UnsafeEnabled {
|
|
mi := &file_private_pbsubscribe_subscribe_proto_msgTypes[2]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
}
|
|
|
|
func (x *Event) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*Event) ProtoMessage() {}
|
|
|
|
func (x *Event) ProtoReflect() protoreflect.Message {
|
|
mi := &file_private_pbsubscribe_subscribe_proto_msgTypes[2]
|
|
if protoimpl.UnsafeEnabled && x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use Event.ProtoReflect.Descriptor instead.
|
|
func (*Event) Descriptor() ([]byte, []int) {
|
|
return file_private_pbsubscribe_subscribe_proto_rawDescGZIP(), []int{2}
|
|
}
|
|
|
|
func (x *Event) GetIndex() uint64 {
|
|
if x != nil {
|
|
return x.Index
|
|
}
|
|
return 0
|
|
}
|
|
|
|
func (m *Event) GetPayload() isEvent_Payload {
|
|
if m != nil {
|
|
return m.Payload
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *Event) GetEndOfSnapshot() bool {
|
|
if x, ok := x.GetPayload().(*Event_EndOfSnapshot); ok {
|
|
return x.EndOfSnapshot
|
|
}
|
|
return false
|
|
}
|
|
|
|
func (x *Event) GetNewSnapshotToFollow() bool {
|
|
if x, ok := x.GetPayload().(*Event_NewSnapshotToFollow); ok {
|
|
return x.NewSnapshotToFollow
|
|
}
|
|
return false
|
|
}
|
|
|
|
func (x *Event) GetEventBatch() *EventBatch {
|
|
if x, ok := x.GetPayload().(*Event_EventBatch); ok {
|
|
return x.EventBatch
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *Event) GetServiceHealth() *ServiceHealthUpdate {
|
|
if x, ok := x.GetPayload().(*Event_ServiceHealth); ok {
|
|
return x.ServiceHealth
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *Event) GetConfigEntry() *ConfigEntryUpdate {
|
|
if x, ok := x.GetPayload().(*Event_ConfigEntry); ok {
|
|
return x.ConfigEntry
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *Event) GetService() *ServiceListUpdate {
|
|
if x, ok := x.GetPayload().(*Event_Service); ok {
|
|
return x.Service
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type isEvent_Payload interface {
|
|
isEvent_Payload()
|
|
}
|
|
|
|
type Event_EndOfSnapshot struct {
|
|
// EndOfSnapshot indicates the event stream for the initial snapshot has
|
|
// ended. Subsequent Events delivered will be mutations to that result.
|
|
EndOfSnapshot bool `protobuf:"varint,2,opt,name=EndOfSnapshot,proto3,oneof"`
|
|
}
|
|
|
|
type Event_NewSnapshotToFollow struct {
|
|
// NewSnapshotToFollow indicates that the client view is stale. The client
|
|
// must reset its view before handing any more events. Subsequent events
|
|
// in the stream will be for a new snapshot until an EndOfSnapshot event
|
|
// is received.
|
|
NewSnapshotToFollow bool `protobuf:"varint,3,opt,name=NewSnapshotToFollow,proto3,oneof"`
|
|
}
|
|
|
|
type Event_EventBatch struct {
|
|
// EventBatch is a set of events. This is typically used as the payload
|
|
// type where multiple events are emitted in a single topic and raft
|
|
// index (e.g. transactional updates). In this case the Topic and Index
|
|
// values of all events will match and the whole set should be delivered
|
|
// and consumed atomically.
|
|
EventBatch *EventBatch `protobuf:"bytes,4,opt,name=EventBatch,proto3,oneof"`
|
|
}
|
|
|
|
type Event_ServiceHealth struct {
|
|
// ServiceHealth is used for ServiceHealth and ServiceHealthConnect
|
|
// topics.
|
|
ServiceHealth *ServiceHealthUpdate `protobuf:"bytes,10,opt,name=ServiceHealth,proto3,oneof"`
|
|
}
|
|
|
|
type Event_ConfigEntry struct {
|
|
// ConfigEntry is used for config entry topics (e.g. MeshConfig).
|
|
ConfigEntry *ConfigEntryUpdate `protobuf:"bytes,11,opt,name=ConfigEntry,proto3,oneof"`
|
|
}
|
|
|
|
type Event_Service struct {
|
|
// Service is used for ServiceList topic.
|
|
Service *ServiceListUpdate `protobuf:"bytes,12,opt,name=Service,proto3,oneof"`
|
|
}
|
|
|
|
func (*Event_EndOfSnapshot) isEvent_Payload() {}
|
|
|
|
func (*Event_NewSnapshotToFollow) isEvent_Payload() {}
|
|
|
|
func (*Event_EventBatch) isEvent_Payload() {}
|
|
|
|
func (*Event_ServiceHealth) isEvent_Payload() {}
|
|
|
|
func (*Event_ConfigEntry) isEvent_Payload() {}
|
|
|
|
func (*Event_Service) isEvent_Payload() {}
|
|
|
|
type EventBatch struct {
|
|
state protoimpl.MessageState
|
|
sizeCache protoimpl.SizeCache
|
|
unknownFields protoimpl.UnknownFields
|
|
|
|
Events []*Event `protobuf:"bytes,1,rep,name=Events,proto3" json:"Events,omitempty"`
|
|
}
|
|
|
|
func (x *EventBatch) Reset() {
|
|
*x = EventBatch{}
|
|
if protoimpl.UnsafeEnabled {
|
|
mi := &file_private_pbsubscribe_subscribe_proto_msgTypes[3]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
}
|
|
|
|
func (x *EventBatch) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*EventBatch) ProtoMessage() {}
|
|
|
|
func (x *EventBatch) ProtoReflect() protoreflect.Message {
|
|
mi := &file_private_pbsubscribe_subscribe_proto_msgTypes[3]
|
|
if protoimpl.UnsafeEnabled && x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use EventBatch.ProtoReflect.Descriptor instead.
|
|
func (*EventBatch) Descriptor() ([]byte, []int) {
|
|
return file_private_pbsubscribe_subscribe_proto_rawDescGZIP(), []int{3}
|
|
}
|
|
|
|
func (x *EventBatch) GetEvents() []*Event {
|
|
if x != nil {
|
|
return x.Events
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type ServiceHealthUpdate struct {
|
|
state protoimpl.MessageState
|
|
sizeCache protoimpl.SizeCache
|
|
unknownFields protoimpl.UnknownFields
|
|
|
|
Op CatalogOp `protobuf:"varint,1,opt,name=Op,proto3,enum=subscribe.CatalogOp" json:"Op,omitempty"`
|
|
CheckServiceNode *pbservice.CheckServiceNode `protobuf:"bytes,2,opt,name=CheckServiceNode,proto3" json:"CheckServiceNode,omitempty"`
|
|
}
|
|
|
|
func (x *ServiceHealthUpdate) Reset() {
|
|
*x = ServiceHealthUpdate{}
|
|
if protoimpl.UnsafeEnabled {
|
|
mi := &file_private_pbsubscribe_subscribe_proto_msgTypes[4]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
}
|
|
|
|
func (x *ServiceHealthUpdate) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*ServiceHealthUpdate) ProtoMessage() {}
|
|
|
|
func (x *ServiceHealthUpdate) ProtoReflect() protoreflect.Message {
|
|
mi := &file_private_pbsubscribe_subscribe_proto_msgTypes[4]
|
|
if protoimpl.UnsafeEnabled && x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use ServiceHealthUpdate.ProtoReflect.Descriptor instead.
|
|
func (*ServiceHealthUpdate) Descriptor() ([]byte, []int) {
|
|
return file_private_pbsubscribe_subscribe_proto_rawDescGZIP(), []int{4}
|
|
}
|
|
|
|
func (x *ServiceHealthUpdate) GetOp() CatalogOp {
|
|
if x != nil {
|
|
return x.Op
|
|
}
|
|
return CatalogOp_Register
|
|
}
|
|
|
|
func (x *ServiceHealthUpdate) GetCheckServiceNode() *pbservice.CheckServiceNode {
|
|
if x != nil {
|
|
return x.CheckServiceNode
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type ConfigEntryUpdate struct {
|
|
state protoimpl.MessageState
|
|
sizeCache protoimpl.SizeCache
|
|
unknownFields protoimpl.UnknownFields
|
|
|
|
Op ConfigEntryUpdate_UpdateOp `protobuf:"varint,1,opt,name=Op,proto3,enum=subscribe.ConfigEntryUpdate_UpdateOp" json:"Op,omitempty"`
|
|
ConfigEntry *pbconfigentry.ConfigEntry `protobuf:"bytes,2,opt,name=ConfigEntry,proto3" json:"ConfigEntry,omitempty"`
|
|
}
|
|
|
|
func (x *ConfigEntryUpdate) Reset() {
|
|
*x = ConfigEntryUpdate{}
|
|
if protoimpl.UnsafeEnabled {
|
|
mi := &file_private_pbsubscribe_subscribe_proto_msgTypes[5]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
}
|
|
|
|
func (x *ConfigEntryUpdate) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*ConfigEntryUpdate) ProtoMessage() {}
|
|
|
|
func (x *ConfigEntryUpdate) ProtoReflect() protoreflect.Message {
|
|
mi := &file_private_pbsubscribe_subscribe_proto_msgTypes[5]
|
|
if protoimpl.UnsafeEnabled && x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use ConfigEntryUpdate.ProtoReflect.Descriptor instead.
|
|
func (*ConfigEntryUpdate) Descriptor() ([]byte, []int) {
|
|
return file_private_pbsubscribe_subscribe_proto_rawDescGZIP(), []int{5}
|
|
}
|
|
|
|
func (x *ConfigEntryUpdate) GetOp() ConfigEntryUpdate_UpdateOp {
|
|
if x != nil {
|
|
return x.Op
|
|
}
|
|
return ConfigEntryUpdate_Upsert
|
|
}
|
|
|
|
func (x *ConfigEntryUpdate) GetConfigEntry() *pbconfigentry.ConfigEntry {
|
|
if x != nil {
|
|
return x.ConfigEntry
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type ServiceListUpdate struct {
|
|
state protoimpl.MessageState
|
|
sizeCache protoimpl.SizeCache
|
|
unknownFields protoimpl.UnknownFields
|
|
|
|
Op CatalogOp `protobuf:"varint,1,opt,name=Op,proto3,enum=subscribe.CatalogOp" json:"Op,omitempty"`
|
|
Name string `protobuf:"bytes,2,opt,name=Name,proto3" json:"Name,omitempty"`
|
|
EnterpriseMeta *pbcommon.EnterpriseMeta `protobuf:"bytes,3,opt,name=EnterpriseMeta,proto3" json:"EnterpriseMeta,omitempty"`
|
|
PeerName string `protobuf:"bytes,4,opt,name=PeerName,proto3" json:"PeerName,omitempty"`
|
|
}
|
|
|
|
func (x *ServiceListUpdate) Reset() {
|
|
*x = ServiceListUpdate{}
|
|
if protoimpl.UnsafeEnabled {
|
|
mi := &file_private_pbsubscribe_subscribe_proto_msgTypes[6]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
}
|
|
|
|
func (x *ServiceListUpdate) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*ServiceListUpdate) ProtoMessage() {}
|
|
|
|
func (x *ServiceListUpdate) ProtoReflect() protoreflect.Message {
|
|
mi := &file_private_pbsubscribe_subscribe_proto_msgTypes[6]
|
|
if protoimpl.UnsafeEnabled && x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use ServiceListUpdate.ProtoReflect.Descriptor instead.
|
|
func (*ServiceListUpdate) Descriptor() ([]byte, []int) {
|
|
return file_private_pbsubscribe_subscribe_proto_rawDescGZIP(), []int{6}
|
|
}
|
|
|
|
func (x *ServiceListUpdate) GetOp() CatalogOp {
|
|
if x != nil {
|
|
return x.Op
|
|
}
|
|
return CatalogOp_Register
|
|
}
|
|
|
|
func (x *ServiceListUpdate) GetName() string {
|
|
if x != nil {
|
|
return x.Name
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *ServiceListUpdate) GetEnterpriseMeta() *pbcommon.EnterpriseMeta {
|
|
if x != nil {
|
|
return x.EnterpriseMeta
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *ServiceListUpdate) GetPeerName() string {
|
|
if x != nil {
|
|
return x.PeerName
|
|
}
|
|
return ""
|
|
}
|
|
|
|
var File_private_pbsubscribe_subscribe_proto protoreflect.FileDescriptor
|
|
|
|
var file_private_pbsubscribe_subscribe_proto_rawDesc = []byte{
|
|
0x0a, 0x23, 0x70, 0x72, 0x69, 0x76, 0x61, 0x74, 0x65, 0x2f, 0x70, 0x62, 0x73, 0x75, 0x62, 0x73,
|
|
0x63, 0x72, 0x69, 0x62, 0x65, 0x2f, 0x73, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x62, 0x65, 0x2e,
|
|
0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x09, 0x73, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x62, 0x65,
|
|
0x1a, 0x25, 0x61, 0x6e, 0x6e, 0x6f, 0x74, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x72, 0x61,
|
|
0x74, 0x65, 0x6c, 0x69, 0x6d, 0x69, 0x74, 0x2f, 0x72, 0x61, 0x74, 0x65, 0x6c, 0x69, 0x6d, 0x69,
|
|
0x74, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x1d, 0x70, 0x72, 0x69, 0x76, 0x61, 0x74, 0x65,
|
|
0x2f, 0x70, 0x62, 0x63, 0x6f, 0x6d, 0x6d, 0x6f, 0x6e, 0x2f, 0x63, 0x6f, 0x6d, 0x6d, 0x6f, 0x6e,
|
|
0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x28, 0x70, 0x72, 0x69, 0x76, 0x61, 0x74, 0x65, 0x2f,
|
|
0x70, 0x62, 0x63, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x65, 0x6e, 0x74, 0x72, 0x79, 0x2f, 0x63, 0x6f,
|
|
0x6e, 0x66, 0x69, 0x67, 0x5f, 0x65, 0x6e, 0x74, 0x72, 0x79, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f,
|
|
0x1a, 0x1c, 0x70, 0x72, 0x69, 0x76, 0x61, 0x74, 0x65, 0x2f, 0x70, 0x62, 0x73, 0x65, 0x72, 0x76,
|
|
0x69, 0x63, 0x65, 0x2f, 0x6e, 0x6f, 0x64, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x22, 0x78,
|
|
0x0a, 0x0c, 0x4e, 0x61, 0x6d, 0x65, 0x64, 0x53, 0x75, 0x62, 0x6a, 0x65, 0x63, 0x74, 0x12, 0x10,
|
|
0x0a, 0x03, 0x4b, 0x65, 0x79, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x03, 0x4b, 0x65, 0x79,
|
|
0x12, 0x1c, 0x0a, 0x09, 0x4e, 0x61, 0x6d, 0x65, 0x73, 0x70, 0x61, 0x63, 0x65, 0x18, 0x02, 0x20,
|
|
0x01, 0x28, 0x09, 0x52, 0x09, 0x4e, 0x61, 0x6d, 0x65, 0x73, 0x70, 0x61, 0x63, 0x65, 0x12, 0x1c,
|
|
0x0a, 0x09, 0x50, 0x61, 0x72, 0x74, 0x69, 0x74, 0x69, 0x6f, 0x6e, 0x18, 0x03, 0x20, 0x01, 0x28,
|
|
0x09, 0x52, 0x09, 0x50, 0x61, 0x72, 0x74, 0x69, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x1a, 0x0a, 0x08,
|
|
0x50, 0x65, 0x65, 0x72, 0x4e, 0x61, 0x6d, 0x65, 0x18, 0x04, 0x20, 0x01, 0x28, 0x09, 0x52, 0x08,
|
|
0x50, 0x65, 0x65, 0x72, 0x4e, 0x61, 0x6d, 0x65, 0x22, 0xe6, 0x02, 0x0a, 0x10, 0x53, 0x75, 0x62,
|
|
0x73, 0x63, 0x72, 0x69, 0x62, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x26, 0x0a,
|
|
0x05, 0x54, 0x6f, 0x70, 0x69, 0x63, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x10, 0x2e, 0x73,
|
|
0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x62, 0x65, 0x2e, 0x54, 0x6f, 0x70, 0x69, 0x63, 0x52, 0x05,
|
|
0x54, 0x6f, 0x70, 0x69, 0x63, 0x12, 0x10, 0x0a, 0x03, 0x4b, 0x65, 0x79, 0x18, 0x02, 0x20, 0x01,
|
|
0x28, 0x09, 0x52, 0x03, 0x4b, 0x65, 0x79, 0x12, 0x14, 0x0a, 0x05, 0x54, 0x6f, 0x6b, 0x65, 0x6e,
|
|
0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x54, 0x6f, 0x6b, 0x65, 0x6e, 0x12, 0x14, 0x0a,
|
|
0x05, 0x49, 0x6e, 0x64, 0x65, 0x78, 0x18, 0x04, 0x20, 0x01, 0x28, 0x04, 0x52, 0x05, 0x49, 0x6e,
|
|
0x64, 0x65, 0x78, 0x12, 0x1e, 0x0a, 0x0a, 0x44, 0x61, 0x74, 0x61, 0x63, 0x65, 0x6e, 0x74, 0x65,
|
|
0x72, 0x18, 0x05, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0a, 0x44, 0x61, 0x74, 0x61, 0x63, 0x65, 0x6e,
|
|
0x74, 0x65, 0x72, 0x12, 0x1c, 0x0a, 0x09, 0x4e, 0x61, 0x6d, 0x65, 0x73, 0x70, 0x61, 0x63, 0x65,
|
|
0x18, 0x06, 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x4e, 0x61, 0x6d, 0x65, 0x73, 0x70, 0x61, 0x63,
|
|
0x65, 0x12, 0x1c, 0x0a, 0x09, 0x50, 0x61, 0x72, 0x74, 0x69, 0x74, 0x69, 0x6f, 0x6e, 0x18, 0x07,
|
|
0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x50, 0x61, 0x72, 0x74, 0x69, 0x74, 0x69, 0x6f, 0x6e, 0x12,
|
|
0x1a, 0x0a, 0x08, 0x50, 0x65, 0x65, 0x72, 0x4e, 0x61, 0x6d, 0x65, 0x18, 0x08, 0x20, 0x01, 0x28,
|
|
0x09, 0x52, 0x08, 0x50, 0x65, 0x65, 0x72, 0x4e, 0x61, 0x6d, 0x65, 0x12, 0x2a, 0x0a, 0x0f, 0x57,
|
|
0x69, 0x6c, 0x64, 0x63, 0x61, 0x72, 0x64, 0x53, 0x75, 0x62, 0x6a, 0x65, 0x63, 0x74, 0x18, 0x09,
|
|
0x20, 0x01, 0x28, 0x08, 0x48, 0x00, 0x52, 0x0f, 0x57, 0x69, 0x6c, 0x64, 0x63, 0x61, 0x72, 0x64,
|
|
0x53, 0x75, 0x62, 0x6a, 0x65, 0x63, 0x74, 0x12, 0x3d, 0x0a, 0x0c, 0x4e, 0x61, 0x6d, 0x65, 0x64,
|
|
0x53, 0x75, 0x62, 0x6a, 0x65, 0x63, 0x74, 0x18, 0x0a, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x17, 0x2e,
|
|
0x73, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x62, 0x65, 0x2e, 0x4e, 0x61, 0x6d, 0x65, 0x64, 0x53,
|
|
0x75, 0x62, 0x6a, 0x65, 0x63, 0x74, 0x48, 0x00, 0x52, 0x0c, 0x4e, 0x61, 0x6d, 0x65, 0x64, 0x53,
|
|
0x75, 0x62, 0x6a, 0x65, 0x63, 0x74, 0x42, 0x09, 0x0a, 0x07, 0x53, 0x75, 0x62, 0x6a, 0x65, 0x63,
|
|
0x74, 0x22, 0x81, 0x03, 0x0a, 0x05, 0x45, 0x76, 0x65, 0x6e, 0x74, 0x12, 0x14, 0x0a, 0x05, 0x49,
|
|
0x6e, 0x64, 0x65, 0x78, 0x18, 0x01, 0x20, 0x01, 0x28, 0x04, 0x52, 0x05, 0x49, 0x6e, 0x64, 0x65,
|
|
0x78, 0x12, 0x26, 0x0a, 0x0d, 0x45, 0x6e, 0x64, 0x4f, 0x66, 0x53, 0x6e, 0x61, 0x70, 0x73, 0x68,
|
|
0x6f, 0x74, 0x18, 0x02, 0x20, 0x01, 0x28, 0x08, 0x48, 0x00, 0x52, 0x0d, 0x45, 0x6e, 0x64, 0x4f,
|
|
0x66, 0x53, 0x6e, 0x61, 0x70, 0x73, 0x68, 0x6f, 0x74, 0x12, 0x32, 0x0a, 0x13, 0x4e, 0x65, 0x77,
|
|
0x53, 0x6e, 0x61, 0x70, 0x73, 0x68, 0x6f, 0x74, 0x54, 0x6f, 0x46, 0x6f, 0x6c, 0x6c, 0x6f, 0x77,
|
|
0x18, 0x03, 0x20, 0x01, 0x28, 0x08, 0x48, 0x00, 0x52, 0x13, 0x4e, 0x65, 0x77, 0x53, 0x6e, 0x61,
|
|
0x70, 0x73, 0x68, 0x6f, 0x74, 0x54, 0x6f, 0x46, 0x6f, 0x6c, 0x6c, 0x6f, 0x77, 0x12, 0x37, 0x0a,
|
|
0x0a, 0x45, 0x76, 0x65, 0x6e, 0x74, 0x42, 0x61, 0x74, 0x63, 0x68, 0x18, 0x04, 0x20, 0x01, 0x28,
|
|
0x0b, 0x32, 0x15, 0x2e, 0x73, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x62, 0x65, 0x2e, 0x45, 0x76,
|
|
0x65, 0x6e, 0x74, 0x42, 0x61, 0x74, 0x63, 0x68, 0x48, 0x00, 0x52, 0x0a, 0x45, 0x76, 0x65, 0x6e,
|
|
0x74, 0x42, 0x61, 0x74, 0x63, 0x68, 0x12, 0x46, 0x0a, 0x0d, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63,
|
|
0x65, 0x48, 0x65, 0x61, 0x6c, 0x74, 0x68, 0x18, 0x0a, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1e, 0x2e,
|
|
0x73, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x62, 0x65, 0x2e, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63,
|
|
0x65, 0x48, 0x65, 0x61, 0x6c, 0x74, 0x68, 0x55, 0x70, 0x64, 0x61, 0x74, 0x65, 0x48, 0x00, 0x52,
|
|
0x0d, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x48, 0x65, 0x61, 0x6c, 0x74, 0x68, 0x12, 0x40,
|
|
0x0a, 0x0b, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x18, 0x0b, 0x20,
|
|
0x01, 0x28, 0x0b, 0x32, 0x1c, 0x2e, 0x73, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x62, 0x65, 0x2e,
|
|
0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x55, 0x70, 0x64, 0x61, 0x74,
|
|
0x65, 0x48, 0x00, 0x52, 0x0b, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x45, 0x6e, 0x74, 0x72, 0x79,
|
|
0x12, 0x38, 0x0a, 0x07, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x18, 0x0c, 0x20, 0x01, 0x28,
|
|
0x0b, 0x32, 0x1c, 0x2e, 0x73, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x62, 0x65, 0x2e, 0x53, 0x65,
|
|
0x72, 0x76, 0x69, 0x63, 0x65, 0x4c, 0x69, 0x73, 0x74, 0x55, 0x70, 0x64, 0x61, 0x74, 0x65, 0x48,
|
|
0x00, 0x52, 0x07, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x42, 0x09, 0x0a, 0x07, 0x50, 0x61,
|
|
0x79, 0x6c, 0x6f, 0x61, 0x64, 0x22, 0x36, 0x0a, 0x0a, 0x45, 0x76, 0x65, 0x6e, 0x74, 0x42, 0x61,
|
|
0x74, 0x63, 0x68, 0x12, 0x28, 0x0a, 0x06, 0x45, 0x76, 0x65, 0x6e, 0x74, 0x73, 0x18, 0x01, 0x20,
|
|
0x03, 0x28, 0x0b, 0x32, 0x10, 0x2e, 0x73, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x62, 0x65, 0x2e,
|
|
0x45, 0x76, 0x65, 0x6e, 0x74, 0x52, 0x06, 0x45, 0x76, 0x65, 0x6e, 0x74, 0x73, 0x22, 0x9c, 0x01,
|
|
0x0a, 0x13, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x48, 0x65, 0x61, 0x6c, 0x74, 0x68, 0x55,
|
|
0x70, 0x64, 0x61, 0x74, 0x65, 0x12, 0x24, 0x0a, 0x02, 0x4f, 0x70, 0x18, 0x01, 0x20, 0x01, 0x28,
|
|
0x0e, 0x32, 0x14, 0x2e, 0x73, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x62, 0x65, 0x2e, 0x43, 0x61,
|
|
0x74, 0x61, 0x6c, 0x6f, 0x67, 0x4f, 0x70, 0x52, 0x02, 0x4f, 0x70, 0x12, 0x5f, 0x0a, 0x10, 0x43,
|
|
0x68, 0x65, 0x63, 0x6b, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x4e, 0x6f, 0x64, 0x65, 0x18,
|
|
0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x33, 0x2e, 0x68, 0x61, 0x73, 0x68, 0x69, 0x63, 0x6f, 0x72,
|
|
0x70, 0x2e, 0x63, 0x6f, 0x6e, 0x73, 0x75, 0x6c, 0x2e, 0x69, 0x6e, 0x74, 0x65, 0x72, 0x6e, 0x61,
|
|
0x6c, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x43, 0x68, 0x65, 0x63, 0x6b, 0x53,
|
|
0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x4e, 0x6f, 0x64, 0x65, 0x52, 0x10, 0x43, 0x68, 0x65, 0x63,
|
|
0x6b, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x4e, 0x6f, 0x64, 0x65, 0x22, 0xc4, 0x01, 0x0a,
|
|
0x11, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x55, 0x70, 0x64, 0x61,
|
|
0x74, 0x65, 0x12, 0x35, 0x0a, 0x02, 0x4f, 0x70, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x25,
|
|
0x2e, 0x73, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x62, 0x65, 0x2e, 0x43, 0x6f, 0x6e, 0x66, 0x69,
|
|
0x67, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x55, 0x70, 0x64, 0x61, 0x74, 0x65, 0x2e, 0x55, 0x70, 0x64,
|
|
0x61, 0x74, 0x65, 0x4f, 0x70, 0x52, 0x02, 0x4f, 0x70, 0x12, 0x54, 0x0a, 0x0b, 0x43, 0x6f, 0x6e,
|
|
0x66, 0x69, 0x67, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x32,
|
|
0x2e, 0x68, 0x61, 0x73, 0x68, 0x69, 0x63, 0x6f, 0x72, 0x70, 0x2e, 0x63, 0x6f, 0x6e, 0x73, 0x75,
|
|
0x6c, 0x2e, 0x69, 0x6e, 0x74, 0x65, 0x72, 0x6e, 0x61, 0x6c, 0x2e, 0x63, 0x6f, 0x6e, 0x66, 0x69,
|
|
0x67, 0x65, 0x6e, 0x74, 0x72, 0x79, 0x2e, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x45, 0x6e, 0x74,
|
|
0x72, 0x79, 0x52, 0x0b, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x22,
|
|
0x22, 0x0a, 0x08, 0x55, 0x70, 0x64, 0x61, 0x74, 0x65, 0x4f, 0x70, 0x12, 0x0a, 0x0a, 0x06, 0x55,
|
|
0x70, 0x73, 0x65, 0x72, 0x74, 0x10, 0x00, 0x12, 0x0a, 0x0a, 0x06, 0x44, 0x65, 0x6c, 0x65, 0x74,
|
|
0x65, 0x10, 0x01, 0x22, 0xc3, 0x01, 0x0a, 0x11, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x4c,
|
|
0x69, 0x73, 0x74, 0x55, 0x70, 0x64, 0x61, 0x74, 0x65, 0x12, 0x24, 0x0a, 0x02, 0x4f, 0x70, 0x18,
|
|
0x01, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x14, 0x2e, 0x73, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x62,
|
|
0x65, 0x2e, 0x43, 0x61, 0x74, 0x61, 0x6c, 0x6f, 0x67, 0x4f, 0x70, 0x52, 0x02, 0x4f, 0x70, 0x12,
|
|
0x12, 0x0a, 0x04, 0x4e, 0x61, 0x6d, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x4e,
|
|
0x61, 0x6d, 0x65, 0x12, 0x58, 0x0a, 0x0e, 0x45, 0x6e, 0x74, 0x65, 0x72, 0x70, 0x72, 0x69, 0x73,
|
|
0x65, 0x4d, 0x65, 0x74, 0x61, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x30, 0x2e, 0x68, 0x61,
|
|
0x73, 0x68, 0x69, 0x63, 0x6f, 0x72, 0x70, 0x2e, 0x63, 0x6f, 0x6e, 0x73, 0x75, 0x6c, 0x2e, 0x69,
|
|
0x6e, 0x74, 0x65, 0x72, 0x6e, 0x61, 0x6c, 0x2e, 0x63, 0x6f, 0x6d, 0x6d, 0x6f, 0x6e, 0x2e, 0x45,
|
|
0x6e, 0x74, 0x65, 0x72, 0x70, 0x72, 0x69, 0x73, 0x65, 0x4d, 0x65, 0x74, 0x61, 0x52, 0x0e, 0x45,
|
|
0x6e, 0x74, 0x65, 0x72, 0x70, 0x72, 0x69, 0x73, 0x65, 0x4d, 0x65, 0x74, 0x61, 0x12, 0x1a, 0x0a,
|
|
0x08, 0x50, 0x65, 0x65, 0x72, 0x4e, 0x61, 0x6d, 0x65, 0x18, 0x04, 0x20, 0x01, 0x28, 0x09, 0x52,
|
|
0x08, 0x50, 0x65, 0x65, 0x72, 0x4e, 0x61, 0x6d, 0x65, 0x2a, 0xc5, 0x02, 0x0a, 0x05, 0x54, 0x6f,
|
|
0x70, 0x69, 0x63, 0x12, 0x0b, 0x0a, 0x07, 0x55, 0x6e, 0x6b, 0x6e, 0x6f, 0x77, 0x6e, 0x10, 0x00,
|
|
0x12, 0x11, 0x0a, 0x0d, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x48, 0x65, 0x61, 0x6c, 0x74,
|
|
0x68, 0x10, 0x01, 0x12, 0x18, 0x0a, 0x14, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x48, 0x65,
|
|
0x61, 0x6c, 0x74, 0x68, 0x43, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x10, 0x02, 0x12, 0x0e, 0x0a,
|
|
0x0a, 0x4d, 0x65, 0x73, 0x68, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x10, 0x03, 0x12, 0x13, 0x0a,
|
|
0x0f, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x52, 0x65, 0x73, 0x6f, 0x6c, 0x76, 0x65, 0x72,
|
|
0x10, 0x04, 0x12, 0x12, 0x0a, 0x0e, 0x49, 0x6e, 0x67, 0x72, 0x65, 0x73, 0x73, 0x47, 0x61, 0x74,
|
|
0x65, 0x77, 0x61, 0x79, 0x10, 0x05, 0x12, 0x15, 0x0a, 0x11, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63,
|
|
0x65, 0x49, 0x6e, 0x74, 0x65, 0x6e, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x10, 0x06, 0x12, 0x0f, 0x0a,
|
|
0x0b, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x4c, 0x69, 0x73, 0x74, 0x10, 0x07, 0x12, 0x13,
|
|
0x0a, 0x0f, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x44, 0x65, 0x66, 0x61, 0x75, 0x6c, 0x74,
|
|
0x73, 0x10, 0x08, 0x12, 0x0e, 0x0a, 0x0a, 0x41, 0x50, 0x49, 0x47, 0x61, 0x74, 0x65, 0x77, 0x61,
|
|
0x79, 0x10, 0x09, 0x12, 0x0c, 0x0a, 0x08, 0x54, 0x43, 0x50, 0x52, 0x6f, 0x75, 0x74, 0x65, 0x10,
|
|
0x0a, 0x12, 0x0d, 0x0a, 0x09, 0x48, 0x54, 0x54, 0x50, 0x52, 0x6f, 0x75, 0x74, 0x65, 0x10, 0x0b,
|
|
0x12, 0x15, 0x0a, 0x11, 0x49, 0x6e, 0x6c, 0x69, 0x6e, 0x65, 0x43, 0x65, 0x72, 0x74, 0x69, 0x66,
|
|
0x69, 0x63, 0x61, 0x74, 0x65, 0x10, 0x0c, 0x12, 0x13, 0x0a, 0x0f, 0x42, 0x6f, 0x75, 0x6e, 0x64,
|
|
0x41, 0x50, 0x49, 0x47, 0x61, 0x74, 0x65, 0x77, 0x61, 0x79, 0x10, 0x0d, 0x12, 0x0f, 0x0a, 0x0b,
|
|
0x49, 0x50, 0x52, 0x61, 0x74, 0x65, 0x4c, 0x69, 0x6d, 0x69, 0x74, 0x10, 0x0e, 0x12, 0x11, 0x0a,
|
|
0x0d, 0x53, 0x61, 0x6d, 0x65, 0x6e, 0x65, 0x73, 0x73, 0x47, 0x72, 0x6f, 0x75, 0x70, 0x10, 0x0f,
|
|
0x12, 0x0f, 0x0a, 0x0b, 0x4a, 0x57, 0x54, 0x50, 0x72, 0x6f, 0x76, 0x69, 0x64, 0x65, 0x72, 0x10,
|
|
0x10, 0x2a, 0x29, 0x0a, 0x09, 0x43, 0x61, 0x74, 0x61, 0x6c, 0x6f, 0x67, 0x4f, 0x70, 0x12, 0x0c,
|
|
0x0a, 0x08, 0x52, 0x65, 0x67, 0x69, 0x73, 0x74, 0x65, 0x72, 0x10, 0x00, 0x12, 0x0e, 0x0a, 0x0a,
|
|
0x44, 0x65, 0x72, 0x65, 0x67, 0x69, 0x73, 0x74, 0x65, 0x72, 0x10, 0x01, 0x32, 0x61, 0x0a, 0x17,
|
|
0x53, 0x74, 0x61, 0x74, 0x65, 0x43, 0x68, 0x61, 0x6e, 0x67, 0x65, 0x53, 0x75, 0x62, 0x73, 0x63,
|
|
0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x46, 0x0a, 0x09, 0x53, 0x75, 0x62, 0x73, 0x63,
|
|
0x72, 0x69, 0x62, 0x65, 0x12, 0x1b, 0x2e, 0x73, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x62, 0x65,
|
|
0x2e, 0x53, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x62, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73,
|
|
0x74, 0x1a, 0x10, 0x2e, 0x73, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x62, 0x65, 0x2e, 0x45, 0x76,
|
|
0x65, 0x6e, 0x74, 0x22, 0x08, 0xe2, 0x86, 0x04, 0x04, 0x08, 0x02, 0x10, 0x09, 0x30, 0x01, 0x42,
|
|
0x9a, 0x01, 0x0a, 0x0d, 0x63, 0x6f, 0x6d, 0x2e, 0x73, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x62,
|
|
0x65, 0x42, 0x0e, 0x53, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x62, 0x65, 0x50, 0x72, 0x6f, 0x74,
|
|
0x6f, 0x50, 0x01, 0x5a, 0x35, 0x67, 0x69, 0x74, 0x68, 0x75, 0x62, 0x2e, 0x63, 0x6f, 0x6d, 0x2f,
|
|
0x68, 0x61, 0x73, 0x68, 0x69, 0x63, 0x6f, 0x72, 0x70, 0x2f, 0x63, 0x6f, 0x6e, 0x73, 0x75, 0x6c,
|
|
0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2f, 0x70, 0x72, 0x69, 0x76, 0x61, 0x74, 0x65, 0x2f, 0x70,
|
|
0x62, 0x73, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x62, 0x65, 0xa2, 0x02, 0x03, 0x53, 0x58, 0x58,
|
|
0xaa, 0x02, 0x09, 0x53, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x62, 0x65, 0xca, 0x02, 0x09, 0x53,
|
|
0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x62, 0x65, 0xe2, 0x02, 0x15, 0x53, 0x75, 0x62, 0x73, 0x63,
|
|
0x72, 0x69, 0x62, 0x65, 0x5c, 0x47, 0x50, 0x42, 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61,
|
|
0xea, 0x02, 0x09, 0x53, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x62, 0x65, 0x62, 0x06, 0x70, 0x72,
|
|
0x6f, 0x74, 0x6f, 0x33,
|
|
}
|
|
|
|
var (
|
|
file_private_pbsubscribe_subscribe_proto_rawDescOnce sync.Once
|
|
file_private_pbsubscribe_subscribe_proto_rawDescData = file_private_pbsubscribe_subscribe_proto_rawDesc
|
|
)
|
|
|
|
func file_private_pbsubscribe_subscribe_proto_rawDescGZIP() []byte {
|
|
file_private_pbsubscribe_subscribe_proto_rawDescOnce.Do(func() {
|
|
file_private_pbsubscribe_subscribe_proto_rawDescData = protoimpl.X.CompressGZIP(file_private_pbsubscribe_subscribe_proto_rawDescData)
|
|
})
|
|
return file_private_pbsubscribe_subscribe_proto_rawDescData
|
|
}
|
|
|
|
var file_private_pbsubscribe_subscribe_proto_enumTypes = make([]protoimpl.EnumInfo, 3)
|
|
var file_private_pbsubscribe_subscribe_proto_msgTypes = make([]protoimpl.MessageInfo, 7)
|
|
var file_private_pbsubscribe_subscribe_proto_goTypes = []interface{}{
|
|
(Topic)(0), // 0: subscribe.Topic
|
|
(CatalogOp)(0), // 1: subscribe.CatalogOp
|
|
(ConfigEntryUpdate_UpdateOp)(0), // 2: subscribe.ConfigEntryUpdate.UpdateOp
|
|
(*NamedSubject)(nil), // 3: subscribe.NamedSubject
|
|
(*SubscribeRequest)(nil), // 4: subscribe.SubscribeRequest
|
|
(*Event)(nil), // 5: subscribe.Event
|
|
(*EventBatch)(nil), // 6: subscribe.EventBatch
|
|
(*ServiceHealthUpdate)(nil), // 7: subscribe.ServiceHealthUpdate
|
|
(*ConfigEntryUpdate)(nil), // 8: subscribe.ConfigEntryUpdate
|
|
(*ServiceListUpdate)(nil), // 9: subscribe.ServiceListUpdate
|
|
(*pbservice.CheckServiceNode)(nil), // 10: hashicorp.consul.internal.service.CheckServiceNode
|
|
(*pbconfigentry.ConfigEntry)(nil), // 11: hashicorp.consul.internal.configentry.ConfigEntry
|
|
(*pbcommon.EnterpriseMeta)(nil), // 12: hashicorp.consul.internal.common.EnterpriseMeta
|
|
}
|
|
var file_private_pbsubscribe_subscribe_proto_depIdxs = []int32{
|
|
0, // 0: subscribe.SubscribeRequest.Topic:type_name -> subscribe.Topic
|
|
3, // 1: subscribe.SubscribeRequest.NamedSubject:type_name -> subscribe.NamedSubject
|
|
6, // 2: subscribe.Event.EventBatch:type_name -> subscribe.EventBatch
|
|
7, // 3: subscribe.Event.ServiceHealth:type_name -> subscribe.ServiceHealthUpdate
|
|
8, // 4: subscribe.Event.ConfigEntry:type_name -> subscribe.ConfigEntryUpdate
|
|
9, // 5: subscribe.Event.Service:type_name -> subscribe.ServiceListUpdate
|
|
5, // 6: subscribe.EventBatch.Events:type_name -> subscribe.Event
|
|
1, // 7: subscribe.ServiceHealthUpdate.Op:type_name -> subscribe.CatalogOp
|
|
10, // 8: subscribe.ServiceHealthUpdate.CheckServiceNode:type_name -> hashicorp.consul.internal.service.CheckServiceNode
|
|
2, // 9: subscribe.ConfigEntryUpdate.Op:type_name -> subscribe.ConfigEntryUpdate.UpdateOp
|
|
11, // 10: subscribe.ConfigEntryUpdate.ConfigEntry:type_name -> hashicorp.consul.internal.configentry.ConfigEntry
|
|
1, // 11: subscribe.ServiceListUpdate.Op:type_name -> subscribe.CatalogOp
|
|
12, // 12: subscribe.ServiceListUpdate.EnterpriseMeta:type_name -> hashicorp.consul.internal.common.EnterpriseMeta
|
|
4, // 13: subscribe.StateChangeSubscription.Subscribe:input_type -> subscribe.SubscribeRequest
|
|
5, // 14: subscribe.StateChangeSubscription.Subscribe:output_type -> subscribe.Event
|
|
14, // [14:15] is the sub-list for method output_type
|
|
13, // [13:14] is the sub-list for method input_type
|
|
13, // [13:13] is the sub-list for extension type_name
|
|
13, // [13:13] is the sub-list for extension extendee
|
|
0, // [0:13] is the sub-list for field type_name
|
|
}
|
|
|
|
func init() { file_private_pbsubscribe_subscribe_proto_init() }
|
|
func file_private_pbsubscribe_subscribe_proto_init() {
|
|
if File_private_pbsubscribe_subscribe_proto != nil {
|
|
return
|
|
}
|
|
if !protoimpl.UnsafeEnabled {
|
|
file_private_pbsubscribe_subscribe_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
|
|
switch v := v.(*NamedSubject); i {
|
|
case 0:
|
|
return &v.state
|
|
case 1:
|
|
return &v.sizeCache
|
|
case 2:
|
|
return &v.unknownFields
|
|
default:
|
|
return nil
|
|
}
|
|
}
|
|
file_private_pbsubscribe_subscribe_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
|
|
switch v := v.(*SubscribeRequest); i {
|
|
case 0:
|
|
return &v.state
|
|
case 1:
|
|
return &v.sizeCache
|
|
case 2:
|
|
return &v.unknownFields
|
|
default:
|
|
return nil
|
|
}
|
|
}
|
|
file_private_pbsubscribe_subscribe_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} {
|
|
switch v := v.(*Event); i {
|
|
case 0:
|
|
return &v.state
|
|
case 1:
|
|
return &v.sizeCache
|
|
case 2:
|
|
return &v.unknownFields
|
|
default:
|
|
return nil
|
|
}
|
|
}
|
|
file_private_pbsubscribe_subscribe_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} {
|
|
switch v := v.(*EventBatch); i {
|
|
case 0:
|
|
return &v.state
|
|
case 1:
|
|
return &v.sizeCache
|
|
case 2:
|
|
return &v.unknownFields
|
|
default:
|
|
return nil
|
|
}
|
|
}
|
|
file_private_pbsubscribe_subscribe_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} {
|
|
switch v := v.(*ServiceHealthUpdate); i {
|
|
case 0:
|
|
return &v.state
|
|
case 1:
|
|
return &v.sizeCache
|
|
case 2:
|
|
return &v.unknownFields
|
|
default:
|
|
return nil
|
|
}
|
|
}
|
|
file_private_pbsubscribe_subscribe_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} {
|
|
switch v := v.(*ConfigEntryUpdate); i {
|
|
case 0:
|
|
return &v.state
|
|
case 1:
|
|
return &v.sizeCache
|
|
case 2:
|
|
return &v.unknownFields
|
|
default:
|
|
return nil
|
|
}
|
|
}
|
|
file_private_pbsubscribe_subscribe_proto_msgTypes[6].Exporter = func(v interface{}, i int) interface{} {
|
|
switch v := v.(*ServiceListUpdate); i {
|
|
case 0:
|
|
return &v.state
|
|
case 1:
|
|
return &v.sizeCache
|
|
case 2:
|
|
return &v.unknownFields
|
|
default:
|
|
return nil
|
|
}
|
|
}
|
|
}
|
|
file_private_pbsubscribe_subscribe_proto_msgTypes[1].OneofWrappers = []interface{}{
|
|
(*SubscribeRequest_WildcardSubject)(nil),
|
|
(*SubscribeRequest_NamedSubject)(nil),
|
|
}
|
|
file_private_pbsubscribe_subscribe_proto_msgTypes[2].OneofWrappers = []interface{}{
|
|
(*Event_EndOfSnapshot)(nil),
|
|
(*Event_NewSnapshotToFollow)(nil),
|
|
(*Event_EventBatch)(nil),
|
|
(*Event_ServiceHealth)(nil),
|
|
(*Event_ConfigEntry)(nil),
|
|
(*Event_Service)(nil),
|
|
}
|
|
type x struct{}
|
|
out := protoimpl.TypeBuilder{
|
|
File: protoimpl.DescBuilder{
|
|
GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
|
|
RawDescriptor: file_private_pbsubscribe_subscribe_proto_rawDesc,
|
|
NumEnums: 3,
|
|
NumMessages: 7,
|
|
NumExtensions: 0,
|
|
NumServices: 1,
|
|
},
|
|
GoTypes: file_private_pbsubscribe_subscribe_proto_goTypes,
|
|
DependencyIndexes: file_private_pbsubscribe_subscribe_proto_depIdxs,
|
|
EnumInfos: file_private_pbsubscribe_subscribe_proto_enumTypes,
|
|
MessageInfos: file_private_pbsubscribe_subscribe_proto_msgTypes,
|
|
}.Build()
|
|
File_private_pbsubscribe_subscribe_proto = out.File
|
|
file_private_pbsubscribe_subscribe_proto_rawDesc = nil
|
|
file_private_pbsubscribe_subscribe_proto_goTypes = nil
|
|
file_private_pbsubscribe_subscribe_proto_depIdxs = nil
|
|
}
|