core

Apr 13, 2022

Changes in this version

+ const DefaultDBFolder

+ const DefaultGenesisOffset

+ const PrivateRandLength

+ var DefaultResharingOffset = 30 * time.Second

+ var EciesHash = sha256.New

+ var MaxWaitPrepareDKG = 24 * 7 * 2 * time.Hour

+ func Proxy(s drand.PublicServer) client.Client

type Client

+ func (c *Client) ChainInfo(p net.Peer) (*chain.Info, error)

type Config

+ func (d *Config) BoltOptions() *bolt.Options

+ func (d *Config) PrivateListenAddress(defaultAddr string) string

+ func (d *Config) PublicListenAddress(defaultAddr string) string

+ func (d *Config) Version() string

type ConfigOption

+ func WithDBFolder(folder string) ConfigOption

+ func WithPrivateListenAddress(addr string) ConfigOption

+ func WithPrivateRandomness() ConfigOption

+ func WithPublicListenAddress(addr string) ConfigOption

+ func WithVersion(version string) ConfigOption

type Drand

+ func (d *Drand) BroadcastDKG(c context.Context, in *drand.DKGPacket) (*drand.Empty, error)

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

+ func (d *Drand) GetIdentity(ctx context.Context, req *drand.IdentityRequest) (*drand.Identity, error)

+ func (d *Drand) PartialBeacon(c context.Context, in *drand.PartialBeaconPacket) (*drand.Empty, error)

+ func (d *Drand) PeerMetrics(c context.Context) (map[string]http.Handler, error)

+ func (d *Drand) PublicRandStream(req *drand.PublicRandRequest, stream drand.Public_PublicRandStreamServer) error

+ func (d *Drand) PushDKGInfo(ctx context.Context, in *drand.DKGInfoPacket) (*drand.Empty, error)

+ func (d *Drand) SignalDKGParticipant(ctx context.Context, p *drand.SignalDKGPacket) (*drand.Empty, error)

+ func (d *Drand) StartFollowChain(req *drand.StartFollowRequest, stream drand.Control_StartFollowChainServer) error

+ func (d *Drand) SyncChain(req *drand.SyncRequest, stream drand.Protocol_SyncChainServer) error

Apr 8, 2022

Changes in this version

+ const DefaultDKGTimeout

+ var DefaultDialTimeout = 10 * time.Second

+ var RandomnessHash = sha256.New

type Client

+ func (c *Client) Group(addr string, secure bool) (*drand.GroupResponse, error)

type Config

+ func (d *Config) Logger() log.Logger

type ConfigOption

+ func WithDKGCallback(fn func(*key.Share)) ConfigOption

+ func WithLogLevel(level int) ConfigOption

type Drand

+ func (d *Drand) GroupFile(ctx context.Context, in *control.GroupTOMLRequest) (*control.GroupTOMLResponse, error)

+ func (d *Drand) PrivateRand(c context.Context, priv *drand.PrivateRandRequest) (*drand.PrivateRandResponse, error)

+ func (d *Drand) PublicRand(c context.Context, in *drand.PublicRandRequest) (*drand.PublicRandResponse, error)

+ func (d *Drand) Shutdown(ctx context.Context, in *control.ShutdownRequest) (*control.ShutdownResponse, error)

+ func (d *Drand) WaitExit() chan bool

Dec 29, 2018

Changes in this version

type Drand

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

Nov 1, 2018

Changes in this version

+ const DefaultControlPort

type Client

+ func (c *Client) Public(addr string, pub *key.DistPublic, secure bool, round int) (*drand.PublicRandResponse, error)

type Config

+ func (d *Config) ControlPort() string

type ConfigOption

+ func WithControlPort(port string) ConfigOption

type Drand

+ func (d *Drand) CollectiveKey(ctx context.Context, in *control.CokeyRequest) (*control.CokeyResponse, error)

+ func (d *Drand) Group(ctx context.Context, in *control.GroupRequest) (*control.GroupResponse, error)

+ func (d *Drand) InitDKG(c context.Context, in *control.DKGRequest) (*control.DKGResponse, error)

