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