infra

type Handler interface {
	Handle(*Request)
}

type HandlerFunc func(r *Request)

type Messenger interface {
	GetTRC(ctx context.Context, msg *cert_mgmt.TRCReq, a net.Addr,
		id uint64) (*cert_mgmt.TRC, error)
	SendTRC(ctx context.Context, msg *cert_mgmt.TRC, a net.Addr, id uint64) error
	GetCertChain(ctx context.Context, msg *cert_mgmt.ChainReq, a net.Addr,
		id uint64) (*cert_mgmt.Chain, error)
	SendCertChain(ctx context.Context, msg *cert_mgmt.Chain, a net.Addr, id uint64) error
	AddHandler(msgType string, h Handler)
	ListenAndServe()
	CloseServer() error
}

type Request struct {
	// The inner proto.Cerealizable message, as supported by
	// messenger.Messenger (e.g., a *cert_mgmt.ChainReq). For information about
	// possible messages, see the package documentation for that package.
	Message proto.Cerealizable
	// The top-level SignedCtrlPld message read from the wire
	FullMessage proto.Cerealizable
	// The node that sent this request
	Peer net.Addr

	ID uint64
	// contains filtered or unexported fields
}

type TrustDescriptor struct {
}

type TrustStore interface {
	StartResolvers(messenger Messenger) error
	NewTRCReqHandler() Handler
	NewChainReqHandler() Handler
	NewPushTRCHandler() Handler
	NewPushChainHandler() Handler
	GetCertificate(ctx context.Context, trail []TrustDescriptor, hint net.Addr) (*cert.Certificate, error)
}