net

Apr 13, 2022

Changes in this version

+ const MaxSyncBuffer

+ func RemoteAddress(c context.Context) string

type ControlClient

+ func (c *ControlClient) ChainInfo() (*control.ChainInfoPacket, error)

+ func (c *ControlClient) InitDKGLeader(nodes, threshold int, beaconPeriod, catchupPeriod, timeout time.Duration, ...) (*control.GroupPacket, error)

+ func (c *ControlClient) InitReshareLeader(nodes, threshold int, timeout, catchupPeriod time.Duration, ...) (*control.GroupPacket, error)

+ func (c *ControlClient) StartFollowChain(cc ctx.Context, hash string, nodes []string, tls bool, upTo uint64) (outCh chan *control.FollowProgress, errCh chan error, e error)

type DefaultControlServer

+ func (s *DefaultControlServer) ChainInfo(c ctx.Context, in *control.ChainInfoRequest) (*control.ChainInfoPacket, error)

+ type HTTPClient interface

+ HandleHTTP func(p Peer) (http.Handler, error)

type Listener

+ func NewGRPCListenerForPrivate(ctx context.Context, bindingAddr, certPath, keyPath string, s Service, ...) (Listener, error)

+ func NewRESTListenerForPublic(ctx context.Context, bindingAddr, certPath, keyPath string, ...) (Listener, error)

+ Addr func() string

type Peer

+ func CreatePeer(addr string, tls bool) Peer

+ type PrivateGateway struct

+ func NewGRPCPrivateGateway(ctx context.Context, listen, certPath, keyPath string, certs *CertManager, ...) (*PrivateGateway, error)

+ func (g *PrivateGateway) StartAll()

+ func (g *PrivateGateway) StopAll(ctx context.Context)

type ProtocolClient

+ BroadcastDKG func(c context.Context, p Peer, in *drand.DKGPacket, opts ...CallOption) error

+ GetIdentity func(ctx context.Context, p Peer, in *drand.IdentityRequest, opts ...CallOption) (*drand.Identity, error)

+ PartialBeacon func(ctx context.Context, p Peer, in *drand.PartialBeaconPacket, opts ...CallOption) error

+ PushDKGInfo func(ctx context.Context, p Peer, in *drand.DKGInfoPacket, opts ...grpc.CallOption) error

+ SignalDKGParticipant func(ctx context.Context, p Peer, in *drand.SignalDKGPacket, opts ...CallOption) error

+ SyncChain func(ctx context.Context, p Peer, in *drand.SyncRequest, opts ...CallOption) (chan *drand.BeaconPacket, error)

type PublicClient

+ ChainInfo func(ctx context.Context, p Peer, in *drand.ChainInfoRequest) (*drand.ChainInfoPacket, error)

+ PublicRandStream func(ctx context.Context, p Peer, in *drand.PublicRandRequest, opts ...CallOption) (chan *drand.PublicRandResponse, error)

+ type PublicGateway struct

+ func NewRESTPublicGateway(ctx context.Context, listen, certPath, keyPath string, certs *CertManager, ...) (*PublicGateway, error)

+ func (g *PublicGateway) StartAll()

+ func (g *PublicGateway) StopAll(ctx context.Context)

Apr 8, 2022

Changes in this version

type ControlClient

+ func (c ControlClient) GroupFile() (*control.GroupTOMLResponse, error)

+ func (c ControlClient) Shutdown() (*control.ShutdownResponse, error)

+ type EmptyServer struct

+ func (s *EmptyServer) CollectiveKey(context.Context, *drand.CokeyRequest) (*drand.CokeyResponse, error)

+ func (s *EmptyServer) DistKey(context.Context, *drand.DistKeyRequest) (*drand.DistKeyResponse, error)

+ func (s *EmptyServer) Group(context.Context, *drand.GroupRequest) (*drand.GroupResponse, error)

+ func (s *EmptyServer) GroupFile(context.Context, *drand.GroupTOMLRequest) (*drand.GroupTOMLResponse, error)

+ func (s *EmptyServer) Home(context.Context, *drand.HomeRequest) (*drand.HomeResponse, error)

+ func (s *EmptyServer) InitDKG(context.Context, *drand.InitDKGPacket) (*drand.Empty, error)

+ func (s *EmptyServer) InitReshare(context.Context, *drand.InitResharePacket) (*drand.Empty, error)

