// Code generated by protoc-gen-go-grpc. DO NOT EDIT.
// versions:
// - protoc-gen-go-grpc v1.3.0
// - protoc             v5.29.3
// source: proxy.proto

package protobufs

import (
	context "context"
	grpc "google.golang.org/grpc"
	codes "google.golang.org/grpc/codes"
	status "google.golang.org/grpc/status"
	emptypb "google.golang.org/protobuf/types/known/emptypb"
	wrapperspb "google.golang.org/protobuf/types/known/wrapperspb"
)

// 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.32.0 or later.
const _ = grpc.SupportPackageIsVersion7

const (
	PubSubProxy_PublishToBitmask_FullMethodName         = "/quilibrium.node.proxy.pb.PubSubProxy/PublishToBitmask"
	PubSubProxy_Publish_FullMethodName                  = "/quilibrium.node.proxy.pb.PubSubProxy/Publish"
	PubSubProxy_Subscribe_FullMethodName                = "/quilibrium.node.proxy.pb.PubSubProxy/Subscribe"
	PubSubProxy_Unsubscribe_FullMethodName              = "/quilibrium.node.proxy.pb.PubSubProxy/Unsubscribe"
	PubSubProxy_ValidatorStream_FullMethodName          = "/quilibrium.node.proxy.pb.PubSubProxy/ValidatorStream"
	PubSubProxy_GetPeerID_FullMethodName                = "/quilibrium.node.proxy.pb.PubSubProxy/GetPeerID"
	PubSubProxy_GetPeerstoreCount_FullMethodName        = "/quilibrium.node.proxy.pb.PubSubProxy/GetPeerstoreCount"
	PubSubProxy_GetNetworkPeersCount_FullMethodName     = "/quilibrium.node.proxy.pb.PubSubProxy/GetNetworkPeersCount"
	PubSubProxy_GetRandomPeer_FullMethodName            = "/quilibrium.node.proxy.pb.PubSubProxy/GetRandomPeer"
	PubSubProxy_GetMultiaddrOfPeer_FullMethodName       = "/quilibrium.node.proxy.pb.PubSubProxy/GetMultiaddrOfPeer"
	PubSubProxy_GetMultiaddrOfPeerStream_FullMethodName = "/quilibrium.node.proxy.pb.PubSubProxy/GetMultiaddrOfPeerStream"
	PubSubProxy_GetOwnMultiaddrs_FullMethodName         = "/quilibrium.node.proxy.pb.PubSubProxy/GetOwnMultiaddrs"
	PubSubProxy_GetNetworkInfo_FullMethodName           = "/quilibrium.node.proxy.pb.PubSubProxy/GetNetworkInfo"
	PubSubProxy_GetPeerScore_FullMethodName             = "/quilibrium.node.proxy.pb.PubSubProxy/GetPeerScore"
	PubSubProxy_SetPeerScore_FullMethodName             = "/quilibrium.node.proxy.pb.PubSubProxy/SetPeerScore"
	PubSubProxy_AddPeerScore_FullMethodName             = "/quilibrium.node.proxy.pb.PubSubProxy/AddPeerScore"
	PubSubProxy_Reconnect_FullMethodName                = "/quilibrium.node.proxy.pb.PubSubProxy/Reconnect"
	PubSubProxy_Bootstrap_FullMethodName                = "/quilibrium.node.proxy.pb.PubSubProxy/Bootstrap"
	PubSubProxy_DiscoverPeers_FullMethodName            = "/quilibrium.node.proxy.pb.PubSubProxy/DiscoverPeers"
	PubSubProxy_IsPeerConnected_FullMethodName          = "/quilibrium.node.proxy.pb.PubSubProxy/IsPeerConnected"
	PubSubProxy_GetNetwork_FullMethodName               = "/quilibrium.node.proxy.pb.PubSubProxy/GetNetwork"
	PubSubProxy_Reachability_FullMethodName             = "/quilibrium.node.proxy.pb.PubSubProxy/Reachability"
	PubSubProxy_SignMessage_FullMethodName              = "/quilibrium.node.proxy.pb.PubSubProxy/SignMessage"
	PubSubProxy_GetPublicKey_FullMethodName             = "/quilibrium.node.proxy.pb.PubSubProxy/GetPublicKey"
)

