utils

Documentation

Index

• Constants
• Variables
• func CalculateQueryHash(relayReq pairingtypes.RelayRequest) (queryHash []byte)
• func CalculateVrfOnRelay(request *pairingtypes.RelayRequest, response *pairingtypes.RelayReply, ...) ([]byte, []byte)
• func Deserialize(raw []byte, data any)
• func FormatDataForVrf(request *pairingtypes.RelayRequest, response *pairingtypes.RelayReply, ...) (data []byte)
• func GeneratePrivateVRFKey() (vrf.PrivateKey, vrf.PublicKey, error)
• func GetIndexForVrf(vrf []byte, providersCount uint32, reliabilityThreshold uint32) (index int64, err error)
• func LavaError(ctx sdk.Context, logger log.Logger, name string, attributes map[string]string, ...) error
• func LavaFormatDebug(description string, extraAttributes *map[string]string) error
• func LavaFormatError(description string, err error, extraAttributes *map[string]string) error
• func LavaFormatFatal(description string, err error, extraAttributes *map[string]string)
• func LavaFormatInfo(description string, extraAttributes *map[string]string) error
• func LavaFormatLog(description string, err error, extraAttributes *map[string]string, ...) error
• func LavaFormatWarning(description string, err error, extraAttributes *map[string]string) error
• func LogLavaEvent(ctx sdk.Context, logger log.Logger, name string, attributes map[string]string, ...)
• func LoggingLevel(logLevel string)
• func OpenKeyring(clientCtx client.Context) (keyring.Keyring, error)
• func ProveVrfOnRelay(request *pairingtypes.RelayRequest, response *pairingtypes.RelayReply, ...) (vrf_res []byte, proof []byte)
• func Serialize(data any) []byte
• func VerifyVRF(vrfpk string) error
• func VerifyVrfProof(request *pairingtypes.RelayRequest, vrf_pk VrfPubKey, relayEpochStart uint64) (valid bool)
• func VerifyVrfProofFromVRFData(reliabilityData *pairingtypes.VRFData, vrf_pk VrfPubKey, ...) (valid bool)
• type LavaMutex
  • func (dm *LavaMutex) Lock()
  • func (dm *LavaMutex) TryLock() (isLocked bool)
  • func (dm *LavaMutex) Unlock()
• type Lockable
• type VrfPubKey
  • func GenerateVRFKey(clientCtx client.Context) (vrf.PrivateKey, *VrfPubKey, error)
  • func GetOrCreateVRFKey(clientCtx client.Context) (sk vrf.PrivateKey, pk *VrfPubKey, err error)
  • func LoadVRFKey(clientCtx client.Context) (vrf.PrivateKey, *VrfPubKey, error)
  • func (pk *VrfPubKey) Bytes() []byte
  • func (pk *VrfPubKey) DecodeFromBech32(bech32str string) (*VrfPubKey, error)
  • func (pk *VrfPubKey) EncodeBech32() (string, error)
  • func (pk *VrfPubKey) Equals(pk2 VrfPubKey) bool
  • func (pk *VrfPubKey) MarshalTo(dAtA []byte) (int, error)
  • func (pk *VrfPubKey) Reset()
  • func (pk *VrfPubKey) String() string
  • func (pk *VrfPubKey) Unmarshal(bz []byte) error
  • func (pk *VrfPubKey) VerifySignature(m []byte, vrfBytes []byte, proof []byte) bool

Constants

const (
	EventPrefix = "lava_"
)

const TIMEOUT = 10

Variables

var (
	TimeoutMutex           = "false"
	TimeoutMutexBoolean, _ = strconv.ParseBool(TimeoutMutex)
)

var VRFValueAboveReliabilityThresholdError = sdkerrors.New("VRFValueAboveReliabilityThreshold Error", 1, "calculated vrf does not result in a smaller value than threshold") // client could'nt connect to any provider.

Functions

func CalculateQueryHash

func CalculateQueryHash(relayReq pairingtypes.RelayRequest) (queryHash []byte)

func CalculateVrfOnRelay

func CalculateVrfOnRelay(request *pairingtypes.RelayRequest, response *pairingtypes.RelayReply, vrf_sk vrf.PrivateKey, currentEpoch uint64) ([]byte, []byte)

func Deserialize

func Deserialize(raw []byte, data any)

func FormatDataForVrf

