// Code generated by protoc-gen-go-grpc. DO NOT EDIT.
// versions:
// - protoc-gen-go-grpc v1.6.2
// - protoc             v7.34.1
// source: sketches.proto

package waymaker_sketches

import (
	context "context"
	grpc "google.golang.org/grpc"
	codes "google.golang.org/grpc/codes"
	status "google.golang.org/grpc/status"
)

// This is a compile-time assertion to ensure that this generated file
// is compatible with the grpc package it is being compiled against.
// Requires gRPC-Go v1.64.0 or later.
const _ = grpc.SupportPackageIsVersion9

const (
	WaymakerSketchesService_BloomReserve_FullMethodName       = "/waymaker.sketches.WaymakerSketchesService/BloomReserve"
	WaymakerSketchesService_BloomAdd_FullMethodName           = "/waymaker.sketches.WaymakerSketchesService/BloomAdd"
	WaymakerSketchesService_BloomMultiAdd_FullMethodName      = "/waymaker.sketches.WaymakerSketchesService/BloomMultiAdd"
	WaymakerSketchesService_BloomExists_FullMethodName        = "/waymaker.sketches.WaymakerSketchesService/BloomExists"
	WaymakerSketchesService_BloomMultiExists_FullMethodName   = "/waymaker.sketches.WaymakerSketchesService/BloomMultiExists"
	WaymakerSketchesService_BloomInfo_FullMethodName          = "/waymaker.sketches.WaymakerSketchesService/BloomInfo"
	WaymakerSketchesService_BloomDelete_FullMethodName        = "/waymaker.sketches.WaymakerSketchesService/BloomDelete"
	WaymakerSketchesService_HllReserve_FullMethodName         = "/waymaker.sketches.WaymakerSketchesService/HllReserve"
	WaymakerSketchesService_HllAdd_FullMethodName             = "/waymaker.sketches.WaymakerSketchesService/HllAdd"
	WaymakerSketchesService_HllCount_FullMethodName           = "/waymaker.sketches.WaymakerSketchesService/HllCount"
	WaymakerSketchesService_HllMerge_FullMethodName           = "/waymaker.sketches.WaymakerSketchesService/HllMerge"
	WaymakerSketchesService_HllDelete_FullMethodName          = "/waymaker.sketches.WaymakerSketchesService/HllDelete"
	WaymakerSketchesService_CmsReserve_FullMethodName         = "/waymaker.sketches.WaymakerSketchesService/CmsReserve"
	WaymakerSketchesService_CmsIncrBy_FullMethodName          = "/waymaker.sketches.WaymakerSketchesService/CmsIncrBy"
	WaymakerSketchesService_CmsQuery_FullMethodName           = "/waymaker.sketches.WaymakerSketchesService/CmsQuery"
	WaymakerSketchesService_CmsDelete_FullMethodName          = "/waymaker.sketches.WaymakerSketchesService/CmsDelete"
	WaymakerSketchesService_TopKReserve_FullMethodName        = "/waymaker.sketches.WaymakerSketchesService/TopKReserve"
	WaymakerSketchesService_TopKAdd_FullMethodName            = "/waymaker.sketches.WaymakerSketchesService/TopKAdd"
	WaymakerSketchesService_TopKQuery_FullMethodName          = "/waymaker.sketches.WaymakerSketchesService/TopKQuery"
	WaymakerSketchesService_TopKList_FullMethodName           = "/waymaker.sketches.WaymakerSketchesService/TopKList"
	WaymakerSketchesService_TopKDelete_FullMethodName         = "/waymaker.sketches.WaymakerSketchesService/TopKDelete"
	WaymakerSketchesService_TDigestCreate_FullMethodName      = "/waymaker.sketches.WaymakerSketchesService/TDigestCreate"
	WaymakerSketchesService_TDigestAdd_FullMethodName         = "/waymaker.sketches.WaymakerSketchesService/TDigestAdd"
	WaymakerSketchesService_TDigestQuantile_FullMethodName    = "/waymaker.sketches.WaymakerSketchesService/TDigestQuantile"
	WaymakerSketchesService_TDigestMinMax_FullMethodName      = "/waymaker.sketches.WaymakerSketchesService/TDigestMinMax"
	WaymakerSketchesService_TDigestDelete_FullMethodName      = "/waymaker.sketches.WaymakerSketchesService/TDigestDelete"
	WaymakerSketchesService_ReplicateProbState_FullMethodName = "/waymaker.sketches.WaymakerSketchesService/ReplicateProbState"
)

