pb

Documentation

Index

• Variables
• func RegisterPeerServiceServer(s *grpc.Server, srv PeerServiceServer)
• type GetPeersListRequest
  • func (*GetPeersListRequest) Descriptor() ([]byte, []int)
  • func (x *GetPeersListRequest) GetIncludeAllSubnetworks() bool
  • func (x *GetPeersListRequest) GetServiceFlag() uint64
  • func (x *GetPeersListRequest) GetSubnetworkID() []byte
  • func (*GetPeersListRequest) ProtoMessage()
  • func (x *GetPeersListRequest) ProtoReflect() protoreflect.Message
  • func (x *GetPeersListRequest) Reset()
  • func (x *GetPeersListRequest) String() string
• type GetPeersListResponse
  • func (*GetPeersListResponse) Descriptor() ([]byte, []int)
  • func (x *GetPeersListResponse) GetAddresses() []*NetAddress
  • func (*GetPeersListResponse) ProtoMessage()
  • func (x *GetPeersListResponse) ProtoReflect() protoreflect.Message
  • func (x *GetPeersListResponse) Reset()
  • func (x *GetPeersListResponse) String() string
• type NetAddress
  • func (*NetAddress) Descriptor() ([]byte, []int)
  • func (x *NetAddress) GetIP() []byte
  • func (x *NetAddress) GetPort() uint32
  • func (x *NetAddress) GetServices() uint64
  • func (x *NetAddress) GetTimestamp() int64
  • func (*NetAddress) ProtoMessage()
  • func (x *NetAddress) ProtoReflect() protoreflect.Message
  • func (x *NetAddress) Reset()
  • func (x *NetAddress) String() string
• type PeerServiceClient
  • func NewPeerServiceClient(cc grpc.ClientConnInterface) PeerServiceClient
• type PeerServiceServer
• type UnimplementedPeerServiceServer
  • func (*UnimplementedPeerServiceServer) GetPeersList(context.Context, *GetPeersListRequest) (*GetPeersListResponse, error)

Variables

var File_peer_service_proto protoreflect.FileDescriptor

Functions

func RegisterPeerServiceServer

func RegisterPeerServiceServer(s *grpc.Server, srv PeerServiceServer)

Types

type GetPeersListRequest

type GetPeersListRequest struct {
	ServiceFlag           uint64 `protobuf:"varint,1,opt,name=serviceFlag,proto3" json:"serviceFlag,omitempty"`
	SubnetworkID          []byte `protobuf:"bytes,2,opt,name=subnetworkID,proto3" json:"subnetworkID,omitempty"`
	IncludeAllSubnetworks bool   `protobuf:"varint,3,opt,name=includeAllSubnetworks,proto3" json:"includeAllSubnetworks,omitempty"`
	// contains filtered or unexported fields
}

func (*GetPeersListRequest) Descriptor

func (*GetPeersListRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetPeersListRequest.ProtoReflect.Descriptor instead.

func (*GetPeersListRequest) GetIncludeAllSubnetworks

func (x *GetPeersListRequest) GetIncludeAllSubnetworks() bool

func (*GetPeersListRequest) GetServiceFlag

func (x *GetPeersListRequest) GetServiceFlag() uint64

func (*GetPeersListRequest) GetSubnetworkID

func (x *GetPeersListRequest) GetSubnetworkID() []byte

func (*GetPeersListRequest) ProtoMessage

func (*GetPeersListRequest) ProtoMessage()

func (*GetPeersListRequest) ProtoReflect

func (x *GetPeersListRequest) ProtoReflect() protoreflect.Message

func (*GetPeersListRequest) Reset

func (x *GetPeersListRequest) Reset()

func (*GetPeersListRequest) String

func (x *GetPeersListRequest) String() string

type GetPeersListResponse

type GetPeersListResponse struct {
	Addresses []*NetAddress `protobuf:"bytes,1,rep,name=addresses,proto3" json:"addresses,omitempty"`
	// contains filtered or unexported fields
}

func (*GetPeersListResponse) Descriptor

func (*GetPeersListResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetPeersListResponse.ProtoReflect.Descriptor instead.

func (*GetPeersListResponse) GetAddresses

func (x *GetPeersListResponse) GetAddresses() []*NetAddress

func (*GetPeersListResponse) ProtoMessage

func (*GetPeersListResponse) ProtoMessage()

func (*GetPeersListResponse) ProtoReflect

func (x *GetPeersListResponse) ProtoReflect() protoreflect.Message

func (*GetPeersListResponse) Reset

func (x *GetPeersListResponse) Reset()

func (*GetPeersListResponse) String

func (x *GetPeersListResponse) String() string

type NetAddress

type NetAddress struct {
	Timestamp int64  `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Services  uint64 `protobuf:"varint,2,opt,name=services,proto3" json:"services,omitempty"`
	IP        []byte `protobuf:"bytes,3,opt,name=IP,proto3" json:"IP,omitempty"`
	Port      uint32 `protobuf:"varint,4,opt,name=port,proto3" json:"port,omitempty"`
	// contains filtered or unexported fields
}

func (*NetAddress) Descriptor

func (*NetAddress) Descriptor() ([]byte, []int)

Deprecated: Use NetAddress.ProtoReflect.Descriptor instead.

func (*NetAddress) GetIP

func (x *NetAddress) GetIP() []byte

func (*NetAddress) GetPort

func (x *NetAddress) GetPort() uint32

func (*NetAddress) GetServices

func (x *NetAddress) GetServices() uint64

func (*NetAddress) GetTimestamp

func (x *NetAddress) GetTimestamp() int64

func (*NetAddress) ProtoMessage

func (*NetAddress) ProtoMessage()

func (*NetAddress) ProtoReflect

func (x *NetAddress) ProtoReflect() protoreflect.Message

func (*NetAddress) Reset

func (x *NetAddress) Reset()

func (*NetAddress) String

func (x *NetAddress) String() string

type PeerServiceClient

type PeerServiceClient interface {
	GetPeersList(ctx context.Context, in *GetPeersListRequest, opts ...grpc.CallOption) (*GetPeersListResponse, error)
}

PeerServiceClient is the client API for PeerService 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.

func NewPeerServiceClient

func NewPeerServiceClient(cc grpc.ClientConnInterface) PeerServiceClient

type PeerServiceServer

type PeerServiceServer interface {
	GetPeersList(context.Context, *GetPeersListRequest) (*GetPeersListResponse, error)
	// contains filtered or unexported methods
}

PeerServiceServer is the server API for PeerService service. All implementations must embed UnimplementedPeerServiceServer for forward compatibility

type UnimplementedPeerServiceServer

type UnimplementedPeerServiceServer struct {
}

UnimplementedPeerServiceServer must be embedded to have forward compatible implementations.

func (*UnimplementedPeerServiceServer) GetPeersList

func (*UnimplementedPeerServiceServer) GetPeersList(context.Context, *GetPeersListRequest) (*GetPeersListResponse, error)