drand

package
v2.0.6-testnet Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 10, 2024 License: Apache-2.0, MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	Public_PublicRand_FullMethodName       = "/drand.Public/PublicRand"
	Public_PublicRandStream_FullMethodName = "/drand.Public/PublicRandStream"
	Public_ChainInfo_FullMethodName        = "/drand.Public/ChainInfo"
	Public_ListBeaconIDs_FullMethodName    = "/drand.Public/ListBeaconIDs"
)
View Source 
const (
	Control_PingPong_FullMethodName         = "/drand.Control/PingPong"
	Control_Status_FullMethodName           = "/drand.Control/Status"
	Control_ListSchemes_FullMethodName      = "/drand.Control/ListSchemes"
	Control_PublicKey_FullMethodName        = "/drand.Control/PublicKey"
	Control_ChainInfo_FullMethodName        = "/drand.Control/ChainInfo"
	Control_GroupFile_FullMethodName        = "/drand.Control/GroupFile"
	Control_Shutdown_FullMethodName         = "/drand.Control/Shutdown"
	Control_LoadBeacon_FullMethodName       = "/drand.Control/LoadBeacon"
	Control_StartFollowChain_FullMethodName = "/drand.Control/StartFollowChain"
	Control_StartCheckChain_FullMethodName  = "/drand.Control/StartCheckChain"
	Control_BackupDatabase_FullMethodName   = "/drand.Control/BackupDatabase"
	Control_RemoteStatus_FullMethodName     = "/drand.Control/RemoteStatus"
)
View Source 
const (
	Protocol_GetIdentity_FullMethodName   = "/drand.Protocol/GetIdentity"
	Protocol_PartialBeacon_FullMethodName = "/drand.Protocol/PartialBeacon"
	Protocol_SyncChain_FullMethodName     = "/drand.Protocol/SyncChain"
	Protocol_Status_FullMethodName        = "/drand.Protocol/Status"
)
View Source 
const (
	Metrics_Metrics_FullMethodName = "/drand.Metrics/Metrics"
)

Variables

View Source 
var Control_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "drand.Control",
	HandlerType: (*ControlServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "PingPong",
			Handler:    _Control_PingPong_Handler,
		},
		{
			MethodName: "Status",
			Handler:    _Control_Status_Handler,
		},
		{
			MethodName: "ListSchemes",
			Handler:    _Control_ListSchemes_Handler,
		},
		{
			MethodName: "PublicKey",
			Handler:    _Control_PublicKey_Handler,
		},
		{
			MethodName: "ChainInfo",
			Handler:    _Control_ChainInfo_Handler,
		},
		{
			MethodName: "GroupFile",
			Handler:    _Control_GroupFile_Handler,
		},
		{
			MethodName: "Shutdown",
			Handler:    _Control_Shutdown_Handler,
		},
		{
			MethodName: "LoadBeacon",
			Handler:    _Control_LoadBeacon_Handler,
		},
		{
			MethodName: "BackupDatabase",
			Handler:    _Control_BackupDatabase_Handler,
		},
		{
			MethodName: "RemoteStatus",
			Handler:    _Control_RemoteStatus_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "StartFollowChain",
			Handler:       _Control_StartFollowChain_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "StartCheckChain",
			Handler:       _Control_StartCheckChain_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "drand/control.proto",
}

Control_ServiceDesc is the grpc.ServiceDesc for Control service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_drand_api_proto protoreflect.FileDescriptor
View Source 
var File_drand_common_proto protoreflect.FileDescriptor
View Source 
var File_drand_control_proto protoreflect.FileDescriptor
View Source 
var File_drand_metrics_proto protoreflect.FileDescriptor
View Source 
var File_drand_protocol_proto protoreflect.FileDescriptor
View Source 
var Metrics_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "drand.Metrics",
	HandlerType: (*MetricsServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Metrics",
			Handler:    _Metrics_Metrics_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "drand/metrics.proto",
}

Metrics_ServiceDesc is the grpc.ServiceDesc for Metrics service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var Protocol_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "drand.Protocol",
	HandlerType: (*ProtocolServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetIdentity",
			Handler:    _Protocol_GetIdentity_Handler,
		},
		{
			MethodName: "PartialBeacon",
			Handler:    _Protocol_PartialBeacon_Handler,
		},
		{
			MethodName: "Status",
			Handler:    _Protocol_Status_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "SyncChain",
			Handler:       _Protocol_SyncChain_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "drand/protocol.proto",
}

Protocol_ServiceDesc is the grpc.ServiceDesc for Protocol service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var Public_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "drand.Public",
	HandlerType: (*PublicServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "PublicRand",
			Handler:    _Public_PublicRand_Handler,
		},
		{
			MethodName: "ChainInfo",
			Handler:    _Public_ChainInfo_Handler,
		},
		{
			MethodName: "ListBeaconIDs",
			Handler:    _Public_ListBeaconIDs_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "PublicRandStream",
			Handler:       _Public_PublicRandStream_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "drand/api.proto",
}

Public_ServiceDesc is the grpc.ServiceDesc for Public service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterControlServer 

func RegisterControlServer(s grpc.ServiceRegistrar, srv ControlServer)

func RegisterMetricsServer 

func RegisterMetricsServer(s grpc.ServiceRegistrar, srv MetricsServer)

func RegisterProtocolServer 

func RegisterProtocolServer(s grpc.ServiceRegistrar, srv ProtocolServer)

func RegisterPublicServer 

func RegisterPublicServer(s grpc.ServiceRegistrar, srv PublicServer)

Types

type Address 

type Address struct {
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	// Deprecated: Marked as deprecated in drand/common.proto.
	Tls bool `protobuf:"varint,2,opt,name=tls,proto3" json:"tls,omitempty"`
	// contains filtered or unexported fields
}

func (*Address) Descriptor deprecated 

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

Deprecated: Use Address.ProtoReflect.Descriptor instead.

func (*Address) GetAddress 

func (x *Address) GetAddress() string

func (*Address) GetTls deprecated 

func (x *Address) GetTls() bool

Deprecated: Marked as deprecated in drand/common.proto.

func (*Address) ProtoMessage 

func (*Address) ProtoMessage()

func (*Address) ProtoReflect 

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

func (*Address) Reset 

func (x *Address) Reset()

func (*Address) String 

func (x *Address) String() string

type BackupDBRequest 

