cmd/bpa-operator/vendor/github.com/census-instrumentation/opencensus-proto/gen-go/agent/metrics/v1/metrics_service.pb.go

   1 // Code generated by protoc-gen-go. DO NOT EDIT.
   2 // source: opencensus/proto/agent/metrics/v1/metrics_service.proto
   3
   4 package v1
   5
   6 import (
   7         context "context"
   8         fmt "fmt"
   9         v1 "github.com/census-instrumentation/opencensus-proto/gen-go/agent/common/v1"
  10         v11 "github.com/census-instrumentation/opencensus-proto/gen-go/metrics/v1"
  11         v12 "github.com/census-instrumentation/opencensus-proto/gen-go/resource/v1"
  12         proto "github.com/golang/protobuf/proto"
  13         grpc "google.golang.org/grpc"
  14         math "math"
  15 )
  16
  17 // Reference imports to suppress errors if they are not otherwise used.
  18 var _ = proto.Marshal
  19 var _ = fmt.Errorf
  20 var _ = math.Inf
  21
  22 // This is a compile-time assertion to ensure that this generated file
  23 // is compatible with the proto package it is being compiled against.
  24 // A compilation error at this line likely means your copy of the
  25 // proto package needs to be updated.
  26 const _ = proto.ProtoPackageIsVersion3 // please upgrade the proto package
  27
  28 type ExportMetricsServiceRequest struct {
  29         // This is required only in the first message on the stream or if the
  30         // previous sent ExportMetricsServiceRequest message has a different Node (e.g.
  31         // when the same RPC is used to send Metrics from multiple Applications).
  32         Node *v1.Node `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"`
  33         // A list of metrics that belong to the last received Node.
  34         Metrics []*v11.Metric `protobuf:"bytes,2,rep,name=metrics,proto3" json:"metrics,omitempty"`
  35         // The resource for the metrics in this message that do not have an explicit
  36         // resource set.
  37         // If unset, the most recently set resource in the RPC stream applies. It is
  38         // valid to never be set within a stream, e.g. when no resource info is known
  39         // at all or when all sent metrics have an explicit resource set.
  40         Resource             *v12.Resource `protobuf:"bytes,3,opt,name=resource,proto3" json:"resource,omitempty"`
  41         XXX_NoUnkeyedLiteral struct{}      `json:"-"`
  42         XXX_unrecognized     []byte        `json:"-"`
  43         XXX_sizecache        int32         `json:"-"`
  44 }
  45
  46 func (m *ExportMetricsServiceRequest) Reset()         { *m = ExportMetricsServiceRequest{} }
  47 func (m *ExportMetricsServiceRequest) String() string { return proto.CompactTextString(m) }
  48 func (*ExportMetricsServiceRequest) ProtoMessage()    {}
  49 func (*ExportMetricsServiceRequest) Descriptor() ([]byte, []int) {
  50         return fileDescriptor_47e253a956287d04, []int{0}
  51 }
  52
  53 func (m *ExportMetricsServiceRequest) XXX_Unmarshal(b []byte) error {
  54         return xxx_messageInfo_ExportMetricsServiceRequest.Unmarshal(m, b)
  55 }
  56 func (m *ExportMetricsServiceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
  57         return xxx_messageInfo_ExportMetricsServiceRequest.Marshal(b, m, deterministic)
  58 }
  59 func (m *ExportMetricsServiceRequest) XXX_Merge(src proto.Message) {
  60         xxx_messageInfo_ExportMetricsServiceRequest.Merge(m, src)
  61 }
  62 func (m *ExportMetricsServiceRequest) XXX_Size() int {
  63         return xxx_messageInfo_ExportMetricsServiceRequest.Size(m)
  64 }
  65 func (m *ExportMetricsServiceRequest) XXX_DiscardUnknown() {
  66         xxx_messageInfo_ExportMetricsServiceRequest.DiscardUnknown(m)
  67 }
  68
  69 var xxx_messageInfo_ExportMetricsServiceRequest proto.InternalMessageInfo
  70
  71 func (m *ExportMetricsServiceRequest) GetNode() *v1.Node {
  72         if m != nil {
  73                 return m.Node
  74         }
  75         return nil
  76 }
  77
  78 func (m *ExportMetricsServiceRequest) GetMetrics() []*v11.Metric {
  79         if m != nil {
  80                 return m.Metrics
  81         }
  82         return nil
  83 }
  84
  85 func (m *ExportMetricsServiceRequest) GetResource() *v12.Resource {
  86         if m != nil {
  87                 return m.Resource
  88         }
  89         return nil
  90 }
  91
  92 type ExportMetricsServiceResponse struct {
  93         XXX_NoUnkeyedLiteral struct{} `json:"-"`
  94         XXX_unrecognized     []byte   `json:"-"`
  95         XXX_sizecache        int32    `json:"-"`
  96 }
  97
  98 func (m *ExportMetricsServiceResponse) Reset()         { *m = ExportMetricsServiceResponse{} }
  99 func (m *ExportMetricsServiceResponse) String() string { return proto.CompactTextString(m) }
 100 func (*ExportMetricsServiceResponse) ProtoMessage()    {}
 101 func (*ExportMetricsServiceResponse) Descriptor() ([]byte, []int) {
 102         return fileDescriptor_47e253a956287d04, []int{1}
 103 }
 104
 105 func (m *ExportMetricsServiceResponse) XXX_Unmarshal(b []byte) error {
 106         return xxx_messageInfo_ExportMetricsServiceResponse.Unmarshal(m, b)
 107 }
 108 func (m *ExportMetricsServiceResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
 109         return xxx_messageInfo_ExportMetricsServiceResponse.Marshal(b, m, deterministic)
 110 }
 111 func (m *ExportMetricsServiceResponse) XXX_Merge(src proto.Message) {
 112         xxx_messageInfo_ExportMetricsServiceResponse.Merge(m, src)
 113 }
 114 func (m *ExportMetricsServiceResponse) XXX_Size() int {
 115         return xxx_messageInfo_ExportMetricsServiceResponse.Size(m)
 116 }
 117 func (m *ExportMetricsServiceResponse) XXX_DiscardUnknown() {
 118         xxx_messageInfo_ExportMetricsServiceResponse.DiscardUnknown(m)
 119 }
 120
 121 var xxx_messageInfo_ExportMetricsServiceResponse proto.InternalMessageInfo
 122
 123 func init() {
 124         proto.RegisterType((*ExportMetricsServiceRequest)(nil), "opencensus.proto.agent.metrics.v1.ExportMetricsServiceRequest")
 125         proto.RegisterType((*ExportMetricsServiceResponse)(nil), "opencensus.proto.agent.metrics.v1.ExportMetricsServiceResponse")
 126 }
 127
 128 func init() {
 129         proto.RegisterFile("opencensus/proto/agent/metrics/v1/metrics_service.proto", fileDescriptor_47e253a956287d04)
 130 }
 131
 132 var fileDescriptor_47e253a956287d04 = []byte{
 133         // 340 bytes of a gzipped FileDescriptorProto
 134         0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x9c, 0x92, 0xc1, 0x4a, 0xf3, 0x40,
 135         0x14, 0x85, 0xff, 0xf9, 0x2b, 0x55, 0xa6, 0xe0, 0x62, 0xdc, 0x94, 0x2a, 0x52, 0xab, 0x48, 0x45,
 136         0x32, 0x63, 0xea, 0x42, 0x10, 0x54, 0x28, 0xb8, 0x11, 0x94, 0x12, 0x77, 0x6e, 0xa4, 0x4d, 0x2f,
 137         0x71, 0x16, 0x99, 0x1b, 0x67, 0x26, 0xc1, 0x57, 0x70, 0xe5, 0x3b, 0xf8, 0x5c, 0x3e, 0x8c, 0x24,
 138         0x93, 0xb4, 0x94, 0x18, 0x0b, 0xee, 0x2e, 0x99, 0xf3, 0x9d, 0x9c, 0x33, 0x73, 0xe9, 0x05, 0x26,
 139         0xa0, 0x42, 0x50, 0x26, 0x35, 0x22, 0xd1, 0x68, 0x51, 0x4c, 0x23, 0x50, 0x56, 0xc4, 0x60, 0xb5,
 140         0x0c, 0x8d, 0xc8, 0xfc, 0x6a, 0x7c, 0x36, 0xa0, 0x33, 0x19, 0x02, 0x2f, 0x64, 0xec, 0x60, 0x09,
 141         0xba, 0x2f, 0xbc, 0x00, 0x79, 0xa9, 0xe6, 0x99, 0xdf, 0xf3, 0x1a, 0xbc, 0x43, 0x8c, 0x63, 0x54,
 142         0xb9, 0xb5, 0x9b, 0x1c, 0xdf, 0x3b, 0xa9, 0xc9, 0xeb, 0x21, 0x4a, 0xe9, 0x69, 0x4d, 0xaa, 0xc1,
 143         0x60, 0xaa, 0x43, 0xc8, 0xb5, 0xd5, 0xec, 0xc4, 0x83, 0x2f, 0x42, 0x77, 0x6f, 0xdf, 0x12, 0xd4,
 144         0xf6, 0xde, 0x99, 0x3c, 0xba, 0x22, 0x01, 0xbc, 0xa6, 0x60, 0x2c, 0xbb, 0xa4, 0x1b, 0x0a, 0xe7,
 145         0xd0, 0x25, 0x7d, 0x32, 0xec, 0x8c, 0x8e, 0x79, 0x43, 0xb1, 0x32, 0x6b, 0xe6, 0xf3, 0x07, 0x9c,
 146         0x43, 0x50, 0x30, 0xec, 0x8a, 0x6e, 0x96, 0xc9, 0xba, 0xff, 0xfb, 0xad, 0x61, 0x67, 0x74, 0x58,
 147         0xc7, 0x97, 0x37, 0xc2, 0x5d, 0x80, 0xa0, 0x62, 0xd8, 0x98, 0x6e, 0x55, 0x61, 0xbb, 0xad, 0xa6,
 148         0xdf, 0x2f, 0xea, 0x64, 0x3e, 0x0f, 0xca, 0x39, 0x58, 0x70, 0x83, 0x7d, 0xba, 0xf7, 0x73, 0x3b,
 149         0x93, 0xa0, 0x32, 0x30, 0xfa, 0x24, 0x74, 0x7b, 0xf5, 0x88, 0x7d, 0x10, 0xda, 0x76, 0x0c, 0xbb,
 150         0xe6, 0x6b, 0xdf, 0x91, 0xff, 0x72, 0x79, 0xbd, 0x9b, 0x3f, 0xf3, 0x2e, 0xde, 0xe0, 0xdf, 0x90,
 151         0x9c, 0x91, 0xf1, 0x3b, 0xa1, 0x47, 0x12, 0xd7, 0x7b, 0x8d, 0x77, 0x56, 0x6d, 0x26, 0xb9, 0x6a,
 152         0x42, 0x9e, 0xee, 0x22, 0x69, 0x5f, 0xd2, 0x59, 0xfe, 0x48, 0xc2, 0x19, 0x78, 0x52, 0x19, 0xab,
 153         0xd3, 0x18, 0x94, 0x9d, 0x5a, 0x89, 0x4a, 0x2c, 0xbd, 0x3d, 0xb7, 0x32, 0x11, 0x28, 0x2f, 0xaa,
 154         0xef, 0xfb, 0xac, 0x5d, 0x1c, 0x9f, 0x7f, 0x07, 0x00, 0x00, 0xff, 0xff, 0x16, 0x61, 0x3b, 0xc3,
 155         0x1b, 0x03, 0x00, 0x00,
 156 }
 157
 158 // Reference imports to suppress errors if they are not otherwise used.
 159 var _ context.Context
 160 var _ grpc.ClientConn
 161
 162 // This is a compile-time assertion to ensure that this generated file
 163 // is compatible with the grpc package it is being compiled against.
 164 const _ = grpc.SupportPackageIsVersion4
 165
 166 // MetricsServiceClient is the client API for MetricsService service.
 167 //
 168 // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
 169 type MetricsServiceClient interface {
 170         // For performance reasons, it is recommended to keep this RPC
 171         // alive for the entire life of the application.
 172         Export(ctx context.Context, opts ...grpc.CallOption) (MetricsService_ExportClient, error)
 173 }
 174
 175 type metricsServiceClient struct {
 176         cc *grpc.ClientConn
 177 }
 178
 179 func NewMetricsServiceClient(cc *grpc.ClientConn) MetricsServiceClient {
 180         return &metricsServiceClient{cc}
 181 }
 182
 183 func (c *metricsServiceClient) Export(ctx context.Context, opts ...grpc.CallOption) (MetricsService_ExportClient, error) {
 184         stream, err := c.cc.NewStream(ctx, &_MetricsService_serviceDesc.Streams[0], "/opencensus.proto.agent.metrics.v1.MetricsService/Export", opts...)
 185         if err != nil {
 186                 return nil, err
 187         }
 188         x := &metricsServiceExportClient{stream}
 189         return x, nil
 190 }
 191
 192 type MetricsService_ExportClient interface {
 193         Send(*ExportMetricsServiceRequest) error
 194         Recv() (*ExportMetricsServiceResponse, error)
 195         grpc.ClientStream
 196 }
 197
 198 type metricsServiceExportClient struct {
 199         grpc.ClientStream
 200 }
 201
 202 func (x *metricsServiceExportClient) Send(m *ExportMetricsServiceRequest) error {
 203         return x.ClientStream.SendMsg(m)
 204 }
 205
 206 func (x *metricsServiceExportClient) Recv() (*ExportMetricsServiceResponse, error) {
 207         m := new(ExportMetricsServiceResponse)
 208         if err := x.ClientStream.RecvMsg(m); err != nil {
 209                 return nil, err
 210         }
 211         return m, nil
 212 }
 213
 214 // MetricsServiceServer is the server API for MetricsService service.
 215 type MetricsServiceServer interface {
 216         // For performance reasons, it is recommended to keep this RPC
 217         // alive for the entire life of the application.
 218         Export(MetricsService_ExportServer) error
 219 }
 220
 221 func RegisterMetricsServiceServer(s *grpc.Server, srv MetricsServiceServer) {
 222         s.RegisterService(&_MetricsService_serviceDesc, srv)
 223 }
 224
 225 func _MetricsService_Export_Handler(srv interface{}, stream grpc.ServerStream) error {
 226         return srv.(MetricsServiceServer).Export(&metricsServiceExportServer{stream})
 227 }
 228
 229 type MetricsService_ExportServer interface {
 230         Send(*ExportMetricsServiceResponse) error
 231         Recv() (*ExportMetricsServiceRequest, error)
 232         grpc.ServerStream
 233 }
 234
 235 type metricsServiceExportServer struct {
 236         grpc.ServerStream
 237 }
 238
 239 func (x *metricsServiceExportServer) Send(m *ExportMetricsServiceResponse) error {
 240         return x.ServerStream.SendMsg(m)
 241 }
 242
 243 func (x *metricsServiceExportServer) Recv() (*ExportMetricsServiceRequest, error) {
 244         m := new(ExportMetricsServiceRequest)
 245         if err := x.ServerStream.RecvMsg(m); err != nil {
 246                 return nil, err
 247         }
 248         return m, nil
 249 }
 250
 251 var _MetricsService_serviceDesc = grpc.ServiceDesc{
 252         ServiceName: "opencensus.proto.agent.metrics.v1.MetricsService",
 253         HandlerType: (*MetricsServiceServer)(nil),
 254         Methods:     []grpc.MethodDesc{},
 255         Streams: []grpc.StreamDesc{
 256                 {
 257                         StreamName:    "Export",
 258                         Handler:       _MetricsService_Export_Handler,
 259                         ServerStreams: true,
 260                         ClientStreams: true,
 261                 },
 262         },
 263         Metadata: "opencensus/proto/agent/metrics/v1/metrics_service.proto",
 264 }