func FormatDataForVrf(request *pairingtypes.RelayRequest, response *pairingtypes.RelayReply, differentiator bool, currentEpoch uint64) (data []byte)

func GeneratePrivateVRFKey

func GeneratePrivateVRFKey() (vrf.PrivateKey, vrf.PublicKey, error)

func GetIndexForVrf

func GetIndexForVrf(vrf []byte, providersCount uint32, reliabilityThreshold uint32) (index int64, err error)

func LavaError

func LavaError(ctx sdk.Context, logger log.Logger, name string, attributes map[string]string, description string) error

func LavaFormatDebug

func LavaFormatDebug(description string, extraAttributes *map[string]string) error

func LavaFormatError

func LavaFormatError(description string, err error, extraAttributes *map[string]string) error

func LavaFormatFatal

func LavaFormatFatal(description string, err error, extraAttributes *map[string]string)

func LavaFormatInfo

func LavaFormatInfo(description string, extraAttributes *map[string]string) error

func LavaFormatLog

func LavaFormatLog(description string, err error, extraAttributes *map[string]string, severity uint) error

func LavaFormatWarning

func LavaFormatWarning(description string, err error, extraAttributes *map[string]string) error

func LogLavaEvent

func LogLavaEvent(ctx sdk.Context, logger log.Logger, name string, attributes map[string]string, description string)

func LoggingLevel

func LoggingLevel(logLevel string)

func OpenKeyring

func OpenKeyring(clientCtx client.Context) (keyring.Keyring, error)

func ProveVrfOnRelay

func ProveVrfOnRelay(request *pairingtypes.RelayRequest, response *pairingtypes.RelayReply, vrf_sk vrf.PrivateKey, differentiator bool, currentEpoch uint64) (vrf_res []byte, proof []byte)

func Serialize

func Serialize(data any) []byte

func VerifyVRF

func VerifyVRF(vrfpk string) error

func VerifyVrfProof

func VerifyVrfProof(request *pairingtypes.RelayRequest, vrf_pk VrfPubKey, relayEpochStart uint64) (valid bool)

func VerifyVrfProofFromVRFData

func VerifyVrfProofFromVRFData(reliabilityData *pairingtypes.VRFData, vrf_pk VrfPubKey, relayEpochStart uint64) (valid bool)

Types

type LavaMutex

type LavaMutex struct {
	SecondsLeft int
	// contains filtered or unexported fields
}

func (*LavaMutex) Lock

func (dm *LavaMutex) Lock()

func (*LavaMutex) TryLock

func (dm *LavaMutex) TryLock() (isLocked bool)

func (*LavaMutex) Unlock

func (dm *LavaMutex) Unlock()

type Lockable

type Lockable interface {
	Lock()
	TryLock() bool
	Unlock()
}

type VrfPubKey

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

func GenerateVRFKey

func GenerateVRFKey(clientCtx client.Context) (vrf.PrivateKey, *VrfPubKey, error)

func GetOrCreateVRFKey

func GetOrCreateVRFKey(clientCtx client.Context) (sk vrf.PrivateKey, pk *VrfPubKey, err error)

func LoadVRFKey

func LoadVRFKey(clientCtx client.Context) (vrf.PrivateKey, *VrfPubKey, error)

func (*VrfPubKey) Bytes

func (pk *VrfPubKey) Bytes() []byte

func (*VrfPubKey) DecodeFromBech32

func (pk *VrfPubKey) DecodeFromBech32(bech32str string) (*VrfPubKey, error)

func (*VrfPubKey) EncodeBech32

func (pk *VrfPubKey) EncodeBech32() (string, error)

func (*VrfPubKey) Equals

func (pk *VrfPubKey) Equals(pk2 VrfPubKey) bool

func (*VrfPubKey) MarshalTo

func (pk *VrfPubKey) MarshalTo(dAtA []byte) (int, error)

// MarshalTo implements proto.Marshaler interface.

func (*VrfPubKey) Reset

func (pk *VrfPubKey) Reset()

func (*VrfPubKey) String

func (pk *VrfPubKey) String() string

String returns a string representation of the public key

func (*VrfPubKey) Unmarshal

func (pk *VrfPubKey) Unmarshal(bz []byte) error

// Unmarshal implements proto.Marshaler interface.

func (*VrfPubKey) VerifySignature

func (pk *VrfPubKey) VerifySignature(m []byte, vrfBytes []byte, proof []byte) bool