+ func (s *EmptyServer) NewBeacon(context.Context, *drand.BeaconRequest) (*drand.BeaconResponse, error)

+ func (s *EmptyServer) PingPong(context.Context, *drand.Ping) (*drand.Pong, error)

+ func (s *EmptyServer) PrivateKey(context.Context, *drand.PrivateKeyRequest) (*drand.PrivateKeyResponse, error)

+ func (s *EmptyServer) PrivateRand(context.Context, *drand.PrivateRandRequest) (*drand.PrivateRandResponse, error)

+ func (s *EmptyServer) PublicKey(context.Context, *drand.PublicKeyRequest) (*drand.PublicKeyResponse, error)

+ func (s *EmptyServer) PublicRand(context.Context, *drand.PublicRandRequest) (*drand.PublicRandResponse, error)

+ func (s *EmptyServer) Reshare(context.Context, *drand.ResharePacket) (*drand.Empty, error)

+ func (s *EmptyServer) Setup(context.Context, *drand.SetupPacket) (*drand.Empty, error)

+ func (s *EmptyServer) Share(context.Context, *drand.ShareRequest) (*drand.ShareResponse, error)

+ func (s *EmptyServer) Shutdown(context.Context, *drand.ShutdownRequest) (*drand.ShutdownResponse, error)

+ type ProtocolClient interface

+ NewBeacon func(p Peer, in *drand.BeaconRequest, opts ...CallOption) (*drand.BeaconResponse, error)

+ Reshare func(p Peer, in *drand.ResharePacket, opts ...CallOption) (*drand.Empty, error)

+ SetTimeout func(time.Duration)

+ Setup func(p Peer, in *drand.SetupPacket, opts ...CallOption) (*drand.Empty, error)

+ type PublicClient interface

+ DistKey func(p Peer, in *drand.DistKeyRequest) (*drand.DistKeyResponse, error)

+ Group func(p Peer, in *drand.GroupRequest) (*drand.GroupResponse, error)

+ Home func(p Peer, in *drand.HomeRequest) (*drand.HomeResponse, error)

+ PrivateRand func(p Peer, in *drand.PrivateRandRequest) (*drand.PrivateRandResponse, error)

+ PublicRand func(p Peer, in *drand.PublicRandRequest) (*drand.PublicRandResponse, error)

Dec 29, 2018

Changes in this version

type DefaultService

+ func (s *DefaultService) Home(c context.Context, in *drand.HomeRequest) (*drand.HomeResponse, error)

Nov 1, 2018

Changes in this version

+ type ControlClient struct

+ func NewControlClient(port string) (*ControlClient, error)

+ func (c *ControlClient) Group() (*control.GroupResponse, error)

+ func (c *ControlClient) InitDKG(groupPath string, leader bool) (*control.DKGResponse, error)

+ func (c *ControlClient) InitReshare(oldPath, newPath string, leader bool) (*control.ReshareResponse, error)

+ func (c *ControlClient) Ping() error

+ func (c ControlClient) CollectiveKey() (*control.CokeyResponse, error)

+ func (c ControlClient) PrivateKey() (*control.PrivateKeyResponse, error)

+ func (c ControlClient) PublicKey() (*control.PublicKeyResponse, error)

+ func (c ControlClient) Share() (*control.ShareResponse, error)

+ type ControlListener struct

+ func NewTCPGrpcControlListener(s control.ControlServer, port string) ControlListener

+ func (g *ControlListener) Start()

+ func (g *ControlListener) Stop()

+ type DefaultControlServer struct

+ C control.ControlServer

+ func (s *DefaultControlServer) CollectiveKey(c context.Context, in *control.CokeyRequest) (*control.CokeyResponse, error)

+ func (s *DefaultControlServer) Group(c context.Context, in *control.GroupRequest) (*control.GroupResponse, error)

+ func (s *DefaultControlServer) PingPong(c context.Context, in *control.Ping) (*control.Pong, error)

+ func (s *DefaultControlServer) PrivateKey(c context.Context, in *control.PrivateKeyRequest) (*control.PrivateKeyResponse, error)

+ func (s *DefaultControlServer) PublicKey(c context.Context, in *control.PublicKeyRequest) (*control.PublicKeyResponse, error)

+ func (s *DefaultControlServer) Share(c context.Context, in *control.ShareRequest) (*control.ShareResponse, error)

type DefaultService

+ func (s *DefaultService) Reshare(c context.Context, in *dkg.ResharePacket) (*dkg.ReshareResponse, error)

