glue

type Connector interface {
	Halt()
	DispatchPacket(*packet.Packet)
	IsValidForwardDest(*[constants.NodeIDLength]byte) bool
	ForceUpdate()
}

type Decoy interface {
	Halt()
	OnNewDocument(*pkicache.Entry)
	OnPacket(*packet.Packet)
	ExpectReply(pkt *packet.Packet) bool
	GetStats(doPublishEpoch uint64) *loops.LoopStats
}

type Gateway interface {
	Halt()
	UserDB() userdb.UserDB
	Spool() spool.Spool
	AuthenticateClient(*wire.PeerCredentials) bool
	OnPacket(*packet.Packet)
}

type Glue interface {
	Config() *config.Config
	LogBackend() *log.Backend
	IdentityKey() sign.PrivateKey
	IdentityPublicKey() sign.PublicKey
	LinkKey() kem.PrivateKey

	MixKeys() MixKeys
	PKI() PKI
	Gateway() Gateway
	ServiceNode() ServiceNode
	Scheduler() Scheduler
	Connector() Connector
	Listeners() []Listener
	Decoy() Decoy

	ReshadowCryptoWorkers()
}

type Listener interface {
	Halt()
	CloseOldConns(interface{}) error
	GetConnIdentities() (map[[constants.RecipientIDLength]byte]interface{}, error)
	OnNewSendRatePerMinute(uint64)
	OnNewSendBurst(uint64)
}

type MixKeys interface {
	Halt()
	Generate(uint64) (bool, error)
	Prune() bool
	Get(uint64) ([]byte, bool)
	Shadow(map[uint64]*mixkey.MixKey)
}

type PKI interface {
	Halt()
	StartWorker()
	OutgoingDestinations() map[[constants.NodeIDLength]byte]*pki.MixDescriptor
	AuthenticateConnection(*wire.PeerCredentials, bool) (*pki.MixDescriptor, bool, bool)
	GetRawConsensus(uint64) ([]byte, error)
}

type Scheduler interface {
	Halt()
	OnNewMixMaxDelay(uint64)
	OnPacket(*packet.Packet)
}

type ServiceNode interface {
	Halt()
	OnPacket(*packet.Packet)
	KaetzchenForPKI() (map[string]map[string]interface{}, error)
}