// WaymakerSketchesServiceClient is the client API for WaymakerSketchesService service.
//
// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
type WaymakerSketchesServiceClient interface {
	// ----- Bloom filter -----
	BloomReserve(ctx context.Context, in *BloomReserveRequest, opts ...grpc.CallOption) (*BloomReserveResponse, error)
	BloomAdd(ctx context.Context, in *BloomAddRequest, opts ...grpc.CallOption) (*BloomAddResponse, error)
	BloomMultiAdd(ctx context.Context, in *BloomMultiAddRequest, opts ...grpc.CallOption) (*BloomMultiAddResponse, error)
	BloomExists(ctx context.Context, in *BloomExistsRequest, opts ...grpc.CallOption) (*BloomExistsResponse, error)
	BloomMultiExists(ctx context.Context, in *BloomMultiExistsRequest, opts ...grpc.CallOption) (*BloomMultiExistsResponse, error)
	BloomInfo(ctx context.Context, in *BloomInfoRequest, opts ...grpc.CallOption) (*BloomInfoResponse, error)
	BloomDelete(ctx context.Context, in *BloomDeleteRequest, opts ...grpc.CallOption) (*BloomDeleteResponse, error)
	// ----- HyperLogLog -----
	HllReserve(ctx context.Context, in *HllReserveRequest, opts ...grpc.CallOption) (*HllReserveResponse, error)
	HllAdd(ctx context.Context, in *HllAddRequest, opts ...grpc.CallOption) (*HllAddResponse, error)
	HllCount(ctx context.Context, in *HllCountRequest, opts ...grpc.CallOption) (*HllCountResponse, error)
	HllMerge(ctx context.Context, in *HllMergeRequest, opts ...grpc.CallOption) (*HllMergeResponse, error)
	HllDelete(ctx context.Context, in *HllDeleteRequest, opts ...grpc.CallOption) (*HllDeleteResponse, error)
	// ----- Count-Min Sketch -----
	CmsReserve(ctx context.Context, in *CmsReserveRequest, opts ...grpc.CallOption) (*CmsReserveResponse, error)
	CmsIncrBy(ctx context.Context, in *CmsIncrByRequest, opts ...grpc.CallOption) (*CmsIncrByResponse, error)
	CmsQuery(ctx context.Context, in *CmsQueryRequest, opts ...grpc.CallOption) (*CmsQueryResponse, error)
	CmsDelete(ctx context.Context, in *CmsDeleteRequest, opts ...grpc.CallOption) (*CmsDeleteResponse, error)
	// ----- Top-K -----
	TopKReserve(ctx context.Context, in *TopKReserveRequest, opts ...grpc.CallOption) (*TopKReserveResponse, error)
	TopKAdd(ctx context.Context, in *TopKAddRequest, opts ...grpc.CallOption) (*TopKAddResponse, error)
	TopKQuery(ctx context.Context, in *TopKQueryRequest, opts ...grpc.CallOption) (*TopKQueryResponse, error)
	TopKList(ctx context.Context, in *TopKListRequest, opts ...grpc.CallOption) (*TopKListResponse, error)
	TopKDelete(ctx context.Context, in *TopKDeleteRequest, opts ...grpc.CallOption) (*TopKDeleteResponse, error)
	// ----- t-digest -----
	TDigestCreate(ctx context.Context, in *TDigestCreateRequest, opts ...grpc.CallOption) (*TDigestCreateResponse, error)
	TDigestAdd(ctx context.Context, in *TDigestAddRequest, opts ...grpc.CallOption) (*TDigestAddResponse, error)
	TDigestQuantile(ctx context.Context, in *TDigestQuantileRequest, opts ...grpc.CallOption) (*TDigestQuantileResponse, error)
	TDigestMinMax(ctx context.Context, in *TDigestMinMaxRequest, opts ...grpc.CallOption) (*TDigestMinMaxResponse, error)
	TDigestDelete(ctx context.Context, in *TDigestDeleteRequest, opts ...grpc.CallOption) (*TDigestDeleteResponse, error)
	// Internal: snapshot replication. Primary pushes serialized
	// filter state to N-1 secondaries periodically. Version counter
	// dedupes out-of-order pushes.
	ReplicateProbState(ctx context.Context, in *ReplicateProbStateRequest, opts ...grpc.CallOption) (*ReplicateProbStateResponse, error)
}

type waymakerSketchesServiceClient struct {
	cc grpc.ClientConnInterface
}

func NewWaymakerSketchesServiceClient(cc grpc.ClientConnInterface) WaymakerSketchesServiceClient {
	return &waymakerSketchesServiceClient{cc}
}