type BackupDBRequest struct {
	OutputFile string    `protobuf:"bytes,1,opt,name=output_file,json=outputFile,proto3" json:"output_file,omitempty"`
	Metadata   *Metadata `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

func (*BackupDBRequest) Descriptor deprecated 

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

Deprecated: Use BackupDBRequest.ProtoReflect.Descriptor instead.

func (*BackupDBRequest) GetMetadata 

func (x *BackupDBRequest) GetMetadata() *Metadata

func (*BackupDBRequest) GetOutputFile 

func (x *BackupDBRequest) GetOutputFile() string

func (*BackupDBRequest) ProtoMessage 

func (*BackupDBRequest) ProtoMessage()

func (*BackupDBRequest) ProtoReflect 

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

func (*BackupDBRequest) Reset 

func (x *BackupDBRequest) Reset()

func (*BackupDBRequest) String 

func (x *BackupDBRequest) String() string

type BackupDBResponse 

type BackupDBResponse struct {
	Metadata *Metadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

func (*BackupDBResponse) Descriptor deprecated 

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

Deprecated: Use BackupDBResponse.ProtoReflect.Descriptor instead.

func (*BackupDBResponse) GetMetadata 

func (x *BackupDBResponse) GetMetadata() *Metadata

func (*BackupDBResponse) ProtoMessage 

func (*BackupDBResponse) ProtoMessage()

func (*BackupDBResponse) ProtoReflect 

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

func (*BackupDBResponse) Reset 

func (x *BackupDBResponse) Reset()

func (*BackupDBResponse) String 

func (x *BackupDBResponse) String() string

type BeaconPacket 

type BeaconPacket struct {
	PreviousSignature []byte    `protobuf:"bytes,1,opt,name=previous_signature,json=previousSignature,proto3" json:"previous_signature,omitempty"`
	Round             uint64    `protobuf:"varint,2,opt,name=round,proto3" json:"round,omitempty"`
	Signature         []byte    `protobuf:"bytes,3,opt,name=signature,proto3" json:"signature,omitempty"`
	Metadata          *Metadata `protobuf:"bytes,4,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

func (*BeaconPacket) Descriptor deprecated 

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

Deprecated: Use BeaconPacket.ProtoReflect.Descriptor instead.

func (*BeaconPacket) GetMetadata 

func (x *BeaconPacket) GetMetadata() *Metadata

func (*BeaconPacket) GetPreviousSignature 

func (x *BeaconPacket) GetPreviousSignature() []byte

func (*BeaconPacket) GetRound 

func (x *BeaconPacket) GetRound() uint64

func (*BeaconPacket) GetSignature 

func (x *BeaconPacket) GetSignature() []byte

func (*BeaconPacket) ProtoMessage 

func (*BeaconPacket) ProtoMessage()

func (*BeaconPacket) ProtoReflect 

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

func (*BeaconPacket) Reset 

func (x *BeaconPacket) Reset()

func (*BeaconPacket) String 

func (x *BeaconPacket) String() string

type BeaconStatus 

type BeaconStatus struct {
	Status    uint32 `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"`
	IsRunning bool   `protobuf:"varint,2,opt,name=is_running,json=isRunning,proto3" json:"is_running,omitempty"`
	IsStopped bool   `protobuf:"varint,3,opt,name=is_stopped,json=isStopped,proto3" json:"is_stopped,omitempty"`
	IsStarted bool   `protobuf:"varint,4,opt,name=is_started,json=isStarted,proto3" json:"is_started,omitempty"`
	IsServing bool   `protobuf:"varint,5,opt,name=is_serving,json=isServing,proto3" json:"is_serving,omitempty"`
	// contains filtered or unexported fields
}

func (*BeaconStatus) Descriptor deprecated 

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

Deprecated: Use BeaconStatus.ProtoReflect.Descriptor instead.

func (*BeaconStatus) GetIsRunning 

func (x *BeaconStatus) GetIsRunning() bool

func (*BeaconStatus) GetIsServing 

func (x *BeaconStatus) GetIsServing() bool

func (*BeaconStatus) GetIsStarted 

func (x *BeaconStatus) GetIsStarted() bool

func (*BeaconStatus) GetIsStopped 

func (x *BeaconStatus) GetIsStopped() bool

func (*BeaconStatus) GetStatus 

func (x *BeaconStatus) GetStatus() uint32

func (*BeaconStatus) ProtoMessage 

func (*BeaconStatus) ProtoMessage()

func (*BeaconStatus) ProtoReflect 

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

func (*BeaconStatus) Reset 

func (x *BeaconStatus) Reset()

func (*BeaconStatus) String 

func (x *BeaconStatus) String() string

type ChainInfoPacket 

type ChainInfoPacket struct {

	// marshalled public key
	PublicKey []byte `protobuf:"bytes,1,opt,name=public_key,json=publicKey,proto3" json:"public_key,omitempty"`
	// period in seconds
	Period uint32 `protobuf:"varint,2,opt,name=period,proto3" json:"period,omitempty"`
	// genesis time of the chain
	GenesisTime int64 `protobuf:"varint,3,opt,name=genesis_time,json=genesisTime,proto3" json:"genesis_time,omitempty"`
	// hash is included for ease of use - not needing to have a drand client to
	// compute its hash
	Hash []byte `protobuf:"bytes,4,opt,name=hash,proto3" json:"hash,omitempty"`
	// hash of the genesis group
	GroupHash []byte `protobuf:"bytes,5,opt,name=groupHash,proto3" json:"groupHash,omitempty"`
	// indicates a set of values the process will use to act in specific ways
	SchemeID string    `protobuf:"bytes,6,opt,name=schemeID,proto3" json:"schemeID,omitempty"`
	Metadata *Metadata `protobuf:"bytes,7,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

func (*ChainInfoPacket) Descriptor deprecated 

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

Deprecated: Use ChainInfoPacket.ProtoReflect.Descriptor instead.

func (*ChainInfoPacket) GetGenesisTime 

func (x *ChainInfoPacket) GetGenesisTime() int64

func (*ChainInfoPacket) GetGroupHash 

func (x *ChainInfoPacket) GetGroupHash() []byte

func (*ChainInfoPacket) GetHash 

func (x *ChainInfoPacket) GetHash() []byte

func (*ChainInfoPacket) GetMetadata 

func (x *ChainInfoPacket) GetMetadata() *Metadata

func (*ChainInfoPacket) GetPeriod 

func (x *ChainInfoPacket) GetPeriod() uint32

func (*ChainInfoPacket) GetPublicKey 

func (x *ChainInfoPacket) GetPublicKey() []byte

func (*ChainInfoPacket) GetSchemeID 

func (x *ChainInfoPacket) GetSchemeID() string

func (*ChainInfoPacket) ProtoMessage 

func (*ChainInfoPacket) ProtoMessage()

func (*ChainInfoPacket) ProtoReflect 

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

func (*ChainInfoPacket) Reset 

func (x *ChainInfoPacket) Reset()

func (*ChainInfoPacket) String 

func (x *ChainInfoPacket) String() string

type ChainInfoRequest 

type ChainInfoRequest struct {
	Metadata *Metadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

func (*ChainInfoRequest) Descriptor deprecated 

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

Deprecated: Use ChainInfoRequest.ProtoReflect.Descriptor instead.

func (*ChainInfoRequest) GetMetadata 

func (x *ChainInfoRequest) GetMetadata() *Metadata

func (*ChainInfoRequest) ProtoMessage 

func (*ChainInfoRequest) ProtoMessage()

func (*ChainInfoRequest) ProtoReflect 

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

func (*ChainInfoRequest) Reset 

func (x *ChainInfoRequest) Reset()

func (*ChainInfoRequest) String 

func (x *ChainInfoRequest) String() string

type ChainStoreStatus 

type ChainStoreStatus struct {
	IsEmpty      bool   `protobuf:"varint,1,opt,name=is_empty,json=isEmpty,proto3" json:"is_empty,omitempty"`
	LastStored   uint64 `protobuf:"varint,2,opt,name=last_stored,json=lastStored,proto3" json:"last_stored,omitempty"`
	ExpectedLast uint64 `protobuf:"varint,3,opt,name=expected_last,json=expectedLast,proto3" json:"expected_last,omitempty"`
	// contains filtered or unexported fields
}

func (*ChainStoreStatus) Descriptor deprecated 

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

Deprecated: Use ChainStoreStatus.ProtoReflect.Descriptor instead.

func (*ChainStoreStatus) GetExpectedLast 

func (x *ChainStoreStatus) GetExpectedLast() uint64

func (*ChainStoreStatus) GetIsEmpty 

func (x *ChainStoreStatus) GetIsEmpty() bool

func (*ChainStoreStatus) GetLastStored 

func (x *ChainStoreStatus) GetLastStored() uint64

func (*ChainStoreStatus) ProtoMessage 

func (*ChainStoreStatus) ProtoMessage()

func (*ChainStoreStatus) ProtoReflect 

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

func (*ChainStoreStatus) Reset 

func (x *ChainStoreStatus) Reset()

func (*ChainStoreStatus) String 

func (x *ChainStoreStatus) String() string

type ControlClient 

type ControlClient interface {
	// PingPong returns an empty message. Purpose is to test the control port.
	PingPong(ctx context.Context, in *Ping, opts ...grpc.CallOption) (*Pong, error)
	// Status responds with the actual status of drand process
	Status(ctx context.Context, in *StatusRequest, opts ...grpc.CallOption) (*StatusResponse, error)
	// ListSchemes responds with the list of ids for the available schemes
	ListSchemes(ctx context.Context, in *ListSchemesRequest, opts ...grpc.CallOption) (*ListSchemesResponse, error)
	// PublicKey returns the longterm public key of the drand node
	PublicKey(ctx context.Context, in *PublicKeyRequest, opts ...grpc.CallOption) (*PublicKeyResponse, error)
	// ChainInfo returns the chain info for the chain hash or beacon id requested in the metadata
	ChainInfo(ctx context.Context, in *ChainInfoRequest, opts ...grpc.CallOption) (*ChainInfoPacket, error)
	// GroupFile returns the TOML-encoded group file, containing the group public key and coefficients
	GroupFile(ctx context.Context, in *GroupRequest, opts ...grpc.CallOption) (*GroupPacket, error)
	Shutdown(ctx context.Context, in *ShutdownRequest, opts ...grpc.CallOption) (*ShutdownResponse, error)
	LoadBeacon(ctx context.Context, in *LoadBeaconRequest, opts ...grpc.CallOption) (*LoadBeaconResponse, error)
	StartFollowChain(ctx context.Context, in *StartSyncRequest, opts ...grpc.CallOption) (Control_StartFollowChainClient, error)
	StartCheckChain(ctx context.Context, in *StartSyncRequest, opts ...grpc.CallOption) (Control_StartCheckChainClient, error)
	BackupDatabase(ctx context.Context, in *BackupDBRequest, opts ...grpc.CallOption) (*BackupDBResponse, error)
	// RemoteStatus request the status of some remote drand nodes
	RemoteStatus(ctx context.Context, in *RemoteStatusRequest, opts ...grpc.CallOption) (*RemoteStatusResponse, error)
}

ControlClient is the client API for Control 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 NewControlClient 

func NewControlClient(cc grpc.ClientConnInterface) ControlClient

type ControlServer 

type ControlServer interface {
	// PingPong returns an empty message. Purpose is to test the control port.
	PingPong(context.Context, *Ping) (*Pong, error)
	// Status responds with the actual status of drand process
	Status(context.Context, *StatusRequest) (*StatusResponse, error)
	// ListSchemes responds with the list of ids for the available schemes
	ListSchemes(context.Context, *ListSchemesRequest) (*ListSchemesResponse, error)
	// PublicKey returns the longterm public key of the drand node
	PublicKey(context.Context, *PublicKeyRequest) (*PublicKeyResponse, error)
	// ChainInfo returns the chain info for the chain hash or beacon id requested in the metadata
	ChainInfo(context.Context, *ChainInfoRequest) (*ChainInfoPacket, error)
	// GroupFile returns the TOML-encoded group file, containing the group public key and coefficients
	GroupFile(context.Context, *GroupRequest) (*GroupPacket, error)
	Shutdown(context.Context, *ShutdownRequest) (*ShutdownResponse, error)
	LoadBeacon(context.Context, *LoadBeaconRequest) (*LoadBeaconResponse, error)
	StartFollowChain(*StartSyncRequest, Control_StartFollowChainServer) error
	StartCheckChain(*StartSyncRequest, Control_StartCheckChainServer) error
	BackupDatabase(context.Context, *BackupDBRequest) (*BackupDBResponse, error)
	// RemoteStatus request the status of some remote drand nodes
	RemoteStatus(context.Context, *RemoteStatusRequest) (*RemoteStatusResponse, error)
}

ControlServer is the server API for Control service. All implementations should embed UnimplementedControlServer for forward compatibility

type Control_StartCheckChainClient 

type Control_StartCheckChainClient interface {
	Recv() (*SyncProgress, error)
	grpc.ClientStream
}

type Control_StartCheckChainServer 

type Control_StartCheckChainServer interface {
	Send(*SyncProgress) error
	grpc.ServerStream
}

type Control_StartFollowChainClient 

type Control_StartFollowChainClient interface {
	Recv() (*SyncProgress, error)
	grpc.ClientStream
}

type Control_StartFollowChainServer 

type Control_StartFollowChainServer interface {
	Send(*SyncProgress) error
	grpc.ServerStream
}

type DkgStatus 

type DkgStatus struct {
	Status uint32 `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*DkgStatus) Descriptor deprecated 

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

Deprecated: Use DkgStatus.ProtoReflect.Descriptor instead.

func (*DkgStatus) GetStatus 

func (x *DkgStatus) GetStatus() uint32

func (*DkgStatus) ProtoMessage 

func (*DkgStatus) ProtoMessage()

func (*DkgStatus) ProtoReflect 

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

func (*DkgStatus) Reset 

func (x *DkgStatus) Reset()

func (*DkgStatus) String 

func (x *DkgStatus) String() string

type Empty 

type Empty struct {
	Metadata *Metadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

func (*Empty) Descriptor deprecated 

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

Deprecated: Use Empty.ProtoReflect.Descriptor instead.

func (*Empty) GetMetadata 

func (x *Empty) GetMetadata() *Metadata

func (*Empty) ProtoMessage 

func (*Empty) ProtoMessage()

func (*Empty) ProtoReflect 

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

func (*Empty) Reset 

func (x *Empty) Reset()

func (*Empty) String 

func (x *Empty) String() string

type EntropyInfo 

type EntropyInfo struct {

	// the path to the script to run that returns random bytes when called
	Script string `protobuf:"bytes,1,opt,name=script,proto3" json:"script,omitempty"`
	// do we only take this entropy source or mix it with /dev/urandom
	UserOnly bool      `protobuf:"varint,10,opt,name=userOnly,proto3" json:"userOnly,omitempty"`
	Metadata *Metadata `protobuf:"bytes,11,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

EntropyInfo contains information about external entropy sources can be optional

func (*EntropyInfo) Descriptor deprecated 

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

Deprecated: Use EntropyInfo.ProtoReflect.Descriptor instead.

func (*EntropyInfo) GetMetadata 

func (x *EntropyInfo) GetMetadata() *Metadata

func (*EntropyInfo) GetScript 

func (x *EntropyInfo) GetScript() string

func (*EntropyInfo) GetUserOnly 

func (x *EntropyInfo) GetUserOnly() bool

func (*EntropyInfo) ProtoMessage 

func (*EntropyInfo) ProtoMessage()

func (*EntropyInfo) ProtoReflect 

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

func (*EntropyInfo) Reset 

func (x *EntropyInfo) Reset()

func (*EntropyInfo) String 

func (x *EntropyInfo) String() string

type GroupPacket 

type GroupPacket struct {
	Nodes     []*Node `protobuf:"bytes,1,rep,name=nodes,proto3" json:"nodes,omitempty"`
	Threshold uint32  `protobuf:"varint,2,opt,name=threshold,proto3" json:"threshold,omitempty"`
	// period in seconds
	Period         uint32   `protobuf:"varint,3,opt,name=period,proto3" json:"period,omitempty"`
	GenesisTime    uint64   `protobuf:"varint,4,opt,name=genesis_time,json=genesisTime,proto3" json:"genesis_time,omitempty"`
	TransitionTime uint64   `protobuf:"varint,5,opt,name=transition_time,json=transitionTime,proto3" json:"transition_time,omitempty"`
	GenesisSeed    []byte   `protobuf:"bytes,6,opt,name=genesis_seed,json=genesisSeed,proto3" json:"genesis_seed,omitempty"`
	DistKey        [][]byte `protobuf:"bytes,7,rep,name=dist_key,json=distKey,proto3" json:"dist_key,omitempty"`
	// catchup_period in seconds
	CatchupPeriod uint32    `protobuf:"varint,8,opt,name=catchup_period,json=catchupPeriod,proto3" json:"catchup_period,omitempty"`
	SchemeID      string    `protobuf:"bytes,9,opt,name=schemeID,proto3" json:"schemeID,omitempty"`
	Metadata      *Metadata `protobuf:"bytes,10,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

GroupPacket represents a group that is running a drand network (or is in the process of creating one or performing a resharing).

func (*GroupPacket) Descriptor deprecated 

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

Deprecated: Use GroupPacket.ProtoReflect.Descriptor instead.

func (*GroupPacket) GetCatchupPeriod 

func (x *GroupPacket) GetCatchupPeriod() uint32

func (*GroupPacket) GetDistKey 

func (x *GroupPacket) GetDistKey() [][]byte

func (*GroupPacket) GetGenesisSeed 

func (x *GroupPacket) GetGenesisSeed() []byte

func (*GroupPacket) GetGenesisTime 

func (x *GroupPacket) GetGenesisTime() uint64

func (*GroupPacket) GetMetadata 

func (x *GroupPacket) GetMetadata() *Metadata

func (*GroupPacket) GetNodes 

func (x *GroupPacket) GetNodes() []*Node

func (*GroupPacket) GetPeriod 

func (x *GroupPacket) GetPeriod() uint32

func (*GroupPacket) GetSchemeID 

func (x *GroupPacket) GetSchemeID() string

func (*GroupPacket) GetThreshold 

func (x *GroupPacket) GetThreshold() uint32

func (*GroupPacket) GetTransitionTime 

func (x *GroupPacket) GetTransitionTime() uint64

func (*GroupPacket) ProtoMessage 

func (*GroupPacket) ProtoMessage()

func (*GroupPacket) ProtoReflect 

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

func (*GroupPacket) Reset 

func (x *GroupPacket) Reset()

func (*GroupPacket) String 

func (x *GroupPacket) String() string

type GroupRequest 

type GroupRequest struct {
	Metadata *Metadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

func (*GroupRequest) Descriptor deprecated 

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

Deprecated: Use GroupRequest.ProtoReflect.Descriptor instead.

func (*GroupRequest) GetMetadata 

func (x *GroupRequest) GetMetadata() *Metadata

func (*GroupRequest) ProtoMessage 

func (*GroupRequest) ProtoMessage()

func (*GroupRequest) ProtoReflect 

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

func (*GroupRequest) Reset 

func (x *GroupRequest) Reset()

func (*GroupRequest) String 

func (x *GroupRequest) String() string

type Identity 

type Identity struct {
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	Key     []byte `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	// Deprecated: Marked as deprecated in drand/common.proto.
	Tls bool `protobuf:"varint,3,opt,name=tls,proto3" json:"tls,omitempty"`
	// BLS signature over the identity to prove possession of the private key, it also verify the scheme used
	Signature []byte `protobuf:"bytes,4,opt,name=signature,proto3" json:"signature,omitempty"`
	// contains filtered or unexported fields
}

REMINDER: This fields should be kept in sync with IdentityResponse message, except for the beaconID and schemeID

func (*Identity) Descriptor deprecated 

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

Deprecated: Use Identity.ProtoReflect.Descriptor instead.

func (*Identity) GetAddress 

func (x *Identity) GetAddress() string

func (*Identity) GetKey 

func (x *Identity) GetKey() []byte

func (*Identity) GetSignature 

func (x *Identity) GetSignature() []byte

func (*Identity) GetTls deprecated 

func (x *Identity) GetTls() bool

Deprecated: Marked as deprecated in drand/common.proto.

func (*Identity) ProtoMessage 

func (*Identity) ProtoMessage()

func (*Identity) ProtoReflect 

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

func (*Identity) Reset 

func (x *Identity) Reset()

func (*Identity) String 

func (x *Identity) String() string

type IdentityRequest 

type IdentityRequest struct {
	Metadata *Metadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

func (*IdentityRequest) Descriptor deprecated 

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

Deprecated: Use IdentityRequest.ProtoReflect.Descriptor instead.

func (*IdentityRequest) GetMetadata 

func (x *IdentityRequest) GetMetadata() *Metadata

func (*IdentityRequest) ProtoMessage 

func (*IdentityRequest) ProtoMessage()

func (*IdentityRequest) ProtoReflect 

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

func (*IdentityRequest) Reset 

func (x *IdentityRequest) Reset()

func (*IdentityRequest) String 

func (x *IdentityRequest) String() string

type IdentityResponse 

type IdentityResponse struct {
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	Key     []byte `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	// Deprecated: Marked as deprecated in drand/protocol.proto.
	Tls bool `protobuf:"varint,3,opt,name=tls,proto3" json:"tls,omitempty"`
	// BLS signature over the identity to prove possession of the private key
	Signature []byte `protobuf:"bytes,4,opt,name=signature,proto3" json:"signature,omitempty"`
	// --------------
	Metadata *Metadata `protobuf:"bytes,5,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// We need to specify the scheme name to make sure the key is getting probably decoded on the client side
	SchemeName string `protobuf:"bytes,6,opt,name=schemeName,proto3" json:"schemeName,omitempty"`
	// contains filtered or unexported fields
}

func (*IdentityResponse) Descriptor deprecated 

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

Deprecated: Use IdentityResponse.ProtoReflect.Descriptor instead.

func (*IdentityResponse) GetAddress 

func (x *IdentityResponse) GetAddress() string

func (*IdentityResponse) GetKey 

func (x *IdentityResponse) GetKey() []byte

func (*IdentityResponse) GetMetadata 

func (x *IdentityResponse) GetMetadata() *Metadata

func (*IdentityResponse) GetSchemeName 

func (x *IdentityResponse) GetSchemeName() string

func (*IdentityResponse) GetSignature 

func (x *IdentityResponse) GetSignature() []byte

func (*IdentityResponse) GetTls deprecated 

func (x *IdentityResponse) GetTls() bool

Deprecated: Marked as deprecated in drand/protocol.proto.

func (*IdentityResponse) ProtoMessage 

func (*IdentityResponse) ProtoMessage()

func (*IdentityResponse) ProtoReflect 

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

func (*IdentityResponse) Reset 

func (x *IdentityResponse) Reset()

func (*IdentityResponse) String 

func (x *IdentityResponse) String() string

type Interceptors 

type Interceptors interface {
	NodeVersionValidator(ctx context.Context, req interface{},
		info *grpc.UnaryServerInfo, handler grpc.UnaryHandler) (response interface{}, err error)
	NodeVersionStreamValidator(srv interface{}, ss grpc.ServerStream,
		info *grpc.StreamServerInfo, handler grpc.StreamHandler) error
}

type ListBeaconIDsRequest 

type ListBeaconIDsRequest struct {
	// contains filtered or unexported fields
}

func (*ListBeaconIDsRequest) Descriptor deprecated 

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

Deprecated: Use ListBeaconIDsRequest.ProtoReflect.Descriptor instead.

func (*ListBeaconIDsRequest) ProtoMessage 

func (*ListBeaconIDsRequest) ProtoMessage()

func (*ListBeaconIDsRequest) ProtoReflect 

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

func (*ListBeaconIDsRequest) Reset 

func (x *ListBeaconIDsRequest) Reset()

func (*ListBeaconIDsRequest) String 

func (x *ListBeaconIDsRequest) String() string

type ListBeaconIDsResponse 

type ListBeaconIDsResponse struct {
	Ids       []string    `protobuf:"bytes,1,rep,name=ids,proto3" json:"ids,omitempty"`
	Metadatas []*Metadata `protobuf:"bytes,2,rep,name=metadatas,proto3" json:"metadatas,omitempty"`
	// contains filtered or unexported fields
}

func (*ListBeaconIDsResponse) Descriptor deprecated 

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

Deprecated: Use ListBeaconIDsResponse.ProtoReflect.Descriptor instead.

func (*ListBeaconIDsResponse) GetIds 

func (x *ListBeaconIDsResponse) GetIds() []string

func (*ListBeaconIDsResponse) GetMetadatas 

func (x *ListBeaconIDsResponse) GetMetadatas() []*Metadata

func (*ListBeaconIDsResponse) ProtoMessage 

func (*ListBeaconIDsResponse) ProtoMessage()

func (*ListBeaconIDsResponse) ProtoReflect 

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

func (*ListBeaconIDsResponse) Reset 

func (x *ListBeaconIDsResponse) Reset()

func (*ListBeaconIDsResponse) String 

func (x *ListBeaconIDsResponse) String() string

type ListSchemesRequest 

type ListSchemesRequest struct {
	// contains filtered or unexported fields
}

func (*ListSchemesRequest) Descriptor deprecated 

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

Deprecated: Use ListSchemesRequest.ProtoReflect.Descriptor instead.

func (*ListSchemesRequest) ProtoMessage 

func (*ListSchemesRequest) ProtoMessage()

func (*ListSchemesRequest) ProtoReflect 

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

func (*ListSchemesRequest) Reset 

func (x *ListSchemesRequest) Reset()

func (*ListSchemesRequest) String 

func (x *ListSchemesRequest) String() string

type ListSchemesResponse 

type ListSchemesResponse struct {
	Ids      []string  `protobuf:"bytes,1,rep,name=ids,proto3" json:"ids,omitempty"`
	Metadata *Metadata `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

func (*ListSchemesResponse) Descriptor deprecated 

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

Deprecated: Use ListSchemesResponse.ProtoReflect.Descriptor instead.

func (*ListSchemesResponse) GetIds 

func (x *ListSchemesResponse) GetIds() []string

func (*ListSchemesResponse) GetMetadata 

func (x *ListSchemesResponse) GetMetadata() *Metadata

func (*ListSchemesResponse) ProtoMessage 

func (*ListSchemesResponse) ProtoMessage()

func (*ListSchemesResponse) ProtoReflect 

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

func (*ListSchemesResponse) Reset 

func (x *ListSchemesResponse) Reset()

func (*ListSchemesResponse) String 

func (x *ListSchemesResponse) String() string

type LoadBeaconRequest 

type LoadBeaconRequest struct {
	Metadata *Metadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

func (*LoadBeaconRequest) Descriptor deprecated 

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

Deprecated: Use LoadBeaconRequest.ProtoReflect.Descriptor instead.

func (*LoadBeaconRequest) GetMetadata 

func (x *LoadBeaconRequest) GetMetadata() *Metadata

func (*LoadBeaconRequest) ProtoMessage 

func (*LoadBeaconRequest) ProtoMessage()

func (*LoadBeaconRequest) ProtoReflect 

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

func (*LoadBeaconRequest) Reset 

func (x *LoadBeaconRequest) Reset()

func (*LoadBeaconRequest) String 

func (x *LoadBeaconRequest) String() string

type LoadBeaconResponse 

type LoadBeaconResponse struct {
	Metadata *Metadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

func (*LoadBeaconResponse) Descriptor deprecated 

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

Deprecated: Use LoadBeaconResponse.ProtoReflect.Descriptor instead.

func (*LoadBeaconResponse) GetMetadata 

func (x *LoadBeaconResponse) GetMetadata() *Metadata

func (*LoadBeaconResponse) ProtoMessage 

func (*LoadBeaconResponse) ProtoMessage()

func (*LoadBeaconResponse) ProtoReflect 

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

func (*LoadBeaconResponse) Reset 

func (x *LoadBeaconResponse) Reset()

func (*LoadBeaconResponse) String 

func (x *LoadBeaconResponse) String() string

type Metadata 

type Metadata struct {
	NodeVersion *NodeVersion `protobuf:"bytes,1,opt,name=node_version,json=nodeVersion,proto3" json:"node_version,omitempty"`
	BeaconID    string       `protobuf:"bytes,2,opt,name=beaconID,proto3" json:"beaconID,omitempty"`
	ChainHash   []byte       `protobuf:"bytes,3,opt,name=chain_hash,json=chainHash,proto3" json:"chain_hash,omitempty"`
	// contains filtered or unexported fields
}

func NewMetadata 

func NewMetadata(version *NodeVersion) *Metadata

func (*Metadata) Descriptor deprecated 

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

Deprecated: Use Metadata.ProtoReflect.Descriptor instead.

func (*Metadata) GetBeaconID 

func (x *Metadata) GetBeaconID() string

func (*Metadata) GetChainHash 

func (x *Metadata) GetChainHash() []byte

func (*Metadata) GetNodeVersion 

func (x *Metadata) GetNodeVersion() *NodeVersion

func (*Metadata) ProtoMessage 

func (*Metadata) ProtoMessage()

func (*Metadata) ProtoReflect 

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

func (*Metadata) Reset 

func (x *Metadata) Reset()

func (*Metadata) String 

func (x *Metadata) String() string

type MetricsClient 

type MetricsClient interface {
	Metrics(ctx context.Context, in *MetricsRequest, opts ...grpc.CallOption) (*MetricsResponse, error)
}

MetricsClient is the client API for Metrics 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 NewMetricsClient 

func NewMetricsClient(cc grpc.ClientConnInterface) MetricsClient

type MetricsRequest 

type MetricsRequest struct {
	// contains filtered or unexported fields
}

func (*MetricsRequest) Descriptor deprecated 

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

Deprecated: Use MetricsRequest.ProtoReflect.Descriptor instead.

func (*MetricsRequest) ProtoMessage 

func (*MetricsRequest) ProtoMessage()

func (*MetricsRequest) ProtoReflect 

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

func (*MetricsRequest) Reset 

func (x *MetricsRequest) Reset()

func (*MetricsRequest) String 

func (x *MetricsRequest) String() string

type MetricsResponse 

type MetricsResponse struct {
	Metrics []byte `protobuf:"bytes,1,opt,name=metrics,proto3" json:"metrics,omitempty"`
	// contains filtered or unexported fields
}

func (*MetricsResponse) Descriptor deprecated 

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

Deprecated: Use MetricsResponse.ProtoReflect.Descriptor instead.

func (*MetricsResponse) GetMetrics 

func (x *MetricsResponse) GetMetrics() []byte

func (*MetricsResponse) ProtoMessage 

func (*MetricsResponse) ProtoMessage()

func (*MetricsResponse) ProtoReflect 

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

func (*MetricsResponse) Reset 

func (x *MetricsResponse) Reset()

func (*MetricsResponse) String 

func (x *MetricsResponse) String() string

type MetricsServer 

type MetricsServer interface {
	Metrics(context.Context, *MetricsRequest) (*MetricsResponse, error)
}

MetricsServer is the server API for Metrics service. All implementations should embed UnimplementedMetricsServer for forward compatibility

type Node 

type Node struct {
	Public *Identity `protobuf:"bytes,1,opt,name=public,proto3" json:"public,omitempty"`
	Index  uint32    `protobuf:"varint,2,opt,name=index,proto3" json:"index,omitempty"`
	// contains filtered or unexported fields
}

Node holds the information related to a server in a group that forms a drand network

func (*Node) Descriptor deprecated 

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

Deprecated: Use Node.ProtoReflect.Descriptor instead.

func (*Node) GetIndex 

func (x *Node) GetIndex() uint32

func (*Node) GetPublic 

func (x *Node) GetPublic() *Identity

func (*Node) ProtoMessage 

func (*Node) ProtoMessage()

func (*Node) ProtoReflect 

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

func (*Node) Reset 

func (x *Node) Reset()

func (*Node) String 

func (x *Node) String() string

type NodeVersion 

type NodeVersion struct {
	Major      uint32  `protobuf:"varint,1,opt,name=major,proto3" json:"major,omitempty"`
	Minor      uint32  `protobuf:"varint,2,opt,name=minor,proto3" json:"minor,omitempty"`
	Patch      uint32  `protobuf:"varint,3,opt,name=patch,proto3" json:"patch,omitempty"`
	Prerelease *string `protobuf:"bytes,4,opt,name=prerelease,proto3,oneof" json:"prerelease,omitempty"`
	// contains filtered or unexported fields
}

func (*NodeVersion) Descriptor deprecated 

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

Deprecated: Use NodeVersion.ProtoReflect.Descriptor instead.

func (*NodeVersion) GetMajor 

func (x *NodeVersion) GetMajor() uint32

func (*NodeVersion) GetMinor 

func (x *NodeVersion) GetMinor() uint32

func (*NodeVersion) GetPatch 

func (x *NodeVersion) GetPatch() uint32

func (*NodeVersion) GetPrerelease 

func (x *NodeVersion) GetPrerelease() string

func (*NodeVersion) ProtoMessage 

func (*NodeVersion) ProtoMessage()

func (*NodeVersion) ProtoReflect 

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

func (*NodeVersion) Reset 

func (x *NodeVersion) Reset()

func (*NodeVersion) String 

func (x *NodeVersion) String() string

type PartialBeaconPacket 

type PartialBeaconPacket struct {

	// Round is the round for which the beacon will be created from the partial
	// signatures
	Round uint64 `protobuf:"varint,1,opt,name=round,proto3" json:"round,omitempty"`
	// signature of the previous round - could be removed at some point but now
	// is used to verify the signature even before accessing the store
	PreviousSignature []byte `protobuf:"bytes,2,opt,name=previous_signature,json=previousSignature,proto3" json:"previous_signature,omitempty"`
	// partial signature - a threshold of them needs to be aggregated to produce
	// the final beacon at the given round.
	PartialSig []byte    `protobuf:"bytes,3,opt,name=partial_sig,json=partialSig,proto3" json:"partial_sig,omitempty"`
	Metadata   *Metadata `protobuf:"bytes,4,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

func (*PartialBeaconPacket) Descriptor deprecated 

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

Deprecated: Use PartialBeaconPacket.ProtoReflect.Descriptor instead.

func (*PartialBeaconPacket) GetMetadata 

func (x *PartialBeaconPacket) GetMetadata() *Metadata

func (*PartialBeaconPacket) GetPartialSig 

func (x *PartialBeaconPacket) GetPartialSig() []byte

func (*PartialBeaconPacket) GetPreviousSignature 

func (x *PartialBeaconPacket) GetPreviousSignature() []byte

func (*PartialBeaconPacket) GetRound 

func (x *PartialBeaconPacket) GetRound() uint64

func (*PartialBeaconPacket) ProtoMessage 

func (*PartialBeaconPacket) ProtoMessage()

func (*PartialBeaconPacket) ProtoReflect 

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

func (*PartialBeaconPacket) Reset 

func (x *PartialBeaconPacket) Reset()

func (*PartialBeaconPacket) String 

func (x *PartialBeaconPacket) String() string

type Ping 

type Ping struct {
	Metadata *Metadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

func (*Ping) Descriptor deprecated 

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

Deprecated: Use Ping.ProtoReflect.Descriptor instead.

func (*Ping) GetMetadata 

func (x *Ping) GetMetadata() *Metadata

func (*Ping) ProtoMessage 

func (*Ping) ProtoMessage()

func (*Ping) ProtoReflect 

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

func (*Ping) Reset 

func (x *Ping) Reset()

func (*Ping) String 

func (x *Ping) String() string

type Pong 

type Pong struct {
	Metadata *Metadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

func (*Pong) Descriptor deprecated 

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

Deprecated: Use Pong.ProtoReflect.Descriptor instead.

func (*Pong) GetMetadata 

func (x *Pong) GetMetadata() *Metadata

func (*Pong) ProtoMessage 

func (*Pong) ProtoMessage()

func (*Pong) ProtoReflect 

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

func (*Pong) Reset 

func (x *Pong) Reset()

func (*Pong) String 

func (x *Pong) String() string

type ProtocolClient 

type ProtocolClient interface {
	// GetIdentity returns the identity of the drand node
	GetIdentity(ctx context.Context, in *IdentityRequest, opts ...grpc.CallOption) (*IdentityResponse, error)
	// PartialBeacon sends its partial beacon to another node
	PartialBeacon(ctx context.Context, in *PartialBeaconPacket, opts ...grpc.CallOption) (*Empty, error)
	// SyncRequest forces a daemon to sync up its chain with other nodes
	SyncChain(ctx context.Context, in *SyncRequest, opts ...grpc.CallOption) (Protocol_SyncChainClient, error)
	// Status responds with the actual status of drand process
	Status(ctx context.Context, in *StatusRequest, opts ...grpc.CallOption) (*StatusResponse, error)
}

ProtocolClient is the client API for Protocol 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 NewProtocolClient 

func NewProtocolClient(cc grpc.ClientConnInterface) ProtocolClient

type ProtocolServer 

type ProtocolServer interface {
	// GetIdentity returns the identity of the drand node
	GetIdentity(context.Context, *IdentityRequest) (*IdentityResponse, error)
	// PartialBeacon sends its partial beacon to another node
	PartialBeacon(context.Context, *PartialBeaconPacket) (*Empty, error)
	// SyncRequest forces a daemon to sync up its chain with other nodes
	SyncChain(*SyncRequest, Protocol_SyncChainServer) error
	// Status responds with the actual status of drand process
	Status(context.Context, *StatusRequest) (*StatusResponse, error)
}

ProtocolServer is the server API for Protocol service. All implementations should embed UnimplementedProtocolServer for forward compatibility

type Protocol_SyncChainClient 

type Protocol_SyncChainClient interface {
	Recv() (*BeaconPacket, error)
	grpc.ClientStream
}

type Protocol_SyncChainServer 

type Protocol_SyncChainServer interface {
	Send(*BeaconPacket) error
	grpc.ServerStream
}

type PublicClient 

type PublicClient interface {
	// PublicRand is the method that returns the publicly verifiable randomness
	// generated by the drand network.
	PublicRand(ctx context.Context, in *PublicRandRequest, opts ...grpc.CallOption) (*PublicRandResponse, error)
	PublicRandStream(ctx context.Context, in *PublicRandRequest, opts ...grpc.CallOption) (Public_PublicRandStreamClient, error)
	// ChainInfo returns the information related to the chain this node
	// participates to
	ChainInfo(ctx context.Context, in *ChainInfoRequest, opts ...grpc.CallOption) (*ChainInfoPacket, error)
	// ListBeaconIDs responds with the list of Beacon IDs running on that node
	ListBeaconIDs(ctx context.Context, in *ListBeaconIDsRequest, opts ...grpc.CallOption) (*ListBeaconIDsResponse, error)
}

PublicClient is the client API for Public 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 NewPublicClient 

func NewPublicClient(cc grpc.ClientConnInterface) PublicClient

type PublicKeyRequest 

type PublicKeyRequest struct {
	Metadata *Metadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

PublicKeyRequest requests the public key of a drand node for a given Beacon ID

func (*PublicKeyRequest) Descriptor deprecated 

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

Deprecated: Use PublicKeyRequest.ProtoReflect.Descriptor instead.

func (*PublicKeyRequest) GetMetadata 

func (x *PublicKeyRequest) GetMetadata() *Metadata

func (*PublicKeyRequest) ProtoMessage 

func (*PublicKeyRequest) ProtoMessage()

func (*PublicKeyRequest) ProtoReflect 

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

func (*PublicKeyRequest) Reset 

func (x *PublicKeyRequest) Reset()

func (*PublicKeyRequest) String 

func (x *PublicKeyRequest) String() string

type PublicKeyResponse 

type PublicKeyResponse struct {
	PubKey []byte `protobuf:"bytes,1,opt,name=pubKey,proto3" json:"pubKey,omitempty"`
	Addr   string `protobuf:"bytes,2,opt,name=addr,proto3" json:"addr,omitempty"`
	// Deprecated: Marked as deprecated in drand/control.proto.
	Tls        bool      `protobuf:"varint,3,opt,name=tls,proto3" json:"tls,omitempty"`
	Signature  []byte    `protobuf:"bytes,4,opt,name=signature,proto3" json:"signature,omitempty"`
	Metadata   *Metadata `protobuf:"bytes,5,opt,name=metadata,proto3" json:"metadata,omitempty"`
	SchemeName string    `protobuf:"bytes,6,opt,name=schemeName,proto3" json:"schemeName,omitempty"`
	// contains filtered or unexported fields
}

PublicKeyResponse holds the public key of a drand node

func (*PublicKeyResponse) Descriptor deprecated 

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

Deprecated: Use PublicKeyResponse.ProtoReflect.Descriptor instead.

func (*PublicKeyResponse) GetAddr 

func (x *PublicKeyResponse) GetAddr() string

func (*PublicKeyResponse) GetMetadata 

func (x *PublicKeyResponse) GetMetadata() *Metadata

func (*PublicKeyResponse) GetPubKey 

func (x *PublicKeyResponse) GetPubKey() []byte

func (*PublicKeyResponse) GetSchemeName 

func (x *PublicKeyResponse) GetSchemeName() string

func (*PublicKeyResponse) GetSignature 

func (x *PublicKeyResponse) GetSignature() []byte

func (*PublicKeyResponse) GetTls deprecated 

func (x *PublicKeyResponse) GetTls() bool

Deprecated: Marked as deprecated in drand/control.proto.

func (*PublicKeyResponse) ProtoMessage 

func (*PublicKeyResponse) ProtoMessage()

func (*PublicKeyResponse) ProtoReflect 

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

func (*PublicKeyResponse) Reset 

func (x *PublicKeyResponse) Reset()

func (*PublicKeyResponse) String 

func (x *PublicKeyResponse) String() string

type PublicRandRequest 

type PublicRandRequest struct {

	// round uniquely identifies a beacon. If round == 0 (or unspecified), then
	// the response will contain the last.
	Round    uint64    `protobuf:"varint,1,opt,name=round,proto3" json:"round,omitempty"`
	Metadata *Metadata `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

PublicRandRequest requests a public random value that has been generated in a unbiasable way and verifiable.

func (*PublicRandRequest) Descriptor deprecated 

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

Deprecated: Use PublicRandRequest.ProtoReflect.Descriptor instead.

func (*PublicRandRequest) GetMetadata 

func (x *PublicRandRequest) GetMetadata() *Metadata

func (*PublicRandRequest) GetRound 

func (x *PublicRandRequest) GetRound() uint64

func (*PublicRandRequest) ProtoMessage 

func (*PublicRandRequest) ProtoMessage()

func (*PublicRandRequest) ProtoReflect 

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

func (*PublicRandRequest) Reset 

func (x *PublicRandRequest) Reset()

func (*PublicRandRequest) String 

func (x *PublicRandRequest) String() string

type PublicRandResponse 

type PublicRandResponse struct {
	Round             uint64 `protobuf:"varint,1,opt,name=round,proto3" json:"round,omitempty"`
	Signature         []byte `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"`
	PreviousSignature []byte `protobuf:"bytes,3,opt,name=previous_signature,json=previousSignature,proto3" json:"previous_signature,omitempty"`
	// randomness is simply there to demonstrate - it is the hash of the
	// signature. It should be computed locally.
	//
	// Deprecated: Marked as deprecated in drand/api.proto.
	Randomness []byte    `protobuf:"bytes,4,opt,name=randomness,proto3" json:"randomness,omitempty"`
	Metadata   *Metadata `protobuf:"bytes,5,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

PublicRandResponse holds a signature which is the random value. It can be verified thanks to the distributed public key of the nodes that have ran the DKG protocol and is unbiasable. The randomness can be verified using the BLS verification routine with the message "round || previous_rand".

func (*PublicRandResponse) Descriptor deprecated 

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

Deprecated: Use PublicRandResponse.ProtoReflect.Descriptor instead.

func (*PublicRandResponse) GetMetadata 

func (x *PublicRandResponse) GetMetadata() *Metadata

func (*PublicRandResponse) GetPreviousSignature 

func (x *PublicRandResponse) GetPreviousSignature() []byte

func (*PublicRandResponse) GetRandomness deprecated 

func (x *PublicRandResponse) GetRandomness() []byte

Deprecated: Marked as deprecated in drand/api.proto.

func (*PublicRandResponse) GetRound 

func (x *PublicRandResponse) GetRound() uint64

func (*PublicRandResponse) GetSignature 

func (x *PublicRandResponse) GetSignature() []byte

func (*PublicRandResponse) ProtoMessage 

func (*PublicRandResponse) ProtoMessage()

func (*PublicRandResponse) ProtoReflect 

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

func (*PublicRandResponse) Reset 

func (x *PublicRandResponse) Reset()

func (*PublicRandResponse) String 

func (x *PublicRandResponse) String() string

type PublicServer 

type PublicServer interface {
	// PublicRand is the method that returns the publicly verifiable randomness
	// generated by the drand network.
	PublicRand(context.Context, *PublicRandRequest) (*PublicRandResponse, error)
	PublicRandStream(*PublicRandRequest, Public_PublicRandStreamServer) error
	// ChainInfo returns the information related to the chain this node
	// participates to
	ChainInfo(context.Context, *ChainInfoRequest) (*ChainInfoPacket, error)
	// ListBeaconIDs responds with the list of Beacon IDs running on that node
	ListBeaconIDs(context.Context, *ListBeaconIDsRequest) (*ListBeaconIDsResponse, error)
}

PublicServer is the server API for Public service. All implementations should embed UnimplementedPublicServer for forward compatibility

type Public_PublicRandStreamClient 

type Public_PublicRandStreamClient interface {
	Recv() (*PublicRandResponse, error)
	grpc.ClientStream
}

type Public_PublicRandStreamServer 

type Public_PublicRandStreamServer interface {
	Send(*PublicRandResponse) error
	grpc.ServerStream
}

type RemoteStatusRequest 

type RemoteStatusRequest struct {
	Metadata  *Metadata  `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	Addresses []*Address `protobuf:"bytes,2,rep,name=addresses,proto3" json:"addresses,omitempty"`
	// contains filtered or unexported fields
}

RemoteStatusRequest contains the list of addresses that the local drand node process should ask the status to.

func (*RemoteStatusRequest) Descriptor deprecated 

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

Deprecated: Use RemoteStatusRequest.ProtoReflect.Descriptor instead.

func (*RemoteStatusRequest) GetAddresses 

func (x *RemoteStatusRequest) GetAddresses() []*Address

func (*RemoteStatusRequest) GetMetadata 

func (x *RemoteStatusRequest) GetMetadata() *Metadata

func (*RemoteStatusRequest) ProtoMessage 

func (*RemoteStatusRequest) ProtoMessage()

func (*RemoteStatusRequest) ProtoReflect 

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

func (*RemoteStatusRequest) Reset 

func (x *RemoteStatusRequest) Reset()

func (*RemoteStatusRequest) String 

func (x *RemoteStatusRequest) String() string

type RemoteStatusResponse 

type RemoteStatusResponse struct {
	Statuses map[string]*StatusResponse `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

RemoteStatusResponse contains the statuses reponses of all nodes given in the requests. If a node did not reply, then the address key is absent from the map

func (*RemoteStatusResponse) Descriptor deprecated 

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

Deprecated: Use RemoteStatusResponse.ProtoReflect.Descriptor instead.

func (*RemoteStatusResponse) GetStatuses 

func (x *RemoteStatusResponse) GetStatuses() map[string]*StatusResponse

func (*RemoteStatusResponse) ProtoMessage 

func (*RemoteStatusResponse) ProtoMessage()

func (*RemoteStatusResponse) ProtoReflect 

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

func (*RemoteStatusResponse) Reset 

func (x *RemoteStatusResponse) Reset()

func (*RemoteStatusResponse) String 

func (x *RemoteStatusResponse) String() string

type ShutdownRequest 

type ShutdownRequest struct {
	Metadata *Metadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

func (*ShutdownRequest) Descriptor deprecated 

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

Deprecated: Use ShutdownRequest.ProtoReflect.Descriptor instead.

func (*ShutdownRequest) GetMetadata 

func (x *ShutdownRequest) GetMetadata() *Metadata

func (*ShutdownRequest) ProtoMessage 

func (*ShutdownRequest) ProtoMessage()

func (*ShutdownRequest) ProtoReflect 

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

func (*ShutdownRequest) Reset 

func (x *ShutdownRequest) Reset()

func (*ShutdownRequest) String 

func (x *ShutdownRequest) String() string

type ShutdownResponse 

type ShutdownResponse struct {
	Metadata *Metadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

func (*ShutdownResponse) Descriptor deprecated 

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

Deprecated: Use ShutdownResponse.ProtoReflect.Descriptor instead.

func (*ShutdownResponse) GetMetadata 

func (x *ShutdownResponse) GetMetadata() *Metadata

func (*ShutdownResponse) ProtoMessage 

func (*ShutdownResponse) ProtoMessage()

func (*ShutdownResponse) ProtoReflect 

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

func (*ShutdownResponse) Reset 

func (x *ShutdownResponse) Reset()

func (*ShutdownResponse) String 

func (x *ShutdownResponse) String() string

type StartSyncRequest 

type StartSyncRequest struct {

	// nodes to contact to
	Nodes []string `protobuf:"bytes,2,rep,name=nodes,proto3" json:"nodes,omitempty"`
	// is TLS enabled on these nodes or not
	// NOTE currently drand either supports syncing from all TLS or all
	// non-tls nodes
	//
	// Deprecated: Marked as deprecated in drand/control.proto.
	IsTls bool `protobuf:"varint,3,opt,name=is_tls,json=isTls,proto3" json:"is_tls,omitempty"`
	// up_to tells the drand daemon to not sync up after the given round.
	// if up_to is 0, the sync operation continues until it is cancelled.
	UpTo     uint64    `protobuf:"varint,4,opt,name=up_to,json=upTo,proto3" json:"up_to,omitempty"`
	Metadata *Metadata `protobuf:"bytes,5,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

func (*StartSyncRequest) Descriptor deprecated 

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

Deprecated: Use StartSyncRequest.ProtoReflect.Descriptor instead.

func (*StartSyncRequest) GetIsTls deprecated 

func (x *StartSyncRequest) GetIsTls() bool

Deprecated: Marked as deprecated in drand/control.proto.

func (*StartSyncRequest) GetMetadata 

func (x *StartSyncRequest) GetMetadata() *Metadata

func (*StartSyncRequest) GetNodes 

func (x *StartSyncRequest) GetNodes() []string

func (*StartSyncRequest) GetUpTo 

func (x *StartSyncRequest) GetUpTo() uint64

func (*StartSyncRequest) ProtoMessage 

func (*StartSyncRequest) ProtoMessage()

func (*StartSyncRequest) ProtoReflect 

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

func (*StartSyncRequest) Reset 

func (x *StartSyncRequest) Reset()

func (*StartSyncRequest) String 

func (x *StartSyncRequest) String() string

type StatusRequest 

type StatusRequest struct {

	// the check_conn contains the list of addresses to check connectivity to,
	// i.e. does a GRPC health check on it.
	// If the field is absent or empty, then all nodes in the group file are tested.
	CheckConn []*Address `protobuf:"bytes,1,rep,name=check_conn,json=checkConn,proto3" json:"check_conn,omitempty"`
	Metadata  *Metadata  `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

func (*StatusRequest) Descriptor deprecated 

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

Deprecated: Use StatusRequest.ProtoReflect.Descriptor instead.

func (*StatusRequest) GetCheckConn 

func (x *StatusRequest) GetCheckConn() []*Address

func (*StatusRequest) GetMetadata 

func (x *StatusRequest) GetMetadata() *Metadata

func (*StatusRequest) ProtoMessage 

func (*StatusRequest) ProtoMessage()

func (*StatusRequest) ProtoReflect 

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

func (*StatusRequest) Reset 

func (x *StatusRequest) Reset()

func (*StatusRequest) String 

func (x *StatusRequest) String() string

type StatusResponse 

type StatusResponse struct {
	Dkg         *DkgStatus        `protobuf:"bytes,1,opt,name=dkg,proto3" json:"dkg,omitempty"`
	Epoch       uint32            `protobuf:"varint,2,opt,name=epoch,proto3" json:"epoch,omitempty"`
	Beacon      *BeaconStatus     `protobuf:"bytes,3,opt,name=beacon,proto3" json:"beacon,omitempty"`
	ChainStore  *ChainStoreStatus `protobuf:"bytes,4,opt,name=chain_store,json=chainStore,proto3" json:"chain_store,omitempty"`
	Connections map[string]bool   `` /* 164-byte string literal not displayed */
	// contains filtered or unexported fields
}

StatusResponse contains different indicators of the status of the local drand node process and as well some view on the connectivity with other nodes if ask during the StatusRequest.

func (*StatusResponse) Descriptor deprecated 

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

Deprecated: Use StatusResponse.ProtoReflect.Descriptor instead.

func (*StatusResponse) GetBeacon 

func (x *StatusResponse) GetBeacon() *BeaconStatus

func (*StatusResponse) GetChainStore 

func (x *StatusResponse) GetChainStore() *ChainStoreStatus

func (*StatusResponse) GetConnections 

func (x *StatusResponse) GetConnections() map[string]bool

func (*StatusResponse) GetDkg 

func (x *StatusResponse) GetDkg() *DkgStatus

func (*StatusResponse) GetEpoch 

func (x *StatusResponse) GetEpoch() uint32

func (*StatusResponse) ProtoMessage 

func (*StatusResponse) ProtoMessage()

func (*StatusResponse) ProtoReflect 

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

func (*StatusResponse) Reset 

func (x *StatusResponse) Reset()

func (*StatusResponse) String 

func (x *StatusResponse) String() string

type SyncProgress 

type SyncProgress struct {
	Current  uint64    `protobuf:"varint,1,opt,name=current,proto3" json:"current,omitempty"`
	Target   uint64    `protobuf:"varint,2,opt,name=target,proto3" json:"target,omitempty"`
	Metadata *Metadata `protobuf:"bytes,3,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

func (*SyncProgress) Descriptor deprecated 

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

Deprecated: Use SyncProgress.ProtoReflect.Descriptor instead.

func (*SyncProgress) GetCurrent 

func (x *SyncProgress) GetCurrent() uint64

func (*SyncProgress) GetMetadata 

func (x *SyncProgress) GetMetadata() *Metadata

func (*SyncProgress) GetTarget 

func (x *SyncProgress) GetTarget() uint64

func (*SyncProgress) ProtoMessage 

func (*SyncProgress) ProtoMessage()

func (*SyncProgress) ProtoReflect 

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

func (*SyncProgress) Reset 

func (x *SyncProgress) Reset()

func (*SyncProgress) String 

func (x *SyncProgress) String() string

type SyncRequest 

type SyncRequest struct {
	FromRound uint64    `protobuf:"varint,1,opt,name=from_round,json=fromRound,proto3" json:"from_round,omitempty"`
	Metadata  *Metadata `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

SyncRequest is from a node that needs to sync up with the current head of the chain

func (*SyncRequest) Descriptor deprecated 

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

Deprecated: Use SyncRequest.ProtoReflect.Descriptor instead.

func (*SyncRequest) GetFromRound 

func (x *SyncRequest) GetFromRound() uint64

func (*SyncRequest) GetMetadata 

func (x *SyncRequest) GetMetadata() *Metadata

func (*SyncRequest) ProtoMessage 

func (*SyncRequest) ProtoMessage()

func (*SyncRequest) ProtoReflect 

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

func (*SyncRequest) Reset 

func (x *SyncRequest) Reset()

func (*SyncRequest) String 

func (x *SyncRequest) String() string

type UnimplementedControlServer 

type UnimplementedControlServer struct {
}

UnimplementedControlServer should be embedded to have forward compatible implementations.

func (UnimplementedControlServer) BackupDatabase 

func (UnimplementedControlServer) BackupDatabase(context.Context, *BackupDBRequest) (*BackupDBResponse, error)

func (UnimplementedControlServer) ChainInfo 

func (UnimplementedControlServer) ChainInfo(context.Context, *ChainInfoRequest) (*ChainInfoPacket, error)

func (UnimplementedControlServer) GroupFile 

func (UnimplementedControlServer) GroupFile(context.Context, *GroupRequest) (*GroupPacket, error)

func (UnimplementedControlServer) ListSchemes 

func (UnimplementedControlServer) ListSchemes(context.Context, *ListSchemesRequest) (*ListSchemesResponse, error)

func (UnimplementedControlServer) LoadBeacon 

func (UnimplementedControlServer) LoadBeacon(context.Context, *LoadBeaconRequest) (*LoadBeaconResponse, error)

func (UnimplementedControlServer) PingPong 

func (UnimplementedControlServer) PingPong(context.Context, *Ping) (*Pong, error)

func (UnimplementedControlServer) PublicKey 

func (UnimplementedControlServer) PublicKey(context.Context, *PublicKeyRequest) (*PublicKeyResponse, error)

func (UnimplementedControlServer) RemoteStatus 

func (UnimplementedControlServer) RemoteStatus(context.Context, *RemoteStatusRequest) (*RemoteStatusResponse, error)

func (UnimplementedControlServer) Shutdown 

func (UnimplementedControlServer) Shutdown(context.Context, *ShutdownRequest) (*ShutdownResponse, error)

func (UnimplementedControlServer) StartCheckChain 

func (UnimplementedControlServer) StartCheckChain(*StartSyncRequest, Control_StartCheckChainServer) error

func (UnimplementedControlServer) StartFollowChain 

func (UnimplementedControlServer) StartFollowChain(*StartSyncRequest, Control_StartFollowChainServer) error

func (UnimplementedControlServer) Status 

func (UnimplementedControlServer) Status(context.Context, *StatusRequest) (*StatusResponse, error)

type UnimplementedMetricsServer 

type UnimplementedMetricsServer struct {
}

UnimplementedMetricsServer should be embedded to have forward compatible implementations.

func (UnimplementedMetricsServer) Metrics 

func (UnimplementedMetricsServer) Metrics(context.Context, *MetricsRequest) (*MetricsResponse, error)

type UnimplementedProtocolServer 

type UnimplementedProtocolServer struct {
}

UnimplementedProtocolServer should be embedded to have forward compatible implementations.

func (UnimplementedProtocolServer) GetIdentity 

func (UnimplementedProtocolServer) GetIdentity(context.Context, *IdentityRequest) (*IdentityResponse, error)

func (UnimplementedProtocolServer) PartialBeacon 

func (UnimplementedProtocolServer) PartialBeacon(context.Context, *PartialBeaconPacket) (*Empty, error)

func (UnimplementedProtocolServer) Status 

func (UnimplementedProtocolServer) Status(context.Context, *StatusRequest) (*StatusResponse, error)

func (UnimplementedProtocolServer) SyncChain 

func (UnimplementedProtocolServer) SyncChain(*SyncRequest, Protocol_SyncChainServer) error

type UnimplementedPublicServer 

type UnimplementedPublicServer struct {
}

UnimplementedPublicServer should be embedded to have forward compatible implementations.

func (UnimplementedPublicServer) ChainInfo 

func (UnimplementedPublicServer) ChainInfo(context.Context, *ChainInfoRequest) (*ChainInfoPacket, error)

func (UnimplementedPublicServer) ListBeaconIDs 

func (UnimplementedPublicServer) ListBeaconIDs(context.Context, *ListBeaconIDsRequest) (*ListBeaconIDsResponse, error)

func (UnimplementedPublicServer) PublicRand 

func (UnimplementedPublicServer) PublicRand(context.Context, *PublicRandRequest) (*PublicRandResponse, error)

func (UnimplementedPublicServer) PublicRandStream 

func (UnimplementedPublicServer) PublicRandStream(*PublicRandRequest, Public_PublicRandStreamServer) error

type UnsafeControlServer 

type UnsafeControlServer interface {
	// contains filtered or unexported methods
}

UnsafeControlServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ControlServer will result in compilation errors.

type UnsafeMetricsServer 

type UnsafeMetricsServer interface {
	// contains filtered or unexported methods
}

UnsafeMetricsServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to MetricsServer will result in compilation errors.

type UnsafeProtocolServer 

type UnsafeProtocolServer interface {
	// contains filtered or unexported methods
}

UnsafeProtocolServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ProtocolServer will result in compilation errors.

type UnsafePublicServer 

type UnsafePublicServer interface {
	// contains filtered or unexported methods
}

UnsafePublicServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to PublicServer will result in compilation errors.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.