net

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