updater

Documentation

Index

• func ConnectToMultiaddr(ctx context.Context, h host.Host, targetPeer string) error
• func HashRequestContent(content UpdateRequestContent) []byte
• func HostToString(h host.Host) string
• func NewHost() host.Host
• type PublicKey
  • func PublicKeyFromBase64(base64KeyString string) PublicKey
• type Signature
• type UpdateRequest
• type UpdateRequestContent
• type UpdaterInstance
  • func NewInstance(trustedKeys []PublicKey, p2pInstance *p2p.Instance) *UpdaterInstance
  • func (updater *UpdaterInstance) Start(ctx context.Context)
  • func (u *UpdaterInstance) UpdateIfAppropriate(h host.Host) bool
  • func (u *UpdaterInstance) VerifyRequest(req UpdateRequest) bool

Functions

func ConnectToMultiaddr

func ConnectToMultiaddr(ctx context.Context, h host.Host, targetPeer string) error

TODO: Move this somewhere more appropriate

func HashRequestContent

func HashRequestContent(content UpdateRequestContent) []byte

func HostToString

func HostToString(h host.Host) string

func NewHost

func NewHost() host.Host

Used for debugging, will panic on err.

Types

type PublicKey

type PublicKey [ed25519.PublicKeySize]byte

func PublicKeyFromBase64

func PublicKeyFromBase64(base64KeyString string) PublicKey

type Signature

type Signature [ed25519.SignatureSize]byte

type UpdateRequest

type UpdateRequest struct {
	PublicKey PublicKey
	Signature Signature

	Content UpdateRequestContent
}

type UpdateRequestContent

type UpdateRequestContent struct {
	Nonce     int64
	BinaryCid []byte
}

type UpdaterInstance

type UpdaterInstance struct {
	TrustedKeys []PublicKey

	LatestVerifiedRequests []UpdateRequest
	P2pInstance            *p2p.Instance
}

func NewInstance

func NewInstance(trustedKeys []PublicKey, p2pInstance *p2p.Instance) *UpdaterInstance

func (*UpdaterInstance) Start

func (updater *UpdaterInstance) Start(ctx context.Context)

func (*UpdaterInstance) UpdateIfAppropriate

func (u *UpdaterInstance) UpdateIfAppropriate(h host.Host) bool

func (*UpdaterInstance) VerifyRequest

func (u *UpdaterInstance) VerifyRequest(req UpdateRequest) bool