1// Code generated by protoc-gen-go. DO NOT EDIT. 2// source: envoy/service/status/v3/csds.proto 3 4package envoy_service_status_v3 5 6import ( 7 context "context" 8 fmt "fmt" 9 _ "github.com/cncf/udpa/go/udpa/annotations" 10 v31 "github.com/envoyproxy/go-control-plane/envoy/admin/v3" 11 v32 "github.com/envoyproxy/go-control-plane/envoy/config/core/v3" 12 v3 "github.com/envoyproxy/go-control-plane/envoy/type/matcher/v3" 13 proto "github.com/golang/protobuf/proto" 14 _ "github.com/golang/protobuf/ptypes/struct" 15 _ "google.golang.org/genproto/googleapis/api/annotations" 16 grpc "google.golang.org/grpc" 17 codes "google.golang.org/grpc/codes" 18 status "google.golang.org/grpc/status" 19 math "math" 20) 21 22// Reference imports to suppress errors if they are not otherwise used. 23var _ = proto.Marshal 24var _ = fmt.Errorf 25var _ = math.Inf 26 27// This is a compile-time assertion to ensure that this generated file 28// is compatible with the proto package it is being compiled against. 29// A compilation error at this line likely means your copy of the 30// proto package needs to be updated. 31const _ = proto.ProtoPackageIsVersion3 // please upgrade the proto package 32 33type ConfigStatus int32 34 35const ( 36 ConfigStatus_UNKNOWN ConfigStatus = 0 37 ConfigStatus_SYNCED ConfigStatus = 1 38 ConfigStatus_NOT_SENT ConfigStatus = 2 39 ConfigStatus_STALE ConfigStatus = 3 40 ConfigStatus_ERROR ConfigStatus = 4 41) 42 43var ConfigStatus_name = map[int32]string{ 44 0: "UNKNOWN", 45 1: "SYNCED", 46 2: "NOT_SENT", 47 3: "STALE", 48 4: "ERROR", 49} 50 51var ConfigStatus_value = map[string]int32{ 52 "UNKNOWN": 0, 53 "SYNCED": 1, 54 "NOT_SENT": 2, 55 "STALE": 3, 56 "ERROR": 4, 57} 58 59func (x ConfigStatus) String() string { 60 return proto.EnumName(ConfigStatus_name, int32(x)) 61} 62 63func (ConfigStatus) EnumDescriptor() ([]byte, []int) { 64 return fileDescriptor_d6ae65ba18d04178, []int{0} 65} 66 67type ClientStatusRequest struct { 68 NodeMatchers []*v3.NodeMatcher `protobuf:"bytes,1,rep,name=node_matchers,json=nodeMatchers,proto3" json:"node_matchers,omitempty"` 69 XXX_NoUnkeyedLiteral struct{} `json:"-"` 70 XXX_unrecognized []byte `json:"-"` 71 XXX_sizecache int32 `json:"-"` 72} 73 74func (m *ClientStatusRequest) Reset() { *m = ClientStatusRequest{} } 75func (m *ClientStatusRequest) String() string { return proto.CompactTextString(m) } 76func (*ClientStatusRequest) ProtoMessage() {} 77func (*ClientStatusRequest) Descriptor() ([]byte, []int) { 78 return fileDescriptor_d6ae65ba18d04178, []int{0} 79} 80 81func (m *ClientStatusRequest) XXX_Unmarshal(b []byte) error { 82 return xxx_messageInfo_ClientStatusRequest.Unmarshal(m, b) 83} 84func (m *ClientStatusRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 85 return xxx_messageInfo_ClientStatusRequest.Marshal(b, m, deterministic) 86} 87func (m *ClientStatusRequest) XXX_Merge(src proto.Message) { 88 xxx_messageInfo_ClientStatusRequest.Merge(m, src) 89} 90func (m *ClientStatusRequest) XXX_Size() int { 91 return xxx_messageInfo_ClientStatusRequest.Size(m) 92} 93func (m *ClientStatusRequest) XXX_DiscardUnknown() { 94 xxx_messageInfo_ClientStatusRequest.DiscardUnknown(m) 95} 96 97var xxx_messageInfo_ClientStatusRequest proto.InternalMessageInfo 98 99func (m *ClientStatusRequest) GetNodeMatchers() []*v3.NodeMatcher { 100 if m != nil { 101 return m.NodeMatchers 102 } 103 return nil 104} 105 106type PerXdsConfig struct { 107 Status ConfigStatus `protobuf:"varint,1,opt,name=status,proto3,enum=envoy.service.status.v3.ConfigStatus" json:"status,omitempty"` 108 // Types that are valid to be assigned to PerXdsConfig: 109 // *PerXdsConfig_ListenerConfig 110 // *PerXdsConfig_ClusterConfig 111 // *PerXdsConfig_RouteConfig 112 // *PerXdsConfig_ScopedRouteConfig 113 PerXdsConfig isPerXdsConfig_PerXdsConfig `protobuf_oneof:"per_xds_config"` 114 XXX_NoUnkeyedLiteral struct{} `json:"-"` 115 XXX_unrecognized []byte `json:"-"` 116 XXX_sizecache int32 `json:"-"` 117} 118 119func (m *PerXdsConfig) Reset() { *m = PerXdsConfig{} } 120func (m *PerXdsConfig) String() string { return proto.CompactTextString(m) } 121func (*PerXdsConfig) ProtoMessage() {} 122func (*PerXdsConfig) Descriptor() ([]byte, []int) { 123 return fileDescriptor_d6ae65ba18d04178, []int{1} 124} 125 126func (m *PerXdsConfig) XXX_Unmarshal(b []byte) error { 127 return xxx_messageInfo_PerXdsConfig.Unmarshal(m, b) 128} 129func (m *PerXdsConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 130 return xxx_messageInfo_PerXdsConfig.Marshal(b, m, deterministic) 131} 132func (m *PerXdsConfig) XXX_Merge(src proto.Message) { 133 xxx_messageInfo_PerXdsConfig.Merge(m, src) 134} 135func (m *PerXdsConfig) XXX_Size() int { 136 return xxx_messageInfo_PerXdsConfig.Size(m) 137} 138func (m *PerXdsConfig) XXX_DiscardUnknown() { 139 xxx_messageInfo_PerXdsConfig.DiscardUnknown(m) 140} 141 142var xxx_messageInfo_PerXdsConfig proto.InternalMessageInfo 143 144func (m *PerXdsConfig) GetStatus() ConfigStatus { 145 if m != nil { 146 return m.Status 147 } 148 return ConfigStatus_UNKNOWN 149} 150 151type isPerXdsConfig_PerXdsConfig interface { 152 isPerXdsConfig_PerXdsConfig() 153} 154 155type PerXdsConfig_ListenerConfig struct { 156 ListenerConfig *v31.ListenersConfigDump `protobuf:"bytes,2,opt,name=listener_config,json=listenerConfig,proto3,oneof"` 157} 158 159type PerXdsConfig_ClusterConfig struct { 160 ClusterConfig *v31.ClustersConfigDump `protobuf:"bytes,3,opt,name=cluster_config,json=clusterConfig,proto3,oneof"` 161} 162 163type PerXdsConfig_RouteConfig struct { 164 RouteConfig *v31.RoutesConfigDump `protobuf:"bytes,4,opt,name=route_config,json=routeConfig,proto3,oneof"` 165} 166 167type PerXdsConfig_ScopedRouteConfig struct { 168 ScopedRouteConfig *v31.ScopedRoutesConfigDump `protobuf:"bytes,5,opt,name=scoped_route_config,json=scopedRouteConfig,proto3,oneof"` 169} 170 171func (*PerXdsConfig_ListenerConfig) isPerXdsConfig_PerXdsConfig() {} 172 173func (*PerXdsConfig_ClusterConfig) isPerXdsConfig_PerXdsConfig() {} 174 175func (*PerXdsConfig_RouteConfig) isPerXdsConfig_PerXdsConfig() {} 176 177func (*PerXdsConfig_ScopedRouteConfig) isPerXdsConfig_PerXdsConfig() {} 178 179func (m *PerXdsConfig) GetPerXdsConfig() isPerXdsConfig_PerXdsConfig { 180 if m != nil { 181 return m.PerXdsConfig 182 } 183 return nil 184} 185 186func (m *PerXdsConfig) GetListenerConfig() *v31.ListenersConfigDump { 187 if x, ok := m.GetPerXdsConfig().(*PerXdsConfig_ListenerConfig); ok { 188 return x.ListenerConfig 189 } 190 return nil 191} 192 193func (m *PerXdsConfig) GetClusterConfig() *v31.ClustersConfigDump { 194 if x, ok := m.GetPerXdsConfig().(*PerXdsConfig_ClusterConfig); ok { 195 return x.ClusterConfig 196 } 197 return nil 198} 199 200func (m *PerXdsConfig) GetRouteConfig() *v31.RoutesConfigDump { 201 if x, ok := m.GetPerXdsConfig().(*PerXdsConfig_RouteConfig); ok { 202 return x.RouteConfig 203 } 204 return nil 205} 206 207func (m *PerXdsConfig) GetScopedRouteConfig() *v31.ScopedRoutesConfigDump { 208 if x, ok := m.GetPerXdsConfig().(*PerXdsConfig_ScopedRouteConfig); ok { 209 return x.ScopedRouteConfig 210 } 211 return nil 212} 213 214// XXX_OneofWrappers is for the internal use of the proto package. 215func (*PerXdsConfig) XXX_OneofWrappers() []interface{} { 216 return []interface{}{ 217 (*PerXdsConfig_ListenerConfig)(nil), 218 (*PerXdsConfig_ClusterConfig)(nil), 219 (*PerXdsConfig_RouteConfig)(nil), 220 (*PerXdsConfig_ScopedRouteConfig)(nil), 221 } 222} 223 224type ClientConfig struct { 225 Node *v32.Node `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"` 226 XdsConfig []*PerXdsConfig `protobuf:"bytes,2,rep,name=xds_config,json=xdsConfig,proto3" json:"xds_config,omitempty"` 227 XXX_NoUnkeyedLiteral struct{} `json:"-"` 228 XXX_unrecognized []byte `json:"-"` 229 XXX_sizecache int32 `json:"-"` 230} 231 232func (m *ClientConfig) Reset() { *m = ClientConfig{} } 233func (m *ClientConfig) String() string { return proto.CompactTextString(m) } 234func (*ClientConfig) ProtoMessage() {} 235func (*ClientConfig) Descriptor() ([]byte, []int) { 236 return fileDescriptor_d6ae65ba18d04178, []int{2} 237} 238 239func (m *ClientConfig) XXX_Unmarshal(b []byte) error { 240 return xxx_messageInfo_ClientConfig.Unmarshal(m, b) 241} 242func (m *ClientConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 243 return xxx_messageInfo_ClientConfig.Marshal(b, m, deterministic) 244} 245func (m *ClientConfig) XXX_Merge(src proto.Message) { 246 xxx_messageInfo_ClientConfig.Merge(m, src) 247} 248func (m *ClientConfig) XXX_Size() int { 249 return xxx_messageInfo_ClientConfig.Size(m) 250} 251func (m *ClientConfig) XXX_DiscardUnknown() { 252 xxx_messageInfo_ClientConfig.DiscardUnknown(m) 253} 254 255var xxx_messageInfo_ClientConfig proto.InternalMessageInfo 256 257func (m *ClientConfig) GetNode() *v32.Node { 258 if m != nil { 259 return m.Node 260 } 261 return nil 262} 263 264func (m *ClientConfig) GetXdsConfig() []*PerXdsConfig { 265 if m != nil { 266 return m.XdsConfig 267 } 268 return nil 269} 270 271type ClientStatusResponse struct { 272 Config []*ClientConfig `protobuf:"bytes,1,rep,name=config,proto3" json:"config,omitempty"` 273 XXX_NoUnkeyedLiteral struct{} `json:"-"` 274 XXX_unrecognized []byte `json:"-"` 275 XXX_sizecache int32 `json:"-"` 276} 277 278func (m *ClientStatusResponse) Reset() { *m = ClientStatusResponse{} } 279func (m *ClientStatusResponse) String() string { return proto.CompactTextString(m) } 280func (*ClientStatusResponse) ProtoMessage() {} 281func (*ClientStatusResponse) Descriptor() ([]byte, []int) { 282 return fileDescriptor_d6ae65ba18d04178, []int{3} 283} 284 285func (m *ClientStatusResponse) XXX_Unmarshal(b []byte) error { 286 return xxx_messageInfo_ClientStatusResponse.Unmarshal(m, b) 287} 288func (m *ClientStatusResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 289 return xxx_messageInfo_ClientStatusResponse.Marshal(b, m, deterministic) 290} 291func (m *ClientStatusResponse) XXX_Merge(src proto.Message) { 292 xxx_messageInfo_ClientStatusResponse.Merge(m, src) 293} 294func (m *ClientStatusResponse) XXX_Size() int { 295 return xxx_messageInfo_ClientStatusResponse.Size(m) 296} 297func (m *ClientStatusResponse) XXX_DiscardUnknown() { 298 xxx_messageInfo_ClientStatusResponse.DiscardUnknown(m) 299} 300 301var xxx_messageInfo_ClientStatusResponse proto.InternalMessageInfo 302 303func (m *ClientStatusResponse) GetConfig() []*ClientConfig { 304 if m != nil { 305 return m.Config 306 } 307 return nil 308} 309 310func init() { 311 proto.RegisterEnum("envoy.service.status.v3.ConfigStatus", ConfigStatus_name, ConfigStatus_value) 312 proto.RegisterType((*ClientStatusRequest)(nil), "envoy.service.status.v3.ClientStatusRequest") 313 proto.RegisterType((*PerXdsConfig)(nil), "envoy.service.status.v3.PerXdsConfig") 314 proto.RegisterType((*ClientConfig)(nil), "envoy.service.status.v3.ClientConfig") 315 proto.RegisterType((*ClientStatusResponse)(nil), "envoy.service.status.v3.ClientStatusResponse") 316} 317 318func init() { proto.RegisterFile("envoy/service/status/v3/csds.proto", fileDescriptor_d6ae65ba18d04178) } 319 320var fileDescriptor_d6ae65ba18d04178 = []byte{ 321 // 727 bytes of a gzipped FileDescriptorProto 322 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xbc, 0x54, 0x4d, 0x6f, 0xd3, 0x4a, 323 0x14, 0xed, 0x24, 0x6d, 0xde, 0xeb, 0x4d, 0x9a, 0x97, 0xba, 0x4f, 0x7a, 0x51, 0x5e, 0x0b, 0xc1, 324 0xd0, 0x2a, 0xea, 0x87, 0x8d, 0x92, 0x5d, 0x24, 0x84, 0x68, 0x12, 0x40, 0x6a, 0x71, 0x2b, 0xa7, 325 0x88, 0xb2, 0x8a, 0x5c, 0x7b, 0x9a, 0x5a, 0x4a, 0x3c, 0xc6, 0x33, 0x0e, 0xcd, 0x0e, 0xb1, 0xaa, 326 0x58, 0xc2, 0x8e, 0x05, 0xff, 0x81, 0x1d, 0x62, 0x8f, 0x84, 0xd8, 0x21, 0xfe, 0x02, 0x3f, 0x04, 327 0xcd, 0x47, 0x14, 0x27, 0x34, 0x6a, 0x57, 0xec, 0x66, 0x74, 0xcf, 0x39, 0xf7, 0xdc, 0x8f, 0x19, 328 0xd0, 0x71, 0x30, 0x20, 0x43, 0x93, 0xe2, 0x68, 0xe0, 0xbb, 0xd8, 0xa4, 0xcc, 0x61, 0x31, 0x35, 329 0x07, 0x35, 0xd3, 0xa5, 0x1e, 0x35, 0xc2, 0x88, 0x30, 0xa2, 0xfd, 0x27, 0x30, 0x86, 0xc2, 0x18, 330 0x12, 0x63, 0x0c, 0x6a, 0xa5, 0xb2, 0x24, 0x3b, 0x5e, 0xdf, 0x0f, 0x04, 0x87, 0x04, 0xa7, 0x7e, 331 0xb7, 0xe3, 0xc5, 0xfd, 0x50, 0x52, 0x4b, 0x37, 0x25, 0x42, 0x06, 0x4c, 0x97, 0x44, 0x98, 0xe3, 332 0x4e, 0x1c, 0x8a, 0x15, 0x40, 0x49, 0xb0, 0x61, 0x88, 0xcd, 0xbe, 0xc3, 0xdc, 0x33, 0x1c, 0x71, 333 0x44, 0x40, 0xbc, 0x11, 0x62, 0xb5, 0x4b, 0x48, 0xb7, 0x87, 0x4d, 0x27, 0xf4, 0x4d, 0x27, 0x08, 334 0x08, 0x73, 0x98, 0x4f, 0x02, 0x3a, 0x15, 0x15, 0xb7, 0x93, 0xf8, 0xd4, 0xa4, 0x2c, 0x8a, 0x5d, 335 0xa6, 0xa2, 0x6b, 0xb1, 0x17, 0x3a, 0x49, 0x96, 0x2a, 0x50, 0x85, 0x6f, 0xfd, 0x16, 0x1e, 0xe0, 336 0x88, 0xfa, 0x24, 0xf0, 0x83, 0xae, 0x84, 0xe8, 0x6f, 0x11, 0xac, 0x34, 0x7a, 0x3e, 0x0e, 0x58, 337 0x5b, 0x30, 0x6d, 0xfc, 0x22, 0xc6, 0x94, 0x69, 0x8f, 0x60, 0x89, 0x7b, 0xec, 0x28, 0xcf, 0xb4, 338 0x88, 0xca, 0xe9, 0x4a, 0xb6, 0xaa, 0x1b, 0xb2, 0x57, 0xbc, 0x1e, 0x43, 0xc5, 0x8c, 0x41, 0xcd, 339 0xb0, 0x88, 0x87, 0x9f, 0xc8, 0xab, 0x9d, 0x0b, 0xc6, 0x17, 0x5a, 0xaf, 0xbe, 0xff, 0x72, 0x71, 340 0x63, 0x07, 0xb6, 0x2e, 0xef, 0x71, 0xd5, 0xb8, 0x24, 0xb9, 0xfe, 0x2d, 0x0d, 0xb9, 0x43, 0x1c, 341 0x1d, 0x7b, 0xb4, 0x21, 0x1a, 0xab, 0xdd, 0x83, 0x8c, 0x64, 0x14, 0x51, 0x19, 0x55, 0xf2, 0xd5, 342 0x75, 0x63, 0xc6, 0xc8, 0x0c, 0x49, 0x50, 0x72, 0x8a, 0xa4, 0x59, 0xf0, 0x4f, 0xcf, 0xa7, 0x0c, 343 0x07, 0x38, 0xea, 0xc8, 0x51, 0x15, 0x53, 0x65, 0x54, 0xc9, 0x56, 0x6f, 0x2b, 0x1d, 0x31, 0x61, 344 0x4e, 0xdf, 0x57, 0x30, 0x95, 0xb8, 0x19, 0xf7, 0xc3, 0xc7, 0x73, 0x76, 0x7e, 0xc4, 0x56, 0x76, 345 0xf6, 0x20, 0xef, 0xf6, 0x62, 0xca, 0xc6, 0x72, 0x69, 0x21, 0xa7, 0x4f, 0xcb, 0x35, 0x24, 0x6a, 346 0x52, 0x6d, 0x49, 0x71, 0x95, 0x58, 0x0b, 0x72, 0x11, 0x89, 0x19, 0x1e, 0x49, 0xcd, 0x0b, 0xa9, 347 0xf2, 0xb4, 0x94, 0xcd, 0x31, 0x93, 0x42, 0x59, 0xc1, 0x53, 0x32, 0xc7, 0xb0, 0x42, 0x5d, 0x12, 348 0x62, 0xaf, 0x33, 0xa1, 0xb6, 0x20, 0xd4, 0x36, 0xa6, 0xd5, 0xda, 0x02, 0x7a, 0x89, 0xe6, 0x32, 349 0x1d, 0x47, 0x64, 0xa0, 0xbe, 0xc5, 0x27, 0xb8, 0x01, 0x77, 0x66, 0x4d, 0x30, 0x39, 0xa9, 0xdd, 350 0x02, 0xe4, 0x43, 0x1c, 0x75, 0xce, 0x3d, 0xaa, 0x1c, 0xe8, 0x1f, 0x11, 0xe4, 0xe4, 0x90, 0x95, 351 0x53, 0x03, 0xe6, 0xf9, 0x86, 0x88, 0x51, 0x66, 0xab, 0x25, 0x65, 0x4d, 0xa2, 0x0d, 0xfe, 0x84, 352 0x46, 0x0b, 0x65, 0x0b, 0x9c, 0xd6, 0x04, 0x18, 0xcb, 0x15, 0x53, 0x62, 0x0f, 0x67, 0x2f, 0x40, 353 0xd2, 0x8d, 0xbd, 0x78, 0x3e, 0x3a, 0x5e, 0x59, 0x45, 0xd2, 0xa2, 0xfe, 0x06, 0xc1, 0xbf, 0x93, 354 0x8b, 0x49, 0x43, 0x12, 0x50, 0xcc, 0x17, 0x51, 0xf9, 0x40, 0x57, 0xf8, 0x48, 0xea, 0xd9, 0x8a, 355 0x54, 0xaf, 0x71, 0x13, 0x06, 0x6c, 0x5f, 0xef, 0x31, 0xc8, 0x9c, 0x9b, 0x7b, 0x90, 0x4b, 0x6e, 356 0xb5, 0x96, 0x85, 0xbf, 0x9e, 0x5a, 0x7b, 0xd6, 0xc1, 0x33, 0xab, 0x30, 0xa7, 0x01, 0x64, 0xda, 357 0xcf, 0xad, 0x46, 0xab, 0x59, 0x40, 0x5a, 0x0e, 0xfe, 0xb6, 0x0e, 0x8e, 0x3a, 0xed, 0x96, 0x75, 358 0x54, 0x48, 0x69, 0x8b, 0xb0, 0xd0, 0x3e, 0x7a, 0xb0, 0xdf, 0x2a, 0xa4, 0xf9, 0xb1, 0x65, 0xdb, 359 0x07, 0x76, 0x61, 0xbe, 0xfa, 0x29, 0x05, 0xab, 0xc9, 0x2c, 0x4d, 0x9f, 0xba, 0x64, 0x80, 0xa3, 360 0x61, 0x5b, 0x9a, 0xd1, 0x5e, 0x82, 0xd6, 0x66, 0x11, 0x76, 0xfa, 0x49, 0x94, 0xb6, 0x7d, 0x45, 361 0x9d, 0x13, 0xef, 0xb7, 0xb4, 0x73, 0x4d, 0xb4, 0x2c, 0x50, 0x9f, 0xab, 0xa0, 0xbb, 0x48, 0xfb, 362 0x80, 0x60, 0xf9, 0x21, 0x66, 0xee, 0xd9, 0x9f, 0x4b, 0xbc, 0xfd, 0xfa, 0xc7, 0xcf, 0x77, 0xa9, 363 0x35, 0xfd, 0x7f, 0xfe, 0x25, 0x7b, 0xa3, 0x4e, 0xd4, 0x5d, 0x81, 0xed, 0x48, 0xb2, 0x80, 0xa4, 364 0xeb, 0x68, 0x73, 0xf7, 0xfe, 0xe7, 0x57, 0x5f, 0xbf, 0x67, 0x52, 0x85, 0x14, 0xac, 0xfb, 0x44, 365 0x26, 0x0a, 0x23, 0x72, 0x3e, 0x9c, 0x95, 0x73, 0x77, 0xb1, 0x41, 0x3d, 0x7a, 0xc8, 0xbf, 0xd9, 366 0x43, 0x74, 0x81, 0xd0, 0x49, 0x46, 0x7c, 0xb9, 0xb5, 0x5f, 0x01, 0x00, 0x00, 0xff, 0xff, 0xf8, 367 0xc7, 0x20, 0x98, 0x94, 0x06, 0x00, 0x00, 368} 369 370// Reference imports to suppress errors if they are not otherwise used. 371var _ context.Context 372var _ grpc.ClientConn 373 374// This is a compile-time assertion to ensure that this generated file 375// is compatible with the grpc package it is being compiled against. 376const _ = grpc.SupportPackageIsVersion4 377 378// ClientStatusDiscoveryServiceClient is the client API for ClientStatusDiscoveryService service. 379// 380// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream. 381type ClientStatusDiscoveryServiceClient interface { 382 StreamClientStatus(ctx context.Context, opts ...grpc.CallOption) (ClientStatusDiscoveryService_StreamClientStatusClient, error) 383 FetchClientStatus(ctx context.Context, in *ClientStatusRequest, opts ...grpc.CallOption) (*ClientStatusResponse, error) 384} 385 386type clientStatusDiscoveryServiceClient struct { 387 cc *grpc.ClientConn 388} 389 390func NewClientStatusDiscoveryServiceClient(cc *grpc.ClientConn) ClientStatusDiscoveryServiceClient { 391 return &clientStatusDiscoveryServiceClient{cc} 392} 393 394func (c *clientStatusDiscoveryServiceClient) StreamClientStatus(ctx context.Context, opts ...grpc.CallOption) (ClientStatusDiscoveryService_StreamClientStatusClient, error) { 395 stream, err := c.cc.NewStream(ctx, &_ClientStatusDiscoveryService_serviceDesc.Streams[0], "/envoy.service.status.v3.ClientStatusDiscoveryService/StreamClientStatus", opts...) 396 if err != nil { 397 return nil, err 398 } 399 x := &clientStatusDiscoveryServiceStreamClientStatusClient{stream} 400 return x, nil 401} 402 403type ClientStatusDiscoveryService_StreamClientStatusClient interface { 404 Send(*ClientStatusRequest) error 405 Recv() (*ClientStatusResponse, error) 406 grpc.ClientStream 407} 408 409type clientStatusDiscoveryServiceStreamClientStatusClient struct { 410 grpc.ClientStream 411} 412 413func (x *clientStatusDiscoveryServiceStreamClientStatusClient) Send(m *ClientStatusRequest) error { 414 return x.ClientStream.SendMsg(m) 415} 416 417func (x *clientStatusDiscoveryServiceStreamClientStatusClient) Recv() (*ClientStatusResponse, error) { 418 m := new(ClientStatusResponse) 419 if err := x.ClientStream.RecvMsg(m); err != nil { 420 return nil, err 421 } 422 return m, nil 423} 424 425func (c *clientStatusDiscoveryServiceClient) FetchClientStatus(ctx context.Context, in *ClientStatusRequest, opts ...grpc.CallOption) (*ClientStatusResponse, error) { 426 out := new(ClientStatusResponse) 427 err := c.cc.Invoke(ctx, "/envoy.service.status.v3.ClientStatusDiscoveryService/FetchClientStatus", in, out, opts...) 428 if err != nil { 429 return nil, err 430 } 431 return out, nil 432} 433 434// ClientStatusDiscoveryServiceServer is the server API for ClientStatusDiscoveryService service. 435type ClientStatusDiscoveryServiceServer interface { 436 StreamClientStatus(ClientStatusDiscoveryService_StreamClientStatusServer) error 437 FetchClientStatus(context.Context, *ClientStatusRequest) (*ClientStatusResponse, error) 438} 439 440// UnimplementedClientStatusDiscoveryServiceServer can be embedded to have forward compatible implementations. 441type UnimplementedClientStatusDiscoveryServiceServer struct { 442} 443 444func (*UnimplementedClientStatusDiscoveryServiceServer) StreamClientStatus(srv ClientStatusDiscoveryService_StreamClientStatusServer) error { 445 return status.Errorf(codes.Unimplemented, "method StreamClientStatus not implemented") 446} 447func (*UnimplementedClientStatusDiscoveryServiceServer) FetchClientStatus(ctx context.Context, req *ClientStatusRequest) (*ClientStatusResponse, error) { 448 return nil, status.Errorf(codes.Unimplemented, "method FetchClientStatus not implemented") 449} 450 451func RegisterClientStatusDiscoveryServiceServer(s *grpc.Server, srv ClientStatusDiscoveryServiceServer) { 452 s.RegisterService(&_ClientStatusDiscoveryService_serviceDesc, srv) 453} 454 455func _ClientStatusDiscoveryService_StreamClientStatus_Handler(srv interface{}, stream grpc.ServerStream) error { 456 return srv.(ClientStatusDiscoveryServiceServer).StreamClientStatus(&clientStatusDiscoveryServiceStreamClientStatusServer{stream}) 457} 458 459type ClientStatusDiscoveryService_StreamClientStatusServer interface { 460 Send(*ClientStatusResponse) error 461 Recv() (*ClientStatusRequest, error) 462 grpc.ServerStream 463} 464 465type clientStatusDiscoveryServiceStreamClientStatusServer struct { 466 grpc.ServerStream 467} 468 469func (x *clientStatusDiscoveryServiceStreamClientStatusServer) Send(m *ClientStatusResponse) error { 470 return x.ServerStream.SendMsg(m) 471} 472 473func (x *clientStatusDiscoveryServiceStreamClientStatusServer) Recv() (*ClientStatusRequest, error) { 474 m := new(ClientStatusRequest) 475 if err := x.ServerStream.RecvMsg(m); err != nil { 476 return nil, err 477 } 478 return m, nil 479} 480 481func _ClientStatusDiscoveryService_FetchClientStatus_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 482 in := new(ClientStatusRequest) 483 if err := dec(in); err != nil { 484 return nil, err 485 } 486 if interceptor == nil { 487 return srv.(ClientStatusDiscoveryServiceServer).FetchClientStatus(ctx, in) 488 } 489 info := &grpc.UnaryServerInfo{ 490 Server: srv, 491 FullMethod: "/envoy.service.status.v3.ClientStatusDiscoveryService/FetchClientStatus", 492 } 493 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 494 return srv.(ClientStatusDiscoveryServiceServer).FetchClientStatus(ctx, req.(*ClientStatusRequest)) 495 } 496 return interceptor(ctx, in, info, handler) 497} 498 499var _ClientStatusDiscoveryService_serviceDesc = grpc.ServiceDesc{ 500 ServiceName: "envoy.service.status.v3.ClientStatusDiscoveryService", 501 HandlerType: (*ClientStatusDiscoveryServiceServer)(nil), 502 Methods: []grpc.MethodDesc{ 503 { 504 MethodName: "FetchClientStatus", 505 Handler: _ClientStatusDiscoveryService_FetchClientStatus_Handler, 506 }, 507 }, 508 Streams: []grpc.StreamDesc{ 509 { 510 StreamName: "StreamClientStatus", 511 Handler: _ClientStatusDiscoveryService_StreamClientStatus_Handler, 512 ServerStreams: true, 513 ClientStreams: true, 514 }, 515 }, 516 Metadata: "envoy/service/status/v3/csds.proto", 517} 518