xxdk

Dec 19, 2023

Changes in this version

+ func LocalKV(storageDir string, password []byte, rng *fastRNG.StreamGenerator) (versioned.KV, error)

+ func NewSynchronizedCmix(ndfJSON, storageDir, remoteStoragePathPrefix string, password []byte, ...) error

+ func SynchronizedKV(storageDir, remoteStoragePathPrefix string, password []byte, ...) (versioned.KV, error)

+ type ClientError struct

+ Message string

+ Source string

+ Trace string

+ type ClientErrorReport func(source, message, trace string)

type Cmix

+ func LoadSynchronizedCmix(storageDir, remoteStoragePathPrefix string, password []byte, ...) (*Cmix, error)

+ func OpenSynchronizedCmix(storageDir, remoteStoragePathPrefix string, password []byte, ...) (*Cmix, error)

+ type HealthTracker interface

+ AddChannel func(chan bool) uint64

+ AddFunc func(f func(bool)) uint64

+ IsHealthy func() bool

+ RemoveChannel func(uint64)

+ RemoveFunc func(uint64)

+ WasHealthy func() bool

+ type RoundEvents interface

+ AddRoundEvent func(rid id.Round, callback ds.RoundEventCallback, timeout time.Duration, ...) *ds.EventCallback

+ AddRoundEventChan func(rid id.Round, eventChan chan ds.EventReturn, timeout time.Duration, ...) *ds.EventCallback

+ Remove func(rid id.Round, e *ds.EventCallback)

Jan 19, 2023

Changes in this version

type Cmix

+ func (c *Cmix) SetTrackNetworkPeriod(d time.Duration)

type TransmissionIdentity

+ RSAPrivate rsa.PrivateKey

Nov 10, 2022

Changes in this version

+ const DEPENDENCIES

+ const GITVERSION

+ const SEMVER

+ const SaltSize

+ func CheckVersionAndSetupStorage(def *ndf.NetworkDefinition, storageDir string, password []byte, ...) (storage.Session, error)

+ func CompressJpeg(imgBytes []byte) ([]byte, error)

+ func CompressJpegForPreview(imgBytes []byte) ([]byte, error)

+ func DecodeGroups(ndf *ndf.NetworkDefinition) (cmixGrp, e2eGrp *cyclic.Group)

+ func DownloadAndVerifySignedNdfWithUrl(url, cert string) ([]byte, error)

+ func DownloadNdfFromGateway(address string, cert []byte) ([]byte, error)

+ func LoadSecretWithMnemonic(mnemonic, path string) (secret []byte, err error)

+ func MakeAuthCB(e2e *E2e, cbs AuthCallbacks) auth.Callbacks

+ func MakeAuthCallbacksAdapter(ac AuthCallbacks, e2e *E2e) *authCallbacksAdapter

+ func NewCmix(ndfJSON, storageDir string, password []byte, registrationCode string) error

+ func NewPrecannedCmix(precannedID uint, defJSON, storageDir string, password []byte) error

+ func NewProtoCmix_Unsafe(ndfJSON, storageDir string, password []byte, protoUser *user.Proto) error

+ func NewVanityCmix(ndfJSON, storageDir string, password []byte, registrationCode string, ...) error

+ func ParseNDF(ndfString string) (*ndf.NetworkDefinition, error)

+ func StoreReceptionIdentity(key string, identity ReceptionIdentity, net *Cmix) error

+ func StoreSecretWithMnemonic(secret []byte, path string) (string, error)

+ type AuthCallbacks interface

+ Confirm func(partner contact.Contact, receptionID receptionID.EphemeralIdentity, ...)

+ Request func(partner contact.Contact, receptionID receptionID.EphemeralIdentity, ...)

+ Reset func(partner contact.Contact, receptionID receptionID.EphemeralIdentity, ...)

+ type CMIXParams struct

+ CMIX cmix.CMIXParams

+ Network cmix.Params

+ func GetDefaultCMixParams() CMIXParams

+ func (p *CMIXParams) Marshal() ([]byte, error)

+ func (p *CMIXParams) Unmarshal(jsonData []byte) error

+ type Cmix struct

+ func LoadCmix(storageDir string, password []byte, parameters CMIXParams) (*Cmix, error)

+ func OpenCmix(storageDir string, password []byte) (*Cmix, error)

+ func (c *Cmix) AddService(sp Service) error

+ func (c *Cmix) ChangeNumberOfNodeRegistrations(toRun int, timeout time.Duration) error

+ func (c *Cmix) ConstructProtoUserFile() ([]byte, error)

+ func (c *Cmix) GetCmix() cmix.Client

+ func (c *Cmix) GetComms() *client.Comms

+ func (c *Cmix) GetErrorsChannel() <-chan interfaces.ClientError

+ func (c *Cmix) GetEventReporter() event.Reporter

