1// Code generated by protoc-gen-gogo. DO NOT EDIT. 2// source: distributor.proto 3 4package distributorpb 5 6import ( 7 context "context" 8 fmt "fmt" 9 cortexpb "github.com/cortexproject/cortex/pkg/cortexpb" 10 _ "github.com/gogo/protobuf/gogoproto" 11 proto "github.com/gogo/protobuf/proto" 12 grpc "google.golang.org/grpc" 13 codes "google.golang.org/grpc/codes" 14 status "google.golang.org/grpc/status" 15 math "math" 16) 17 18// Reference imports to suppress errors if they are not otherwise used. 19var _ = proto.Marshal 20var _ = fmt.Errorf 21var _ = math.Inf 22 23// This is a compile-time assertion to ensure that this generated file 24// is compatible with the proto package it is being compiled against. 25// A compilation error at this line likely means your copy of the 26// proto package needs to be updated. 27const _ = proto.GoGoProtoPackageIsVersion3 // please upgrade the proto package 28 29func init() { proto.RegisterFile("distributor.proto", fileDescriptor_c518e33639ca565d) } 30 31var fileDescriptor_c518e33639ca565d = []byte{ 32 // 221 bytes of a gzipped FileDescriptorProto 33 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xe2, 0x12, 0x4c, 0xc9, 0x2c, 0x2e, 34 0x29, 0xca, 0x4c, 0x2a, 0x2d, 0xc9, 0x2f, 0xd2, 0x2b, 0x28, 0xca, 0x2f, 0xc9, 0x17, 0xe2, 0x46, 35 0x12, 0x92, 0xd2, 0x4d, 0xcf, 0x2c, 0xc9, 0x28, 0x4d, 0xd2, 0x4b, 0xce, 0xcf, 0xd5, 0x4f, 0xcf, 36 0x4f, 0xcf, 0xd7, 0x07, 0xab, 0x49, 0x2a, 0x4d, 0x03, 0xf3, 0xc0, 0x1c, 0x30, 0x0b, 0xa2, 0x57, 37 0xca, 0x12, 0x49, 0x79, 0x72, 0x7e, 0x51, 0x49, 0x6a, 0x45, 0x41, 0x51, 0x7e, 0x56, 0x6a, 0x72, 38 0x09, 0x94, 0xa7, 0x5f, 0x90, 0x9d, 0x0e, 0x93, 0x48, 0x82, 0x32, 0x20, 0x5a, 0x8d, 0x3c, 0xb8, 39 0xb8, 0x5d, 0x10, 0x16, 0x0b, 0x59, 0x72, 0xb1, 0x04, 0x94, 0x16, 0x67, 0x08, 0x89, 0xe9, 0xc1, 40 0x94, 0xeb, 0x85, 0x17, 0x65, 0x96, 0xa4, 0x06, 0xa5, 0x16, 0x96, 0xa6, 0x16, 0x97, 0x48, 0x89, 41 0x63, 0x88, 0x17, 0x17, 0xe4, 0xe7, 0x15, 0xa7, 0x2a, 0x31, 0x38, 0x39, 0x5f, 0x78, 0x28, 0xc7, 42 0x70, 0xe3, 0xa1, 0x1c, 0xc3, 0x87, 0x87, 0x72, 0x8c, 0x0d, 0x8f, 0xe4, 0x18, 0x57, 0x3c, 0x92, 43 0x63, 0x3c, 0xf1, 0x48, 0x8e, 0xf1, 0xc2, 0x23, 0x39, 0xc6, 0x07, 0x8f, 0xe4, 0x18, 0x5f, 0x3c, 44 0x92, 0x63, 0xf8, 0xf0, 0x48, 0x8e, 0x71, 0xc2, 0x63, 0x39, 0x86, 0x0b, 0x8f, 0xe5, 0x18, 0x6e, 45 0x3c, 0x96, 0x63, 0x88, 0xe2, 0x45, 0xf2, 0x76, 0x41, 0x52, 0x12, 0x1b, 0xd8, 0x55, 0xc6, 0x80, 46 0x00, 0x00, 0x00, 0xff, 0xff, 0x91, 0xcd, 0x1b, 0x85, 0x21, 0x01, 0x00, 0x00, 47} 48 49// Reference imports to suppress errors if they are not otherwise used. 50var _ context.Context 51var _ grpc.ClientConn 52 53// This is a compile-time assertion to ensure that this generated file 54// is compatible with the grpc package it is being compiled against. 55const _ = grpc.SupportPackageIsVersion4 56 57// DistributorClient is the client API for Distributor service. 58// 59// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream. 60type DistributorClient interface { 61 Push(ctx context.Context, in *cortexpb.WriteRequest, opts ...grpc.CallOption) (*cortexpb.WriteResponse, error) 62} 63 64type distributorClient struct { 65 cc *grpc.ClientConn 66} 67 68func NewDistributorClient(cc *grpc.ClientConn) DistributorClient { 69 return &distributorClient{cc} 70} 71 72func (c *distributorClient) Push(ctx context.Context, in *cortexpb.WriteRequest, opts ...grpc.CallOption) (*cortexpb.WriteResponse, error) { 73 out := new(cortexpb.WriteResponse) 74 err := c.cc.Invoke(ctx, "/distributor.Distributor/Push", in, out, opts...) 75 if err != nil { 76 return nil, err 77 } 78 return out, nil 79} 80 81// DistributorServer is the server API for Distributor service. 82type DistributorServer interface { 83 Push(context.Context, *cortexpb.WriteRequest) (*cortexpb.WriteResponse, error) 84} 85 86// UnimplementedDistributorServer can be embedded to have forward compatible implementations. 87type UnimplementedDistributorServer struct { 88} 89 90func (*UnimplementedDistributorServer) Push(ctx context.Context, req *cortexpb.WriteRequest) (*cortexpb.WriteResponse, error) { 91 return nil, status.Errorf(codes.Unimplemented, "method Push not implemented") 92} 93 94func RegisterDistributorServer(s *grpc.Server, srv DistributorServer) { 95 s.RegisterService(&_Distributor_serviceDesc, srv) 96} 97 98func _Distributor_Push_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 99 in := new(cortexpb.WriteRequest) 100 if err := dec(in); err != nil { 101 return nil, err 102 } 103 if interceptor == nil { 104 return srv.(DistributorServer).Push(ctx, in) 105 } 106 info := &grpc.UnaryServerInfo{ 107 Server: srv, 108 FullMethod: "/distributor.Distributor/Push", 109 } 110 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 111 return srv.(DistributorServer).Push(ctx, req.(*cortexpb.WriteRequest)) 112 } 113 return interceptor(ctx, in, info, handler) 114} 115 116var _Distributor_serviceDesc = grpc.ServiceDesc{ 117 ServiceName: "distributor.Distributor", 118 HandlerType: (*DistributorServer)(nil), 119 Methods: []grpc.MethodDesc{ 120 { 121 MethodName: "Push", 122 Handler: _Distributor_Push_Handler, 123 }, 124 }, 125 Streams: []grpc.StreamDesc{}, 126 Metadata: "distributor.proto", 127} 128