func (c *waymakerSketchesServiceClient) BloomReserve(ctx context.Context, in *BloomReserveRequest, opts ...grpc.CallOption) (*BloomReserveResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(BloomReserveResponse)
	err := c.cc.Invoke(ctx, WaymakerSketchesService_BloomReserve_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *waymakerSketchesServiceClient) BloomAdd(ctx context.Context, in *BloomAddRequest, opts ...grpc.CallOption) (*BloomAddResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(BloomAddResponse)
	err := c.cc.Invoke(ctx, WaymakerSketchesService_BloomAdd_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *waymakerSketchesServiceClient) BloomMultiAdd(ctx context.Context, in *BloomMultiAddRequest, opts ...grpc.CallOption) (*BloomMultiAddResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(BloomMultiAddResponse)
	err := c.cc.Invoke(ctx, WaymakerSketchesService_BloomMultiAdd_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *waymakerSketchesServiceClient) BloomExists(ctx context.Context, in *BloomExistsRequest, opts ...grpc.CallOption) (*BloomExistsResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(BloomExistsResponse)
	err := c.cc.Invoke(ctx, WaymakerSketchesService_BloomExists_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *waymakerSketchesServiceClient) BloomMultiExists(ctx context.Context, in *BloomMultiExistsRequest, opts ...grpc.CallOption) (*BloomMultiExistsResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(BloomMultiExistsResponse)
	err := c.cc.Invoke(ctx, WaymakerSketchesService_BloomMultiExists_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *waymakerSketchesServiceClient) BloomInfo(ctx context.Context, in *BloomInfoRequest, opts ...grpc.CallOption) (*BloomInfoResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(BloomInfoResponse)
	err := c.cc.Invoke(ctx, WaymakerSketchesService_BloomInfo_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *waymakerSketchesServiceClient) BloomDelete(ctx context.Context, in *BloomDeleteRequest, opts ...grpc.CallOption) (*BloomDeleteResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(BloomDeleteResponse)
	err := c.cc.Invoke(ctx, WaymakerSketchesService_BloomDelete_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *waymakerSketchesServiceClient) HllReserve(ctx context.Context, in *HllReserveRequest, opts ...grpc.CallOption) (*HllReserveResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(HllReserveResponse)
	err := c.cc.Invoke(ctx, WaymakerSketchesService_HllReserve_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *waymakerSketchesServiceClient) HllAdd(ctx context.Context, in *HllAddRequest, opts ...grpc.CallOption) (*HllAddResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(HllAddResponse)
	err := c.cc.Invoke(ctx, WaymakerSketchesService_HllAdd_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *waymakerSketchesServiceClient) HllCount(ctx context.Context, in *HllCountRequest, opts ...grpc.CallOption) (*HllCountResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(HllCountResponse)
	err := c.cc.Invoke(ctx, WaymakerSketchesService_HllCount_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *waymakerSketchesServiceClient) HllMerge(ctx context.Context, in *HllMergeRequest, opts ...grpc.CallOption) (*HllMergeResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(HllMergeResponse)
	err := c.cc.Invoke(ctx, WaymakerSketchesService_HllMerge_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *waymakerSketchesServiceClient) HllDelete(ctx context.Context, in *HllDeleteRequest, opts ...grpc.CallOption) (*HllDeleteResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(HllDeleteResponse)
	err := c.cc.Invoke(ctx, WaymakerSketchesService_HllDelete_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *waymakerSketchesServiceClient) CmsReserve(ctx context.Context, in *CmsReserveRequest, opts ...grpc.CallOption) (*CmsReserveResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(CmsReserveResponse)
	err := c.cc.Invoke(ctx, WaymakerSketchesService_CmsReserve_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *waymakerSketchesServiceClient) CmsIncrBy(ctx context.Context, in *CmsIncrByRequest, opts ...grpc.CallOption) (*CmsIncrByResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(CmsIncrByResponse)
	err := c.cc.Invoke(ctx, WaymakerSketchesService_CmsIncrBy_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *waymakerSketchesServiceClient) CmsQuery(ctx context.Context, in *CmsQueryRequest, opts ...grpc.CallOption) (*CmsQueryResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(CmsQueryResponse)
	err := c.cc.Invoke(ctx, WaymakerSketchesService_CmsQuery_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *waymakerSketchesServiceClient) CmsDelete(ctx context.Context, in *CmsDeleteRequest, opts ...grpc.CallOption) (*CmsDeleteResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(CmsDeleteResponse)
	err := c.cc.Invoke(ctx, WaymakerSketchesService_CmsDelete_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *waymakerSketchesServiceClient) TopKReserve(ctx context.Context, in *TopKReserveRequest, opts ...grpc.CallOption) (*TopKReserveResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(TopKReserveResponse)
	err := c.cc.Invoke(ctx, WaymakerSketchesService_TopKReserve_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *waymakerSketchesServiceClient) TopKAdd(ctx context.Context, in *TopKAddRequest, opts ...grpc.CallOption) (*TopKAddResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(TopKAddResponse)
	err := c.cc.Invoke(ctx, WaymakerSketchesService_TopKAdd_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *waymakerSketchesServiceClient) TopKQuery(ctx context.Context, in *TopKQueryRequest, opts ...grpc.CallOption) (*TopKQueryResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(TopKQueryResponse)
	err := c.cc.Invoke(ctx, WaymakerSketchesService_TopKQuery_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *waymakerSketchesServiceClient) TopKList(ctx context.Context, in *TopKListRequest, opts ...grpc.CallOption) (*TopKListResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(TopKListResponse)
	err := c.cc.Invoke(ctx, WaymakerSketchesService_TopKList_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *waymakerSketchesServiceClient) TopKDelete(ctx context.Context, in *TopKDeleteRequest, opts ...grpc.CallOption) (*TopKDeleteResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(TopKDeleteResponse)
	err := c.cc.Invoke(ctx, WaymakerSketchesService_TopKDelete_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *waymakerSketchesServiceClient) TDigestCreate(ctx context.Context, in *TDigestCreateRequest, opts ...grpc.CallOption) (*TDigestCreateResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(TDigestCreateResponse)
	err := c.cc.Invoke(ctx, WaymakerSketchesService_TDigestCreate_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *waymakerSketchesServiceClient) TDigestAdd(ctx context.Context, in *TDigestAddRequest, opts ...grpc.CallOption) (*TDigestAddResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(TDigestAddResponse)
	err := c.cc.Invoke(ctx, WaymakerSketchesService_TDigestAdd_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *waymakerSketchesServiceClient) TDigestQuantile(ctx context.Context, in *TDigestQuantileRequest, opts ...grpc.CallOption) (*TDigestQuantileResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(TDigestQuantileResponse)
	err := c.cc.Invoke(ctx, WaymakerSketchesService_TDigestQuantile_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *waymakerSketchesServiceClient) TDigestMinMax(ctx context.Context, in *TDigestMinMaxRequest, opts ...grpc.CallOption) (*TDigestMinMaxResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(TDigestMinMaxResponse)
	err := c.cc.Invoke(ctx, WaymakerSketchesService_TDigestMinMax_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *waymakerSketchesServiceClient) TDigestDelete(ctx context.Context, in *TDigestDeleteRequest, opts ...grpc.CallOption) (*TDigestDeleteResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(TDigestDeleteResponse)
	err := c.cc.Invoke(ctx, WaymakerSketchesService_TDigestDelete_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *waymakerSketchesServiceClient) ReplicateProbState(ctx context.Context, in *ReplicateProbStateRequest, opts ...grpc.CallOption) (*ReplicateProbStateResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(ReplicateProbStateResponse)
	err := c.cc.Invoke(ctx, WaymakerSketchesService_ReplicateProbState_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

// WaymakerSketchesServiceServer is the server API for WaymakerSketchesService service.
// All implementations must embed UnimplementedWaymakerSketchesServiceServer
// for forward compatibility.
type WaymakerSketchesServiceServer interface {
	// ----- Bloom filter -----
	BloomReserve(context.Context, *BloomReserveRequest) (*BloomReserveResponse, error)
	BloomAdd(context.Context, *BloomAddRequest) (*BloomAddResponse, error)
	BloomMultiAdd(context.Context, *BloomMultiAddRequest) (*BloomMultiAddResponse, error)
	BloomExists(context.Context, *BloomExistsRequest) (*BloomExistsResponse, error)
	BloomMultiExists(context.Context, *BloomMultiExistsRequest) (*BloomMultiExistsResponse, error)
	BloomInfo(context.Context, *BloomInfoRequest) (*BloomInfoResponse, error)
	BloomDelete(context.Context, *BloomDeleteRequest) (*BloomDeleteResponse, error)
	// ----- HyperLogLog -----
	HllReserve(context.Context, *HllReserveRequest) (*HllReserveResponse, error)
	HllAdd(context.Context, *HllAddRequest) (*HllAddResponse, error)
	HllCount(context.Context, *HllCountRequest) (*HllCountResponse, error)
	HllMerge(context.Context, *HllMergeRequest) (*HllMergeResponse, error)
	HllDelete(context.Context, *HllDeleteRequest) (*HllDeleteResponse, error)
	// ----- Count-Min Sketch -----
	CmsReserve(context.Context, *CmsReserveRequest) (*CmsReserveResponse, error)
	CmsIncrBy(context.Context, *CmsIncrByRequest) (*CmsIncrByResponse, error)
	CmsQuery(context.Context, *CmsQueryRequest) (*CmsQueryResponse, error)
	CmsDelete(context.Context, *CmsDeleteRequest) (*CmsDeleteResponse, error)
	// ----- Top-K -----
	TopKReserve(context.Context, *TopKReserveRequest) (*TopKReserveResponse, error)
	TopKAdd(context.Context, *TopKAddRequest) (*TopKAddResponse, error)
	TopKQuery(context.Context, *TopKQueryRequest) (*TopKQueryResponse, error)
	TopKList(context.Context, *TopKListRequest) (*TopKListResponse, error)
	TopKDelete(context.Context, *TopKDeleteRequest) (*TopKDeleteResponse, error)
	// ----- t-digest -----
	TDigestCreate(context.Context, *TDigestCreateRequest) (*TDigestCreateResponse, error)
	TDigestAdd(context.Context, *TDigestAddRequest) (*TDigestAddResponse, error)
	TDigestQuantile(context.Context, *TDigestQuantileRequest) (*TDigestQuantileResponse, error)
	TDigestMinMax(context.Context, *TDigestMinMaxRequest) (*TDigestMinMaxResponse, error)
	TDigestDelete(context.Context, *TDigestDeleteRequest) (*TDigestDeleteResponse, error)
	// Internal: snapshot replication. Primary pushes serialized
	// filter state to N-1 secondaries periodically. Version counter
	// dedupes out-of-order pushes.
	ReplicateProbState(context.Context, *ReplicateProbStateRequest) (*ReplicateProbStateResponse, error)
	mustEmbedUnimplementedWaymakerSketchesServiceServer()
}

// UnimplementedWaymakerSketchesServiceServer must be embedded to have
// forward compatible implementations.
//
// NOTE: this should be embedded by value instead of pointer to avoid a nil
// pointer dereference when methods are called.
type UnimplementedWaymakerSketchesServiceServer struct{}

func (UnimplementedWaymakerSketchesServiceServer) BloomReserve(context.Context, *BloomReserveRequest) (*BloomReserveResponse, error) {
	return nil, status.Error(codes.Unimplemented, "method BloomReserve not implemented")
}
func (UnimplementedWaymakerSketchesServiceServer) BloomAdd(context.Context, *BloomAddRequest) (*BloomAddResponse, error) {
	return nil, status.Error(codes.Unimplemented, "method BloomAdd not implemented")
}
func (UnimplementedWaymakerSketchesServiceServer) BloomMultiAdd(context.Context, *BloomMultiAddRequest) (*BloomMultiAddResponse, error) {
	return nil, status.Error(codes.Unimplemented, "method BloomMultiAdd not implemented")
}
func (UnimplementedWaymakerSketchesServiceServer) BloomExists(context.Context, *BloomExistsRequest) (*BloomExistsResponse, error) {
	return nil, status.Error(codes.Unimplemented, "method BloomExists not implemented")
}
func (UnimplementedWaymakerSketchesServiceServer) BloomMultiExists(context.Context, *BloomMultiExistsRequest) (*BloomMultiExistsResponse, error) {
	return nil, status.Error(codes.Unimplemented, "method BloomMultiExists not implemented")
}
func (UnimplementedWaymakerSketchesServiceServer) BloomInfo(context.Context, *BloomInfoRequest) (*BloomInfoResponse, error) {
	return nil, status.Error(codes.Unimplemented, "method BloomInfo not implemented")
}
func (UnimplementedWaymakerSketchesServiceServer) BloomDelete(context.Context, *BloomDeleteRequest) (*BloomDeleteResponse, error) {
	return nil, status.Error(codes.Unimplemented, "method BloomDelete not implemented")
}
func (UnimplementedWaymakerSketchesServiceServer) HllReserve(context.Context, *HllReserveRequest) (*HllReserveResponse, error) {
	return nil, status.Error(codes.Unimplemented, "method HllReserve not implemented")
}
func (UnimplementedWaymakerSketchesServiceServer) HllAdd(context.Context, *HllAddRequest) (*HllAddResponse, error) {
	return nil, status.Error(codes.Unimplemented, "method HllAdd not implemented")
}
func (UnimplementedWaymakerSketchesServiceServer) HllCount(context.Context, *HllCountRequest) (*HllCountResponse, error) {
	return nil, status.Error(codes.Unimplemented, "method HllCount not implemented")
}
func (UnimplementedWaymakerSketchesServiceServer) HllMerge(context.Context, *HllMergeRequest) (*HllMergeResponse, error) {
	return nil, status.Error(codes.Unimplemented, "method HllMerge not implemented")
}
func (UnimplementedWaymakerSketchesServiceServer) HllDelete(context.Context, *HllDeleteRequest) (*HllDeleteResponse, error) {
	return nil, status.Error(codes.Unimplemented, "method HllDelete not implemented")
}
func (UnimplementedWaymakerSketchesServiceServer) CmsReserve(context.Context, *CmsReserveRequest) (*CmsReserveResponse, error) {
	return nil, status.Error(codes.Unimplemented, "method CmsReserve not implemented")
}
func (UnimplementedWaymakerSketchesServiceServer) CmsIncrBy(context.Context, *CmsIncrByRequest) (*CmsIncrByResponse, error) {
	return nil, status.Error(codes.Unimplemented, "method CmsIncrBy not implemented")
}
func (UnimplementedWaymakerSketchesServiceServer) CmsQuery(context.Context, *CmsQueryRequest) (*CmsQueryResponse, error) {
	return nil, status.Error(codes.Unimplemented, "method CmsQuery not implemented")
}
func (UnimplementedWaymakerSketchesServiceServer) CmsDelete(context.Context, *CmsDeleteRequest) (*CmsDeleteResponse, error) {
	return nil, status.Error(codes.Unimplemented, "method CmsDelete not implemented")
}
func (UnimplementedWaymakerSketchesServiceServer) TopKReserve(context.Context, *TopKReserveRequest) (*TopKReserveResponse, error) {
	return nil, status.Error(codes.Unimplemented, "method TopKReserve not implemented")
}
func (UnimplementedWaymakerSketchesServiceServer) TopKAdd(context.Context, *TopKAddRequest) (*TopKAddResponse, error) {
	return nil, status.Error(codes.Unimplemented, "method TopKAdd not implemented")
}
func (UnimplementedWaymakerSketchesServiceServer) TopKQuery(context.Context, *TopKQueryRequest) (*TopKQueryResponse, error) {
	return nil, status.Error(codes.Unimplemented, "method TopKQuery not implemented")
}
func (UnimplementedWaymakerSketchesServiceServer) TopKList(context.Context, *TopKListRequest) (*TopKListResponse, error) {
	return nil, status.Error(codes.Unimplemented, "method TopKList not implemented")
}
func (UnimplementedWaymakerSketchesServiceServer) TopKDelete(context.Context, *TopKDeleteRequest) (*TopKDeleteResponse, error) {
	return nil, status.Error(codes.Unimplemented, "method TopKDelete not implemented")
}
func (UnimplementedWaymakerSketchesServiceServer) TDigestCreate(context.Context, *TDigestCreateRequest) (*TDigestCreateResponse, error) {
	return nil, status.Error(codes.Unimplemented, "method TDigestCreate not implemented")
}
func (UnimplementedWaymakerSketchesServiceServer) TDigestAdd(context.Context, *TDigestAddRequest) (*TDigestAddResponse, error) {
	return nil, status.Error(codes.Unimplemented, "method TDigestAdd not implemented")
}
func (UnimplementedWaymakerSketchesServiceServer) TDigestQuantile(context.Context, *TDigestQuantileRequest) (*TDigestQuantileResponse, error) {
	return nil, status.Error(codes.Unimplemented, "method TDigestQuantile not implemented")
}
func (UnimplementedWaymakerSketchesServiceServer) TDigestMinMax(context.Context, *TDigestMinMaxRequest) (*TDigestMinMaxResponse, error) {
	return nil, status.Error(codes.Unimplemented, "method TDigestMinMax not implemented")
}
func (UnimplementedWaymakerSketchesServiceServer) TDigestDelete(context.Context, *TDigestDeleteRequest) (*TDigestDeleteResponse, error) {
	return nil, status.Error(codes.Unimplemented, "method TDigestDelete not implemented")
}
func (UnimplementedWaymakerSketchesServiceServer) ReplicateProbState(context.Context, *ReplicateProbStateRequest) (*ReplicateProbStateResponse, error) {
	return nil, status.Error(codes.Unimplemented, "method ReplicateProbState not implemented")
}
func (UnimplementedWaymakerSketchesServiceServer) mustEmbedUnimplementedWaymakerSketchesServiceServer() {
}
func (UnimplementedWaymakerSketchesServiceServer) testEmbeddedByValue() {}

// UnsafeWaymakerSketchesServiceServer may be embedded to opt out of forward compatibility for this service.
// Use of this interface is not recommended, as added methods to WaymakerSketchesServiceServer will
// result in compilation errors.
type UnsafeWaymakerSketchesServiceServer interface {
	mustEmbedUnimplementedWaymakerSketchesServiceServer()
}

func RegisterWaymakerSketchesServiceServer(s grpc.ServiceRegistrar, srv WaymakerSketchesServiceServer) {
	// If the following call panics, it indicates UnimplementedWaymakerSketchesServiceServer was
	// embedded by pointer and is nil.  This will cause panics if an
	// unimplemented method is ever invoked, so we test this at initialization
	// time to prevent it from happening at runtime later due to I/O.
	if t, ok := srv.(interface{ testEmbeddedByValue() }); ok {
		t.testEmbeddedByValue()
	}
	s.RegisterService(&WaymakerSketchesService_ServiceDesc, srv)
}

func _WaymakerSketchesService_BloomReserve_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(BloomReserveRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(WaymakerSketchesServiceServer).BloomReserve(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: WaymakerSketchesService_BloomReserve_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(WaymakerSketchesServiceServer).BloomReserve(ctx, req.(*BloomReserveRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _WaymakerSketchesService_BloomAdd_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(BloomAddRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(WaymakerSketchesServiceServer).BloomAdd(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: WaymakerSketchesService_BloomAdd_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(WaymakerSketchesServiceServer).BloomAdd(ctx, req.(*BloomAddRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _WaymakerSketchesService_BloomMultiAdd_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(BloomMultiAddRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(WaymakerSketchesServiceServer).BloomMultiAdd(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: WaymakerSketchesService_BloomMultiAdd_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(WaymakerSketchesServiceServer).BloomMultiAdd(ctx, req.(*BloomMultiAddRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _WaymakerSketchesService_BloomExists_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(BloomExistsRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(WaymakerSketchesServiceServer).BloomExists(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: WaymakerSketchesService_BloomExists_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(WaymakerSketchesServiceServer).BloomExists(ctx, req.(*BloomExistsRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _WaymakerSketchesService_BloomMultiExists_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(BloomMultiExistsRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(WaymakerSketchesServiceServer).BloomMultiExists(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: WaymakerSketchesService_BloomMultiExists_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(WaymakerSketchesServiceServer).BloomMultiExists(ctx, req.(*BloomMultiExistsRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _WaymakerSketchesService_BloomInfo_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(BloomInfoRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(WaymakerSketchesServiceServer).BloomInfo(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: WaymakerSketchesService_BloomInfo_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(WaymakerSketchesServiceServer).BloomInfo(ctx, req.(*BloomInfoRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _WaymakerSketchesService_BloomDelete_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(BloomDeleteRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(WaymakerSketchesServiceServer).BloomDelete(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: WaymakerSketchesService_BloomDelete_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(WaymakerSketchesServiceServer).BloomDelete(ctx, req.(*BloomDeleteRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _WaymakerSketchesService_HllReserve_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(HllReserveRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(WaymakerSketchesServiceServer).HllReserve(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: WaymakerSketchesService_HllReserve_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(WaymakerSketchesServiceServer).HllReserve(ctx, req.(*HllReserveRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _WaymakerSketchesService_HllAdd_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(HllAddRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(WaymakerSketchesServiceServer).HllAdd(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: WaymakerSketchesService_HllAdd_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(WaymakerSketchesServiceServer).HllAdd(ctx, req.(*HllAddRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _WaymakerSketchesService_HllCount_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(HllCountRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(WaymakerSketchesServiceServer).HllCount(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: WaymakerSketchesService_HllCount_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(WaymakerSketchesServiceServer).HllCount(ctx, req.(*HllCountRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _WaymakerSketchesService_HllMerge_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(HllMergeRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(WaymakerSketchesServiceServer).HllMerge(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: WaymakerSketchesService_HllMerge_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(WaymakerSketchesServiceServer).HllMerge(ctx, req.(*HllMergeRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _WaymakerSketchesService_HllDelete_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(HllDeleteRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(WaymakerSketchesServiceServer).HllDelete(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: WaymakerSketchesService_HllDelete_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(WaymakerSketchesServiceServer).HllDelete(ctx, req.(*HllDeleteRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _WaymakerSketchesService_CmsReserve_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(CmsReserveRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(WaymakerSketchesServiceServer).CmsReserve(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: WaymakerSketchesService_CmsReserve_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(WaymakerSketchesServiceServer).CmsReserve(ctx, req.(*CmsReserveRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _WaymakerSketchesService_CmsIncrBy_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(CmsIncrByRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(WaymakerSketchesServiceServer).CmsIncrBy(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: WaymakerSketchesService_CmsIncrBy_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(WaymakerSketchesServiceServer).CmsIncrBy(ctx, req.(*CmsIncrByRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _WaymakerSketchesService_CmsQuery_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(CmsQueryRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(WaymakerSketchesServiceServer).CmsQuery(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: WaymakerSketchesService_CmsQuery_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(WaymakerSketchesServiceServer).CmsQuery(ctx, req.(*CmsQueryRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _WaymakerSketchesService_CmsDelete_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(CmsDeleteRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(WaymakerSketchesServiceServer).CmsDelete(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: WaymakerSketchesService_CmsDelete_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(WaymakerSketchesServiceServer).CmsDelete(ctx, req.(*CmsDeleteRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _WaymakerSketchesService_TopKReserve_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(TopKReserveRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(WaymakerSketchesServiceServer).TopKReserve(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: WaymakerSketchesService_TopKReserve_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(WaymakerSketchesServiceServer).TopKReserve(ctx, req.(*TopKReserveRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _WaymakerSketchesService_TopKAdd_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(TopKAddRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(WaymakerSketchesServiceServer).TopKAdd(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: WaymakerSketchesService_TopKAdd_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(WaymakerSketchesServiceServer).TopKAdd(ctx, req.(*TopKAddRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _WaymakerSketchesService_TopKQuery_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(TopKQueryRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(WaymakerSketchesServiceServer).TopKQuery(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: WaymakerSketchesService_TopKQuery_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(WaymakerSketchesServiceServer).TopKQuery(ctx, req.(*TopKQueryRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _WaymakerSketchesService_TopKList_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(TopKListRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(WaymakerSketchesServiceServer).TopKList(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: WaymakerSketchesService_TopKList_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(WaymakerSketchesServiceServer).TopKList(ctx, req.(*TopKListRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _WaymakerSketchesService_TopKDelete_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(TopKDeleteRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(WaymakerSketchesServiceServer).TopKDelete(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: WaymakerSketchesService_TopKDelete_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(WaymakerSketchesServiceServer).TopKDelete(ctx, req.(*TopKDeleteRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _WaymakerSketchesService_TDigestCreate_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(TDigestCreateRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(WaymakerSketchesServiceServer).TDigestCreate(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: WaymakerSketchesService_TDigestCreate_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(WaymakerSketchesServiceServer).TDigestCreate(ctx, req.(*TDigestCreateRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _WaymakerSketchesService_TDigestAdd_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(TDigestAddRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(WaymakerSketchesServiceServer).TDigestAdd(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: WaymakerSketchesService_TDigestAdd_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(WaymakerSketchesServiceServer).TDigestAdd(ctx, req.(*TDigestAddRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _WaymakerSketchesService_TDigestQuantile_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(TDigestQuantileRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(WaymakerSketchesServiceServer).TDigestQuantile(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: WaymakerSketchesService_TDigestQuantile_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(WaymakerSketchesServiceServer).TDigestQuantile(ctx, req.(*TDigestQuantileRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _WaymakerSketchesService_TDigestMinMax_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(TDigestMinMaxRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(WaymakerSketchesServiceServer).TDigestMinMax(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: WaymakerSketchesService_TDigestMinMax_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(WaymakerSketchesServiceServer).TDigestMinMax(ctx, req.(*TDigestMinMaxRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _WaymakerSketchesService_TDigestDelete_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(TDigestDeleteRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(WaymakerSketchesServiceServer).TDigestDelete(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: WaymakerSketchesService_TDigestDelete_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(WaymakerSketchesServiceServer).TDigestDelete(ctx, req.(*TDigestDeleteRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _WaymakerSketchesService_ReplicateProbState_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ReplicateProbStateRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(WaymakerSketchesServiceServer).ReplicateProbState(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: WaymakerSketchesService_ReplicateProbState_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(WaymakerSketchesServiceServer).ReplicateProbState(ctx, req.(*ReplicateProbStateRequest))
	}
	return interceptor(ctx, in, info, handler)
}

// WaymakerSketchesService_ServiceDesc is the grpc.ServiceDesc for WaymakerSketchesService service.
// It's only intended for direct use with grpc.RegisterService,
// and not to be introspected or modified (even as a copy)
var WaymakerSketchesService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "waymaker.sketches.WaymakerSketchesService",
	HandlerType: (*WaymakerSketchesServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "BloomReserve",
			Handler:    _WaymakerSketchesService_BloomReserve_Handler,
		},
		{
			MethodName: "BloomAdd",
			Handler:    _WaymakerSketchesService_BloomAdd_Handler,
		},
		{
			MethodName: "BloomMultiAdd",
			Handler:    _WaymakerSketchesService_BloomMultiAdd_Handler,
		},
		{
			MethodName: "BloomExists",
			Handler:    _WaymakerSketchesService_BloomExists_Handler,
		},
		{
			MethodName: "BloomMultiExists",
			Handler:    _WaymakerSketchesService_BloomMultiExists_Handler,
		},
		{
			MethodName: "BloomInfo",
			Handler:    _WaymakerSketchesService_BloomInfo_Handler,
		},
		{
			MethodName: "BloomDelete",
			Handler:    _WaymakerSketchesService_BloomDelete_Handler,
		},
		{
			MethodName: "HllReserve",
			Handler:    _WaymakerSketchesService_HllReserve_Handler,
		},
		{
			MethodName: "HllAdd",
			Handler:    _WaymakerSketchesService_HllAdd_Handler,
		},
		{
			MethodName: "HllCount",
			Handler:    _WaymakerSketchesService_HllCount_Handler,
		},
		{
			MethodName: "HllMerge",
			Handler:    _WaymakerSketchesService_HllMerge_Handler,
		},
		{
			MethodName: "HllDelete",
			Handler:    _WaymakerSketchesService_HllDelete_Handler,
		},
		{
			MethodName: "CmsReserve",
			Handler:    _WaymakerSketchesService_CmsReserve_Handler,
		},
		{
			MethodName: "CmsIncrBy",
			Handler:    _WaymakerSketchesService_CmsIncrBy_Handler,
		},
		{
			MethodName: "CmsQuery",
			Handler:    _WaymakerSketchesService_CmsQuery_Handler,
		},
		{
			MethodName: "CmsDelete",
			Handler:    _WaymakerSketchesService_CmsDelete_Handler,
		},
		{
			MethodName: "TopKReserve",
			Handler:    _WaymakerSketchesService_TopKReserve_Handler,
		},
		{
			MethodName: "TopKAdd",
			Handler:    _WaymakerSketchesService_TopKAdd_Handler,
		},
		{
			MethodName: "TopKQuery",
			Handler:    _WaymakerSketchesService_TopKQuery_Handler,
		},
		{
			MethodName: "TopKList",
			Handler:    _WaymakerSketchesService_TopKList_Handler,
		},
		{
			MethodName: "TopKDelete",
			Handler:    _WaymakerSketchesService_TopKDelete_Handler,
		},
		{
			MethodName: "TDigestCreate",
			Handler:    _WaymakerSketchesService_TDigestCreate_Handler,
		},
		{
			MethodName: "TDigestAdd",
			Handler:    _WaymakerSketchesService_TDigestAdd_Handler,
		},
		{
			MethodName: "TDigestQuantile",
			Handler:    _WaymakerSketchesService_TDigestQuantile_Handler,
		},
		{
			MethodName: "TDigestMinMax",
			Handler:    _WaymakerSketchesService_TDigestMinMax_Handler,
		},
		{
			MethodName: "TDigestDelete",
			Handler:    _WaymakerSketchesService_TDigestDelete_Handler,
		},
		{
			MethodName: "ReplicateProbState",
			Handler:    _WaymakerSketchesService_ReplicateProbState_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "sketches.proto",
}