+ func (d *Drand) InitReshare(c context.Context, in *control.ReshareRequest) (*control.ReshareResponse, error)

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

+ func (d *Drand) PrivateKey(ctx context.Context, in *control.PrivateKeyRequest) (*control.PrivateKeyResponse, error)

+ func (d *Drand) PublicKey(ctx context.Context, in *control.PublicKeyRequest) (*control.PublicKeyResponse, error)

+ func (d *Drand) Reshare(c context.Context, in *dkg_proto.ResharePacket) (*dkg_proto.ReshareResponse, error)

+ func (d *Drand) Share(ctx context.Context, in *control.ShareRequest) (*control.ShareResponse, error)

+ func (d *Drand) StartBeacon() error

+ func (d *Drand) StopBeacon()

Aug 9, 2018

Changes in this version

+ const DefaultConfigFolderName

type Client

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

+ func NewGrpcClientFromCert(c *net.CertManager, opts ...grpc.DialOption) *Client

+ func NewRESTClient() *Client

+ func NewRESTClientFromCert(c *net.CertManager) *Client

+ func (c *Client) DistKey(addr string, secure bool) (kyber.Point, error)

type Config

+ func (d *Config) Certs() *net.CertManager

type ConfigOption

+ func WithCallOption(opts ...grpc.CallOption) ConfigOption

+ func WithInsecure() ConfigOption

+ func WithTLS(certPath, keyPath string) ConfigOption

+ func WithTrustedCerts(certPaths ...string) ConfigOption

type Drand

+ func (d *Drand) DistKey(context.Context, *drand.DistKeyRequest) (*drand.DistKeyResponse, error)

May 16, 2018

Changes in this version

+ const DefaultBeaconPeriod

+ const DefaultConfigFolder

+ const DefaultDbFolder

+ var DefaultHash = sha256.New

+ var DefaultSeed = []byte(...)

+ func Decrypt(g kyber.Group, fn func() hash.Hash, priv kyber.Scalar, o *drand.ECIESObject) ([]byte, error)

+ func Encrypt(g kyber.Group, fn func() hash.Hash, public kyber.Point, msg []byte) (*drand.ECIESObject, error)

+ type Client struct

+ func NewClient(opts ...grpc.DialOption) *Client

+ func (c *Client) LastPublic(addr string, pub *key.DistPublic) (*drand.PublicRandResponse, error)

+ func (c *Client) Private(id *key.Identity) ([]byte, error)

+ type Config struct

+ func NewConfig(opts ...ConfigOption) *Config

+ func (d *Config) ConfigFolder() string

+ func (d *Config) DBFolder() string

+ func (d *Config) ListenAddress(defaultAddr string) string

+ type ConfigOption func(*Config)

+ func WithBeaconCallback(fn func(*beacon.Beacon)) ConfigOption

+ func WithBeaconPeriod(period time.Duration) ConfigOption

+ func WithBoltOptions(opts *bolt.Options) ConfigOption

+ func WithConfigFolder(folder string) ConfigOption

+ func WithDbFolder(folder string) ConfigOption

+ func WithDkgTimeout(t time.Duration) ConfigOption

+ func WithGrpcOptions(opts ...grpc.DialOption) ConfigOption

+ func WithListenAddress(addr string) ConfigOption

+ type Drand struct

+ func LoadDrand(s key.Store, c *Config) (*Drand, error)

+ func NewDrand(s key.Store, g *key.Group, c *Config) (*Drand, error)

+ func (d *Drand) BeaconLoop()

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

+ func (d *Drand) Private(c context.Context, priv *drand.PrivateRandRequest) (*drand.PrivateRandResponse, error)

+ func (d *Drand) Public(context.Context, *drand.PublicRandRequest) (*drand.PublicRandResponse, error)

+ func (d *Drand) Setup(c context.Context, in *dkg_proto.DKGPacket) (*dkg_proto.DKGResponse, error)

+ func (d *Drand) StartDKG() error

+ func (d *Drand) Stop()

+ func (d *Drand) WaitDKG() error