// PubSubProxyClient is the client API for PubSubProxy 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 PubSubProxyClient interface {
	// Publishing methods
	PublishToBitmask(ctx context.Context, in *PublishToBitmaskRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	Publish(ctx context.Context, in *PublishRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Subscription methods
	Subscribe(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (PubSubProxy_SubscribeClient, error)
	Unsubscribe(ctx context.Context, in *UnsubscribeRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Validator methods - bidirectional streaming for validation callbacks
	ValidatorStream(ctx context.Context, opts ...grpc.CallOption) (PubSubProxy_ValidatorStreamClient, error)
	// Peer information methods
	GetPeerID(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*GetPeerIDResponse, error)
	GetPeerstoreCount(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*GetPeerstoreCountResponse, error)
	GetNetworkPeersCount(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*GetNetworkPeersCountResponse, error)
	GetRandomPeer(ctx context.Context, in *GetRandomPeerRequest, opts ...grpc.CallOption) (*GetRandomPeerResponse, error)
	GetMultiaddrOfPeer(ctx context.Context, in *GetMultiaddrOfPeerRequest, opts ...grpc.CallOption) (*GetMultiaddrOfPeerResponse, error)
	GetMultiaddrOfPeerStream(ctx context.Context, in *GetMultiaddrOfPeerRequest, opts ...grpc.CallOption) (PubSubProxy_GetMultiaddrOfPeerStreamClient, error)
	GetOwnMultiaddrs(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*GetOwnMultiaddrsResponse, error)
	GetNetworkInfo(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*NetworkInfoResponse, error)
	// Scoring methods
	GetPeerScore(ctx context.Context, in *GetPeerScoreRequest, opts ...grpc.CallOption) (*GetPeerScoreResponse, error)
	SetPeerScore(ctx context.Context, in *SetPeerScoreRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	AddPeerScore(ctx context.Context, in *AddPeerScoreRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Connection management
	Reconnect(ctx context.Context, in *ReconnectRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	Bootstrap(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)
	DiscoverPeers(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)
	IsPeerConnected(ctx context.Context, in *IsPeerConnectedRequest, opts ...grpc.CallOption) (*IsPeerConnectedResponse, error)
	// Utility methods
	GetNetwork(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*GetNetworkResponse, error)
	Reachability(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*wrapperspb.BoolValue, error)
	SignMessage(ctx context.Context, in *SignMessageRequest, opts ...grpc.CallOption) (*SignMessageResponse, error)
	GetPublicKey(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*GetPublicKeyResponse, error)
}

type pubSubProxyClient struct {
	cc grpc.ClientConnInterface
}

func NewPubSubProxyClient(cc grpc.ClientConnInterface) PubSubProxyClient {
	return &pubSubProxyClient{cc}
}

func (c *pubSubProxyClient) PublishToBitmask(ctx context.Context, in *PublishToBitmaskRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {
	out := new(emptypb.Empty)
	err := c.cc.Invoke(ctx, PubSubProxy_PublishToBitmask_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *pubSubProxyClient) Publish(ctx context.Context, in *PublishRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {
	out := new(emptypb.Empty)
	err := c.cc.Invoke(ctx, PubSubProxy_Publish_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *pubSubProxyClient) Subscribe(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (PubSubProxy_SubscribeClient, error) {
	stream, err := c.cc.NewStream(ctx, &PubSubProxy_ServiceDesc.Streams[0], PubSubProxy_Subscribe_FullMethodName, opts...)
	if err != nil {
		return nil, err
	}
	x := &pubSubProxySubscribeClient{stream}
	if err := x.ClientStream.SendMsg(in); err != nil {
		return nil, err
	}
	if err := x.ClientStream.CloseSend(); err != nil {
		return nil, err
	}
	return x, nil
}

type PubSubProxy_SubscribeClient interface {
	Recv() (*MessageEvent, error)
	grpc.ClientStream
}

type pubSubProxySubscribeClient struct {
	grpc.ClientStream
}

func (x *pubSubProxySubscribeClient) Recv() (*MessageEvent, error) {
	m := new(MessageEvent)
	if err := x.ClientStream.RecvMsg(m); err != nil {
		return nil, err
	}
	return m, nil
}

func (c *pubSubProxyClient) Unsubscribe(ctx context.Context, in *UnsubscribeRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {
	out := new(emptypb.Empty)
	err := c.cc.Invoke(ctx, PubSubProxy_Unsubscribe_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *pubSubProxyClient) ValidatorStream(ctx context.Context, opts ...grpc.CallOption) (PubSubProxy_ValidatorStreamClient, error) {
	stream, err := c.cc.NewStream(ctx, &PubSubProxy_ServiceDesc.Streams[1], PubSubProxy_ValidatorStream_FullMethodName, opts...)
	if err != nil {
		return nil, err
	}
	x := &pubSubProxyValidatorStreamClient{stream}
	return x, nil
}

type PubSubProxy_ValidatorStreamClient interface {
	Send(*ValidationStreamMessage) error
	Recv() (*ValidationStreamMessage, error)
	grpc.ClientStream
}

type pubSubProxyValidatorStreamClient struct {
	grpc.ClientStream
}

func (x *pubSubProxyValidatorStreamClient) Send(m *ValidationStreamMessage) error {
	return x.ClientStream.SendMsg(m)
}

func (x *pubSubProxyValidatorStreamClient) Recv() (*ValidationStreamMessage, error) {
	m := new(ValidationStreamMessage)
	if err := x.ClientStream.RecvMsg(m); err != nil {
		return nil, err
	}
	return m, nil
}

func (c *pubSubProxyClient) GetPeerID(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*GetPeerIDResponse, error) {
	out := new(GetPeerIDResponse)
	err := c.cc.Invoke(ctx, PubSubProxy_GetPeerID_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *pubSubProxyClient) GetPeerstoreCount(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*GetPeerstoreCountResponse, error) {
	out := new(GetPeerstoreCountResponse)
	err := c.cc.Invoke(ctx, PubSubProxy_GetPeerstoreCount_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *pubSubProxyClient) GetNetworkPeersCount(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*GetNetworkPeersCountResponse, error) {
	out := new(GetNetworkPeersCountResponse)
	err := c.cc.Invoke(ctx, PubSubProxy_GetNetworkPeersCount_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *pubSubProxyClient) GetRandomPeer(ctx context.Context, in *GetRandomPeerRequest, opts ...grpc.CallOption) (*GetRandomPeerResponse, error) {
	out := new(GetRandomPeerResponse)
	err := c.cc.Invoke(ctx, PubSubProxy_GetRandomPeer_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *pubSubProxyClient) GetMultiaddrOfPeer(ctx context.Context, in *GetMultiaddrOfPeerRequest, opts ...grpc.CallOption) (*GetMultiaddrOfPeerResponse, error) {
	out := new(GetMultiaddrOfPeerResponse)
	err := c.cc.Invoke(ctx, PubSubProxy_GetMultiaddrOfPeer_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *pubSubProxyClient) GetMultiaddrOfPeerStream(ctx context.Context, in *GetMultiaddrOfPeerRequest, opts ...grpc.CallOption) (PubSubProxy_GetMultiaddrOfPeerStreamClient, error) {
	stream, err := c.cc.NewStream(ctx, &PubSubProxy_ServiceDesc.Streams[2], PubSubProxy_GetMultiaddrOfPeerStream_FullMethodName, opts...)
	if err != nil {
		return nil, err
	}
	x := &pubSubProxyGetMultiaddrOfPeerStreamClient{stream}
	if err := x.ClientStream.SendMsg(in); err != nil {
		return nil, err
	}
	if err := x.ClientStream.CloseSend(); err != nil {
		return nil, err
	}
	return x, nil
}

type PubSubProxy_GetMultiaddrOfPeerStreamClient interface {
	Recv() (*GetMultiaddrOfPeerResponse, error)
	grpc.ClientStream
}

type pubSubProxyGetMultiaddrOfPeerStreamClient struct {
	grpc.ClientStream
}

func (x *pubSubProxyGetMultiaddrOfPeerStreamClient) Recv() (*GetMultiaddrOfPeerResponse, error) {
	m := new(GetMultiaddrOfPeerResponse)
	if err := x.ClientStream.RecvMsg(m); err != nil {
		return nil, err
	}
	return m, nil
}

func (c *pubSubProxyClient) GetOwnMultiaddrs(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*GetOwnMultiaddrsResponse, error) {
	out := new(GetOwnMultiaddrsResponse)
	err := c.cc.Invoke(ctx, PubSubProxy_GetOwnMultiaddrs_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *pubSubProxyClient) GetNetworkInfo(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*NetworkInfoResponse, error) {
	out := new(NetworkInfoResponse)
	err := c.cc.Invoke(ctx, PubSubProxy_GetNetworkInfo_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *pubSubProxyClient) GetPeerScore(ctx context.Context, in *GetPeerScoreRequest, opts ...grpc.CallOption) (*GetPeerScoreResponse, error) {
	out := new(GetPeerScoreResponse)
	err := c.cc.Invoke(ctx, PubSubProxy_GetPeerScore_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *pubSubProxyClient) SetPeerScore(ctx context.Context, in *SetPeerScoreRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {
	out := new(emptypb.Empty)
	err := c.cc.Invoke(ctx, PubSubProxy_SetPeerScore_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *pubSubProxyClient) AddPeerScore(ctx context.Context, in *AddPeerScoreRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {
	out := new(emptypb.Empty)
	err := c.cc.Invoke(ctx, PubSubProxy_AddPeerScore_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *pubSubProxyClient) Reconnect(ctx context.Context, in *ReconnectRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {
	out := new(emptypb.Empty)
	err := c.cc.Invoke(ctx, PubSubProxy_Reconnect_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *pubSubProxyClient) Bootstrap(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error) {
	out := new(emptypb.Empty)
	err := c.cc.Invoke(ctx, PubSubProxy_Bootstrap_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *pubSubProxyClient) DiscoverPeers(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error) {
	out := new(emptypb.Empty)
	err := c.cc.Invoke(ctx, PubSubProxy_DiscoverPeers_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *pubSubProxyClient) IsPeerConnected(ctx context.Context, in *IsPeerConnectedRequest, opts ...grpc.CallOption) (*IsPeerConnectedResponse, error) {
	out := new(IsPeerConnectedResponse)
	err := c.cc.Invoke(ctx, PubSubProxy_IsPeerConnected_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *pubSubProxyClient) GetNetwork(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*GetNetworkResponse, error) {
	out := new(GetNetworkResponse)
	err := c.cc.Invoke(ctx, PubSubProxy_GetNetwork_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *pubSubProxyClient) Reachability(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*wrapperspb.BoolValue, error) {
	out := new(wrapperspb.BoolValue)
	err := c.cc.Invoke(ctx, PubSubProxy_Reachability_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *pubSubProxyClient) SignMessage(ctx context.Context, in *SignMessageRequest, opts ...grpc.CallOption) (*SignMessageResponse, error) {
	out := new(SignMessageResponse)
	err := c.cc.Invoke(ctx, PubSubProxy_SignMessage_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *pubSubProxyClient) GetPublicKey(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*GetPublicKeyResponse, error) {
	out := new(GetPublicKeyResponse)
	err := c.cc.Invoke(ctx, PubSubProxy_GetPublicKey_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

// PubSubProxyServer is the server API for PubSubProxy service.
// All implementations must embed UnimplementedPubSubProxyServer
// for forward compatibility
type PubSubProxyServer interface {
	// Publishing methods
	PublishToBitmask(context.Context, *PublishToBitmaskRequest) (*emptypb.Empty, error)
	Publish(context.Context, *PublishRequest) (*emptypb.Empty, error)
	// Subscription methods
	Subscribe(*SubscribeRequest, PubSubProxy_SubscribeServer) error
	Unsubscribe(context.Context, *UnsubscribeRequest) (*emptypb.Empty, error)
	// Validator methods - bidirectional streaming for validation callbacks
	ValidatorStream(PubSubProxy_ValidatorStreamServer) error
	// Peer information methods
	GetPeerID(context.Context, *emptypb.Empty) (*GetPeerIDResponse, error)
	GetPeerstoreCount(context.Context, *emptypb.Empty) (*GetPeerstoreCountResponse, error)
	GetNetworkPeersCount(context.Context, *emptypb.Empty) (*GetNetworkPeersCountResponse, error)
	GetRandomPeer(context.Context, *GetRandomPeerRequest) (*GetRandomPeerResponse, error)
	GetMultiaddrOfPeer(context.Context, *GetMultiaddrOfPeerRequest) (*GetMultiaddrOfPeerResponse, error)
	GetMultiaddrOfPeerStream(*GetMultiaddrOfPeerRequest, PubSubProxy_GetMultiaddrOfPeerStreamServer) error
	GetOwnMultiaddrs(context.Context, *emptypb.Empty) (*GetOwnMultiaddrsResponse, error)
	GetNetworkInfo(context.Context, *emptypb.Empty) (*NetworkInfoResponse, error)
	// Scoring methods
	GetPeerScore(context.Context, *GetPeerScoreRequest) (*GetPeerScoreResponse, error)
	SetPeerScore(context.Context, *SetPeerScoreRequest) (*emptypb.Empty, error)
	AddPeerScore(context.Context, *AddPeerScoreRequest) (*emptypb.Empty, error)
	// Connection management
	Reconnect(context.Context, *ReconnectRequest) (*emptypb.Empty, error)
	Bootstrap(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
	DiscoverPeers(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
	IsPeerConnected(context.Context, *IsPeerConnectedRequest) (*IsPeerConnectedResponse, error)
	// Utility methods
	GetNetwork(context.Context, *emptypb.Empty) (*GetNetworkResponse, error)
	Reachability(context.Context, *emptypb.Empty) (*wrapperspb.BoolValue, error)
	SignMessage(context.Context, *SignMessageRequest) (*SignMessageResponse, error)
	GetPublicKey(context.Context, *emptypb.Empty) (*GetPublicKeyResponse, error)
	mustEmbedUnimplementedPubSubProxyServer()
}

// UnimplementedPubSubProxyServer must be embedded to have forward compatible implementations.
type UnimplementedPubSubProxyServer struct {
}

func (UnimplementedPubSubProxyServer) PublishToBitmask(context.Context, *PublishToBitmaskRequest) (*emptypb.Empty, error) {
	return nil, status.Errorf(codes.Unimplemented, "method PublishToBitmask not implemented")
}
func (UnimplementedPubSubProxyServer) Publish(context.Context, *PublishRequest) (*emptypb.Empty, error) {
	return nil, status.Errorf(codes.Unimplemented, "method Publish not implemented")
}
func (UnimplementedPubSubProxyServer) Subscribe(*SubscribeRequest, PubSubProxy_SubscribeServer) error {
	return status.Errorf(codes.Unimplemented, "method Subscribe not implemented")
}
func (UnimplementedPubSubProxyServer) Unsubscribe(context.Context, *UnsubscribeRequest) (*emptypb.Empty, error) {
	return nil, status.Errorf(codes.Unimplemented, "method Unsubscribe not implemented")
}
func (UnimplementedPubSubProxyServer) ValidatorStream(PubSubProxy_ValidatorStreamServer) error {
	return status.Errorf(codes.Unimplemented, "method ValidatorStream not implemented")
}
func (UnimplementedPubSubProxyServer) GetPeerID(context.Context, *emptypb.Empty) (*GetPeerIDResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetPeerID not implemented")
}
func (UnimplementedPubSubProxyServer) GetPeerstoreCount(context.Context, *emptypb.Empty) (*GetPeerstoreCountResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetPeerstoreCount not implemented")
}
func (UnimplementedPubSubProxyServer) GetNetworkPeersCount(context.Context, *emptypb.Empty) (*GetNetworkPeersCountResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetNetworkPeersCount not implemented")
}
func (UnimplementedPubSubProxyServer) GetRandomPeer(context.Context, *GetRandomPeerRequest) (*GetRandomPeerResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetRandomPeer not implemented")
}
func (UnimplementedPubSubProxyServer) GetMultiaddrOfPeer(context.Context, *GetMultiaddrOfPeerRequest) (*GetMultiaddrOfPeerResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetMultiaddrOfPeer not implemented")
}
func (UnimplementedPubSubProxyServer) GetMultiaddrOfPeerStream(*GetMultiaddrOfPeerRequest, PubSubProxy_GetMultiaddrOfPeerStreamServer) error {
	return status.Errorf(codes.Unimplemented, "method GetMultiaddrOfPeerStream not implemented")
}
func (UnimplementedPubSubProxyServer) GetOwnMultiaddrs(context.Context, *emptypb.Empty) (*GetOwnMultiaddrsResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetOwnMultiaddrs not implemented")
}
func (UnimplementedPubSubProxyServer) GetNetworkInfo(context.Context, *emptypb.Empty) (*NetworkInfoResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetNetworkInfo not implemented")
}
func (UnimplementedPubSubProxyServer) GetPeerScore(context.Context, *GetPeerScoreRequest) (*GetPeerScoreResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetPeerScore not implemented")
}
func (UnimplementedPubSubProxyServer) SetPeerScore(context.Context, *SetPeerScoreRequest) (*emptypb.Empty, error) {
	return nil, status.Errorf(codes.Unimplemented, "method SetPeerScore not implemented")
}
func (UnimplementedPubSubProxyServer) AddPeerScore(context.Context, *AddPeerScoreRequest) (*emptypb.Empty, error) {
	return nil, status.Errorf(codes.Unimplemented, "method AddPeerScore not implemented")
}
func (UnimplementedPubSubProxyServer) Reconnect(context.Context, *ReconnectRequest) (*emptypb.Empty, error) {
	return nil, status.Errorf(codes.Unimplemented, "method Reconnect not implemented")
}
func (UnimplementedPubSubProxyServer) Bootstrap(context.Context, *emptypb.Empty) (*emptypb.Empty, error) {
	return nil, status.Errorf(codes.Unimplemented, "method Bootstrap not implemented")
}
func (UnimplementedPubSubProxyServer) DiscoverPeers(context.Context, *emptypb.Empty) (*emptypb.Empty, error) {
	return nil, status.Errorf(codes.Unimplemented, "method DiscoverPeers not implemented")
}
func (UnimplementedPubSubProxyServer) IsPeerConnected(context.Context, *IsPeerConnectedRequest) (*IsPeerConnectedResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method IsPeerConnected not implemented")
}
func (UnimplementedPubSubProxyServer) GetNetwork(context.Context, *emptypb.Empty) (*GetNetworkResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetNetwork not implemented")
}
func (UnimplementedPubSubProxyServer) Reachability(context.Context, *emptypb.Empty) (*wrapperspb.BoolValue, error) {
	return nil, status.Errorf(codes.Unimplemented, "method Reachability not implemented")
}
func (UnimplementedPubSubProxyServer) SignMessage(context.Context, *SignMessageRequest) (*SignMessageResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method SignMessage not implemented")
}
func (UnimplementedPubSubProxyServer) GetPublicKey(context.Context, *emptypb.Empty) (*GetPublicKeyResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetPublicKey not implemented")
}
func (UnimplementedPubSubProxyServer) mustEmbedUnimplementedPubSubProxyServer() {}

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

func RegisterPubSubProxyServer(s grpc.ServiceRegistrar, srv PubSubProxyServer) {
	s.RegisterService(&PubSubProxy_ServiceDesc, srv)
}

func _PubSubProxy_PublishToBitmask_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(PublishToBitmaskRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(PubSubProxyServer).PublishToBitmask(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: PubSubProxy_PublishToBitmask_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(PubSubProxyServer).PublishToBitmask(ctx, req.(*PublishToBitmaskRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _PubSubProxy_Publish_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(PublishRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(PubSubProxyServer).Publish(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: PubSubProxy_Publish_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(PubSubProxyServer).Publish(ctx, req.(*PublishRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _PubSubProxy_Subscribe_Handler(srv interface{}, stream grpc.ServerStream) error {
	m := new(SubscribeRequest)
	if err := stream.RecvMsg(m); err != nil {
		return err
	}
	return srv.(PubSubProxyServer).Subscribe(m, &pubSubProxySubscribeServer{stream})
}

type PubSubProxy_SubscribeServer interface {
	Send(*MessageEvent) error
	grpc.ServerStream
}

type pubSubProxySubscribeServer struct {
	grpc.ServerStream
}

func (x *pubSubProxySubscribeServer) Send(m *MessageEvent) error {
	return x.ServerStream.SendMsg(m)
}

func _PubSubProxy_Unsubscribe_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(UnsubscribeRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(PubSubProxyServer).Unsubscribe(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: PubSubProxy_Unsubscribe_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(PubSubProxyServer).Unsubscribe(ctx, req.(*UnsubscribeRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _PubSubProxy_ValidatorStream_Handler(srv interface{}, stream grpc.ServerStream) error {
	return srv.(PubSubProxyServer).ValidatorStream(&pubSubProxyValidatorStreamServer{stream})
}

type PubSubProxy_ValidatorStreamServer interface {
	Send(*ValidationStreamMessage) error
	Recv() (*ValidationStreamMessage, error)
	grpc.ServerStream
}

type pubSubProxyValidatorStreamServer struct {
	grpc.ServerStream
}

func (x *pubSubProxyValidatorStreamServer) Send(m *ValidationStreamMessage) error {
	return x.ServerStream.SendMsg(m)
}

func (x *pubSubProxyValidatorStreamServer) Recv() (*ValidationStreamMessage, error) {
	m := new(ValidationStreamMessage)
	if err := x.ServerStream.RecvMsg(m); err != nil {
		return nil, err
	}
	return m, nil
}

func _PubSubProxy_GetPeerID_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(emptypb.Empty)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(PubSubProxyServer).GetPeerID(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: PubSubProxy_GetPeerID_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(PubSubProxyServer).GetPeerID(ctx, req.(*emptypb.Empty))
	}
	return interceptor(ctx, in, info, handler)
}

func _PubSubProxy_GetPeerstoreCount_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(emptypb.Empty)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(PubSubProxyServer).GetPeerstoreCount(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: PubSubProxy_GetPeerstoreCount_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(PubSubProxyServer).GetPeerstoreCount(ctx, req.(*emptypb.Empty))
	}
	return interceptor(ctx, in, info, handler)
}

func _PubSubProxy_GetNetworkPeersCount_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(emptypb.Empty)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(PubSubProxyServer).GetNetworkPeersCount(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: PubSubProxy_GetNetworkPeersCount_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(PubSubProxyServer).GetNetworkPeersCount(ctx, req.(*emptypb.Empty))
	}
	return interceptor(ctx, in, info, handler)
}

func _PubSubProxy_GetRandomPeer_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetRandomPeerRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(PubSubProxyServer).GetRandomPeer(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: PubSubProxy_GetRandomPeer_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(PubSubProxyServer).GetRandomPeer(ctx, req.(*GetRandomPeerRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _PubSubProxy_GetMultiaddrOfPeer_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetMultiaddrOfPeerRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(PubSubProxyServer).GetMultiaddrOfPeer(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: PubSubProxy_GetMultiaddrOfPeer_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(PubSubProxyServer).GetMultiaddrOfPeer(ctx, req.(*GetMultiaddrOfPeerRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _PubSubProxy_GetMultiaddrOfPeerStream_Handler(srv interface{}, stream grpc.ServerStream) error {
	m := new(GetMultiaddrOfPeerRequest)
	if err := stream.RecvMsg(m); err != nil {
		return err
	}
	return srv.(PubSubProxyServer).GetMultiaddrOfPeerStream(m, &pubSubProxyGetMultiaddrOfPeerStreamServer{stream})
}

type PubSubProxy_GetMultiaddrOfPeerStreamServer interface {
	Send(*GetMultiaddrOfPeerResponse) error
	grpc.ServerStream
}

type pubSubProxyGetMultiaddrOfPeerStreamServer struct {
	grpc.ServerStream
}

func (x *pubSubProxyGetMultiaddrOfPeerStreamServer) Send(m *GetMultiaddrOfPeerResponse) error {
	return x.ServerStream.SendMsg(m)
}

func _PubSubProxy_GetOwnMultiaddrs_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(emptypb.Empty)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(PubSubProxyServer).GetOwnMultiaddrs(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: PubSubProxy_GetOwnMultiaddrs_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(PubSubProxyServer).GetOwnMultiaddrs(ctx, req.(*emptypb.Empty))
	}
	return interceptor(ctx, in, info, handler)
}

func _PubSubProxy_GetNetworkInfo_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(emptypb.Empty)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(PubSubProxyServer).GetNetworkInfo(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: PubSubProxy_GetNetworkInfo_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(PubSubProxyServer).GetNetworkInfo(ctx, req.(*emptypb.Empty))
	}
	return interceptor(ctx, in, info, handler)
}

func _PubSubProxy_GetPeerScore_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetPeerScoreRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(PubSubProxyServer).GetPeerScore(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: PubSubProxy_GetPeerScore_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(PubSubProxyServer).GetPeerScore(ctx, req.(*GetPeerScoreRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _PubSubProxy_SetPeerScore_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(SetPeerScoreRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(PubSubProxyServer).SetPeerScore(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: PubSubProxy_SetPeerScore_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(PubSubProxyServer).SetPeerScore(ctx, req.(*SetPeerScoreRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _PubSubProxy_AddPeerScore_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(AddPeerScoreRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(PubSubProxyServer).AddPeerScore(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: PubSubProxy_AddPeerScore_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(PubSubProxyServer).AddPeerScore(ctx, req.(*AddPeerScoreRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _PubSubProxy_Reconnect_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ReconnectRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(PubSubProxyServer).Reconnect(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: PubSubProxy_Reconnect_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(PubSubProxyServer).Reconnect(ctx, req.(*ReconnectRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _PubSubProxy_Bootstrap_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(emptypb.Empty)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(PubSubProxyServer).Bootstrap(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: PubSubProxy_Bootstrap_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(PubSubProxyServer).Bootstrap(ctx, req.(*emptypb.Empty))
	}
	return interceptor(ctx, in, info, handler)
}

func _PubSubProxy_DiscoverPeers_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(emptypb.Empty)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(PubSubProxyServer).DiscoverPeers(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: PubSubProxy_DiscoverPeers_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(PubSubProxyServer).DiscoverPeers(ctx, req.(*emptypb.Empty))
	}
	return interceptor(ctx, in, info, handler)
}

func _PubSubProxy_IsPeerConnected_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(IsPeerConnectedRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(PubSubProxyServer).IsPeerConnected(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: PubSubProxy_IsPeerConnected_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(PubSubProxyServer).IsPeerConnected(ctx, req.(*IsPeerConnectedRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _PubSubProxy_GetNetwork_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(emptypb.Empty)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(PubSubProxyServer).GetNetwork(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: PubSubProxy_GetNetwork_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(PubSubProxyServer).GetNetwork(ctx, req.(*emptypb.Empty))
	}
	return interceptor(ctx, in, info, handler)
}

func _PubSubProxy_Reachability_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(emptypb.Empty)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(PubSubProxyServer).Reachability(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: PubSubProxy_Reachability_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(PubSubProxyServer).Reachability(ctx, req.(*emptypb.Empty))
	}
	return interceptor(ctx, in, info, handler)
}

func _PubSubProxy_SignMessage_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(SignMessageRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(PubSubProxyServer).SignMessage(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: PubSubProxy_SignMessage_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(PubSubProxyServer).SignMessage(ctx, req.(*SignMessageRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _PubSubProxy_GetPublicKey_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(emptypb.Empty)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(PubSubProxyServer).GetPublicKey(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: PubSubProxy_GetPublicKey_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(PubSubProxyServer).GetPublicKey(ctx, req.(*emptypb.Empty))
	}
	return interceptor(ctx, in, info, handler)
}

// PubSubProxy_ServiceDesc is the grpc.ServiceDesc for PubSubProxy service.
// It's only intended for direct use with grpc.RegisterService,
// and not to be introspected or modified (even as a copy)
var PubSubProxy_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "quilibrium.node.proxy.pb.PubSubProxy",
	HandlerType: (*PubSubProxyServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "PublishToBitmask",
			Handler:    _PubSubProxy_PublishToBitmask_Handler,
		},
		{
			MethodName: "Publish",
			Handler:    _PubSubProxy_Publish_Handler,
		},
		{
			MethodName: "Unsubscribe",
			Handler:    _PubSubProxy_Unsubscribe_Handler,
		},
		{
			MethodName: "GetPeerID",
			Handler:    _PubSubProxy_GetPeerID_Handler,
		},
		{
			MethodName: "GetPeerstoreCount",
			Handler:    _PubSubProxy_GetPeerstoreCount_Handler,
		},
		{
			MethodName: "GetNetworkPeersCount",
			Handler:    _PubSubProxy_GetNetworkPeersCount_Handler,
		},
		{
			MethodName: "GetRandomPeer",
			Handler:    _PubSubProxy_GetRandomPeer_Handler,
		},
		{
			MethodName: "GetMultiaddrOfPeer",
			Handler:    _PubSubProxy_GetMultiaddrOfPeer_Handler,
		},
		{
			MethodName: "GetOwnMultiaddrs",
			Handler:    _PubSubProxy_GetOwnMultiaddrs_Handler,
		},
		{
			MethodName: "GetNetworkInfo",
			Handler:    _PubSubProxy_GetNetworkInfo_Handler,
		},
		{
			MethodName: "GetPeerScore",
			Handler:    _PubSubProxy_GetPeerScore_Handler,
		},
		{
			MethodName: "SetPeerScore",
			Handler:    _PubSubProxy_SetPeerScore_Handler,
		},
		{
			MethodName: "AddPeerScore",
			Handler:    _PubSubProxy_AddPeerScore_Handler,
		},
		{
			MethodName: "Reconnect",
			Handler:    _PubSubProxy_Reconnect_Handler,
		},
		{
			MethodName: "Bootstrap",
			Handler:    _PubSubProxy_Bootstrap_Handler,
		},
		{
			MethodName: "DiscoverPeers",
			Handler:    _PubSubProxy_DiscoverPeers_Handler,
		},
		{
			MethodName: "IsPeerConnected",
			Handler:    _PubSubProxy_IsPeerConnected_Handler,
		},
		{
			MethodName: "GetNetwork",
			Handler:    _PubSubProxy_GetNetwork_Handler,
		},
		{
			MethodName: "Reachability",
			Handler:    _PubSubProxy_Reachability_Handler,
		},
		{
			MethodName: "SignMessage",
			Handler:    _PubSubProxy_SignMessage_Handler,
		},
		{
			MethodName: "GetPublicKey",
			Handler:    _PubSubProxy_GetPublicKey_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Subscribe",
			Handler:       _PubSubProxy_Subscribe_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "ValidatorStream",
			Handler:       _PubSubProxy_ValidatorStream_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
		{
			StreamName:    "GetMultiaddrOfPeerStream",
			Handler:       _PubSubProxy_GetMultiaddrOfPeerStream_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "proxy.proto",
}