node

Documentation

Index

• func RegisterRelayServer(s *grpc.Server, srv RelayServer)
• func Run()
• type DistributedHashTable
• type RelayClient
  • func NewRelayClient(cc grpc.ClientConnInterface) RelayClient
• type RelayServer
• type UnimplementedRelayServer
  • func (*UnimplementedRelayServer) ExchangeVersion(ctx context.Context, req *Version) (*Version, error)
• type Version
  • func (*Version) Descriptor() ([]byte, []int)
  • func (m *Version) GetAddressFrom() string
  • func (m *Version) GetBestHeight() uint64
  • func (m *Version) GetVersion() int32
  • func (*Version) ProtoMessage()
  • func (m *Version) Reset()
  • func (m *Version) String() string
  • func (m *Version) XXX_DiscardUnknown()
  • func (m *Version) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *Version) XXX_Merge(src proto.Message)
  • func (m *Version) XXX_Size() int
  • func (m *Version) XXX_Unmarshal(b []byte) error

Functions

func RegisterRelayServer

func RegisterRelayServer(s *grpc.Server, srv RelayServer)

func Run

func Run()

Types

type DistributedHashTable

type DistributedHashTable struct {
	*dht.IpfsDHT
	// contains filtered or unexported fields
}

type RelayClient

type RelayClient interface {
	ExchangeVersion(ctx context.Context, in *Version, opts ...grpc.CallOption) (*Version, error)
}

RelayClient is the client API for relay service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewRelayClient

func NewRelayClient(cc grpc.ClientConnInterface) RelayClient

type RelayServer

type RelayServer interface {
	ExchangeVersion(context.Context, *Version) (*Version, error)
}

RelayServer is the server API for relay service.

type UnimplementedRelayServer

type UnimplementedRelayServer struct {
}

UnimplementedRelayServer can be embedded to have forward compatible implementations.

func (*UnimplementedRelayServer) ExchangeVersion

func (*UnimplementedRelayServer) ExchangeVersion(ctx context.Context, req *Version) (*Version, error)

type Version

type Version struct {
	Version              int32    `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"`
	BestHeight           uint64   `protobuf:"varint,2,opt,name=bestHeight,proto3" json:"bestHeight,omitempty"`
	AddressFrom          string   `protobuf:"bytes,3,opt,name=addressFrom,proto3" json:"addressFrom,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Version) Descriptor

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

func (*Version) GetAddressFrom

func (m *Version) GetAddressFrom() string

func (*Version) GetBestHeight

func (m *Version) GetBestHeight() uint64

func (*Version) GetVersion

func (m *Version) GetVersion() int32

func (*Version) ProtoMessage

func (*Version) ProtoMessage()

func (*Version) Reset

func (m *Version) Reset()

func (*Version) String

func (m *Version) String() string

func (*Version) XXX_DiscardUnknown

func (m *Version) XXX_DiscardUnknown()

func (*Version) XXX_Marshal

func (m *Version) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Version) XXX_Merge

func (m *Version) XXX_Merge(src proto.Message)

func (*Version) XXX_Size

func (m *Version) XXX_Size() int

func (*Version) XXX_Unmarshal

func (m *Version) XXX_Unmarshal(b []byte) error