type Gateway

+ func (g Gateway) StartAll()

+ func (g Gateway) StopAll()

+ type HexJSON struct

+ func (*HexJSON) ContentType() string

+ func (j *HexJSON) Delimiter() []byte

+ func (j *HexJSON) Marshal(v interface{}) ([]byte, error)

+ func (j *HexJSON) NewDecoder(r io.Reader) runtime.Decoder

+ func (j *HexJSON) NewEncoder(w io.Writer) runtime.Encoder

+ func (j *HexJSON) Unmarshal(data []byte, v interface{}) error

type InternalClient

+ Reshare func(p Peer, in *dkg.ResharePacket, opts ...CallOption) (*dkg.ReshareResponse, error)

Aug 9, 2018

Changes in this version

+ func NewGrpcClientFromCertManager(c *CertManager, opts ...grpc.DialOption) *grpcClient

+ type CallOption = grpc.CallOption

+ type CertManager struct

+ func NewCertManager() *CertManager

+ func (p *CertManager) Add(certPath string) error

+ func (p *CertManager) Pool() *x509.CertPool

+ type DefaultService struct

+ B drand.BeaconServer

+ D dkg.DkgServer

+ I drand.InfoServer

+ R drand.RandomnessServer

+ func (s *DefaultService) DistKey(c context.Context, in *drand.DistKeyRequest) (*drand.DistKeyResponse, error)

+ func (s *DefaultService) NewBeacon(c context.Context, in *drand.BeaconRequest) (*drand.BeaconResponse, error)

+ func (s *DefaultService) Private(c context.Context, in *drand.PrivateRandRequest) (*drand.PrivateRandResponse, error)

+ func (s *DefaultService) Public(c context.Context, in *drand.PublicRandRequest) (*drand.PublicRandResponse, error)

+ func (s *DefaultService) Setup(c context.Context, in *dkg.DKGPacket) (*dkg.DKGResponse, error)

+ type ExternalClient interface

+ DistKey func(p Peer, in *drand.DistKeyRequest) (*drand.DistKeyResponse, error)

+ Private func(p Peer, in *drand.PrivateRandRequest) (*drand.PrivateRandResponse, error)

+ Public func(p Peer, in *drand.PublicRandRequest) (*drand.PublicRandResponse, error)

+ func NewRestClient() ExternalClient

+ func NewRestClientFromCertManager(c *CertManager) ExternalClient

type Gateway

+ func NewGrpcGatewayFromCertManager(listen string, certPath, keyPath string, certs *CertManager, s Service, ...) Gateway

+ func NewGrpcGatewayInsecure(listen string, s Service, opts ...grpc.DialOption) Gateway

+ type InternalClient interface

+ NewBeacon func(p Peer, in *drand.BeaconRequest, opts ...CallOption) (*drand.BeaconResponse, error)

+ Setup func(p Peer, in *dkg.DKGPacket, opts ...CallOption) (*dkg.DKGResponse, error)

type Listener

+ func NewTLSGrpcListener(bindingAddr string, certPath, keyPath string, s Service, ...) (Listener, error)

type Peer

+ IsTLS func() bool

May 24, 2018

Changes in this version

+ var DefaultTimeout = time.Duration(30) * time.Second

type Client

+ func NewGrpcClientWithTimeout(timeout time.Duration, opts ...grpc.DialOption) Client

May 16, 2018

Changes in this version

+ func IsTLS(addr string) bool

+ type Client interface

+ NewBeacon func(p Peer, in *drand.BeaconRequest) (*drand.BeaconResponse, error)

+ Private func(p Peer, in *drand.PrivateRandRequest) (*drand.PrivateRandResponse, error)

+ Public func(p Peer, in *drand.PublicRandRequest) (*drand.PublicRandResponse, error)

+ Setup func(p Peer, in *dkg.DKGPacket) (*dkg.DKGResponse, error)

+ func NewGrpcClient(opts ...grpc.DialOption) Client

+ type Gateway struct

+ func NewGrpcGateway(listen string, s Service, opts ...grpc.DialOption) Gateway

+ type Listener interface

+ Start func()

+ Stop func()

+ func NewGrpcListener(l net.Listener, s Service, opts ...grpc.ServerOption) Listener

+ func NewTCPGrpcListener(addr string, s Service) Listener

+ type Peer interface

+ Address func() string

+ type Service interface