+ func (c *Cmix) GetNodeRegistrationStatus() (int, int, error)

+ func (c *Cmix) GetPreferredBins(countryCode string) ([]string, error)

+ func (c *Cmix) GetRng() *fastRNG.StreamGenerator

+ func (c *Cmix) GetRoundEvents() interfaces.RoundEvents

+ func (c *Cmix) GetRunningProcesses() []string

+ func (c *Cmix) GetStorage() storage.Session

+ func (c *Cmix) GetTransmissionIdentity() TransmissionIdentity

+ func (c *Cmix) HasRunningProcessies() bool

+ func (c *Cmix) IsReady(percentReady float64) (isReady bool, howClose float64)

+ func (c *Cmix) NetworkFollowerStatus() Status

+ func (c *Cmix) PauseNodeRegistrations(timeout time.Duration) error

+ func (c *Cmix) RegisterEventCallback(name string, myFunc event.Callback) error

+ func (c *Cmix) ReportEvent(priority int, category, evtType, details string)

+ func (c *Cmix) StartNetworkFollower(timeout time.Duration) error

+ func (c *Cmix) StopNetworkFollower() error

+ func (c *Cmix) UnregisterEventCallback(name string)

+ type Container struct

+ func (bc *Container) SetBackup(triggerBackup TriggerBackup)

+ func (bc *Container) TriggerBackup(reason string)

+ type DefaultAuthCallbacks struct

+ func (a DefaultAuthCallbacks) Confirm(contact.Contact, receptionID.EphemeralIdentity, rounds.Round, *E2e)

+ func (a DefaultAuthCallbacks) Request(contact.Contact, receptionID.EphemeralIdentity, rounds.Round, *E2e)

+ func (a DefaultAuthCallbacks) Reset(contact.Contact, receptionID.EphemeralIdentity, rounds.Round, *E2e)

+ type E2EParams struct

+ Auth auth.Params

+ Base e2e.Params

+ EphemeralRekey rekey.Params

+ Rekey rekey.Params

+ Session session.Params

+ func GetDefaultE2EParams() E2EParams

+ func (p *E2EParams) Marshal() ([]byte, error)

+ func (p *E2EParams) Unmarshal(jsonData []byte) error

+ type E2e struct

+ func Login(net *Cmix, callbacks AuthCallbacks, identity ReceptionIdentity, ...) (m *E2e, err error)

+ func LoginEphemeral(net *Cmix, callbacks AuthCallbacks, identity ReceptionIdentity, ...) (m *E2e, err error)

+ func (m *E2e) ConstructProtoUserFile() ([]byte, error)

+ func (m *E2e) DeleteContact(partnerId *id.ID) error

+ func (m *E2e) DeleteContactNotify(partnerId *id.ID, params e2e.Params) error

+ func (m *E2e) GetAuth() auth.State

+ func (m *E2e) GetBackupContainer() *Container

+ func (m *E2e) GetE2E() e2e.Handler

+ func (m *E2e) GetReceptionIdentity() ReceptionIdentity

+ func (m *E2e) MakePrecannedAuthenticatedChannel(precannedID uint) (contact.Contact, error)

+ func (m *E2e) RegisterForNotifications(token string) error

+ func (m *E2e) UnregisterForNotifications() error

+ type ReceptionIdentity struct

+ DHKeyPrivate []byte

+ E2eGrp []byte

+ ID *id.ID

+ RSAPrivatePem []byte

+ Salt []byte

+ func LoadReceptionIdentity(key string, net *Cmix) (ReceptionIdentity, error)

+ func MakeLegacyReceptionIdentity(net *Cmix) (ReceptionIdentity, error)

+ func MakeReceptionIdentity(net *Cmix) (ReceptionIdentity, error)

+ func UnmarshalReceptionIdentity(marshaled []byte) (ReceptionIdentity, error)

+ func (r ReceptionIdentity) DeepCopy() ReceptionIdentity

+ func (r ReceptionIdentity) GetContact() contact.Contact

+ func (r ReceptionIdentity) GetDHKeyPrivate() (*cyclic.Int, error)

+ func (r ReceptionIdentity) GetGroup() (*cyclic.Group, error)

+ func (r ReceptionIdentity) GetRSAPrivateKey() (*rsa.PrivateKey, error)

+ func (r ReceptionIdentity) Marshal() ([]byte, error)

+ type Service func() (stoppable.Stoppable, error)

+ type Status int

+ const Running

+ const Stopped

+ const Stopping

+ func (s Status) String() string

+ type TransmissionIdentity struct

+ ID *id.ID

+ RSAPrivatePem *rsa.PrivateKey

+ RegistrationTimestamp int64

+ Salt []byte

+ func (t TransmissionIdentity) DeepCopy() TransmissionIdentity

+ type TriggerBackup func(reason string)