infra

package

Go to main page

Versions in this module

v0

v0.4.0

Nov 14, 2019

Changes in this version

+ const ErrAdapter

+ const ErrInternal

+ const ErrLayerClosed

+ const ErrTransport

+ const PromSrcASLocal

+ const PromSrcISDLocal

+ const PromSrcISDRemote

+ const PromSrcUnknown

+ var MetricsErrInternal = &HandlerResult

+ var MetricsErrInvalid = &HandlerResult

+ var MetricsResultOk = &HandlerResult

+ var NullSigVerifier Verifier = nullSigVerifier

+ var NullSigner Signer = nullSigner

+ func NewContextWithResponseWriter(ctx context.Context, rw ResponseWriter) context.Context

+ type ASInspector interface

+ ByAttributes func(ctx context.Context, isd addr.ISD, args ASInspectorOpts) ([]addr.IA, error)

+ HasAttributes func(ctx context.Context, ia addr.IA, args ASInspectorOpts) (bool, error)

+ type ASInspectorOpts struct

+ RequiredAttributes []Attribute

+ type Attribute int

+ const Authoritative

+ const Core

+ const Issuing

+ const Voting

+ type ChainOpts struct

+ AllowInactiveTRC bool

+ type CryptoHandlerFactory interface

+ NewChainReqHandler func(recurseAllowed bool) Handler

+ NewTRCReqHandler func(recurseAllowed bool) Handler

+ type CryptoMaterialProvider interface

+ GetChain func(ctx context.Context, ia addr.IA, version scrypto.Version, opts ChainOpts) (*cert.Chain, error)

+ GetTRC func(ctx context.Context, isd addr.ISD, version scrypto.Version, opts TRCOpts) (*trc.TRC, error)

+ type Error struct

+ Message *ack.Ack

+ func (e *Error) Error() string

+ type ExtendedCryptoHandlerFactory interface

+ NewChainPushHandler func() Handler

+ NewTRCPushHandler func() Handler

+ type ExtendedTrustStore interface

type Handler

+ func NewResourceAwareHandler(handler Handler, resources ...ResourceHealth) Handler

+ type HandlerResult struct

+ Result string

+ Status string

+ func MetricsErrMsger(err error) *HandlerResult

+ func MetricsErrRevCache(err error) *HandlerResult

+ func MetricsErrTrustDB(err error) *HandlerResult

+ func MetricsErrTrustStore(err error) *HandlerResult

+ func MetricsErrWithTimeout(err error, timeoutResult, result *HandlerResult) *HandlerResult

type MessageType

+ const Ack

+ const HPCfgReply

+ const HPCfgRequest

+ const HPSegReg

+ const HPSegReply

+ const HPSegRequest

+ const IfId

+ const IfStateReq

+ const Seg

+ const SignedRev

+ func (mt MessageType) MetricLabel() string

type Messenger

+ GetHPCfgs func(ctx context.Context, msg *path_mgmt.HPCfgReq, a net.Addr, id uint64) (*path_mgmt.HPCfgReply, error)

+ GetHPSegs func(ctx context.Context, msg *path_mgmt.HPSegReq, a net.Addr, id uint64) (*path_mgmt.HPSegReply, error)

+ SendAck func(ctx context.Context, msg *ack.Ack, a net.Addr, id uint64) error

+ SendBeacon func(ctx context.Context, msg *seg.Beacon, a net.Addr, id uint64) error

+ SendHPCfgReply func(ctx context.Context, msg *path_mgmt.HPCfgReply, a net.Addr, id uint64) error

+ SendHPSegReg func(ctx context.Context, msg *path_mgmt.HPSegReg, a net.Addr, id uint64) error

+ SendHPSegReply func(ctx context.Context, msg *path_mgmt.HPSegReply, a net.Addr, id uint64) error

+ SendIfId func(ctx context.Context, msg *ifid.IFID, a net.Addr, id uint64) error

+ SendIfStateInfos func(ctx context.Context, msg *path_mgmt.IFStateInfos, a net.Addr, id uint64) error

+ SendRev func(ctx context.Context, msg *path_mgmt.SignedRevInfo, a net.Addr, id uint64) error

+ SendSegReg func(ctx context.Context, msg *path_mgmt.SegReg, a net.Addr, id uint64) error

+ UpdateSigner func(signer Signer, types []MessageType)

+ UpdateVerifier func(verifier Verifier)

+ type ResourceHealth interface

+ IsHealthy func() bool

+ Name func() string

+ type ResponseWriter interface

+ SendAckReply func(ctx context.Context, msg *ack.Ack) error

+ SendCertChainReply func(ctx context.Context, msg *cert_mgmt.Chain) error

+ SendChainIssueReply func(ctx context.Context, msg *cert_mgmt.ChainIssRep) error

+ SendHPCfgReply func(ctx context.Context, msg *path_mgmt.HPCfgReply) error

+ SendHPSegReply func(ctx context.Context, msg *path_mgmt.HPSegReply) error

+ SendIfStateInfoReply func(ctx context.Context, msg *path_mgmt.IFStateInfos) error

+ SendSegReply func(ctx context.Context, msg *path_mgmt.SegReply) error

+ SendTRCReply func(ctx context.Context, msg *cert_mgmt.TRC) error

+ func ResponseWriterFromContext(ctx context.Context) (ResponseWriter, bool)

+ type SignatureTimestampRange struct

+ MaxInFuture time.Duration

+ MaxPldAge time.Duration

+ type Signer interface

+ Meta func() SignerMeta

+ type SignerMeta struct

+ Algo string

+ ExpTime time.Time

+ Src ctrl.SignSrcDef

+ type TRCOpts struct

+ AllowInactive bool

+ type TrustStoreOpts struct

+ LocalOnly bool

+ Server net.Addr

+ type VerificationFactory interface

+ NewSigner func(key common.RawBytes, meta SignerMeta) (Signer, error)

+ NewVerifier func() Verifier

+ type Verifier interface

+ Verify func(ctx context.Context, msg common.RawBytes, sign *proto.SignS) error

+ WithIA func(ia addr.IA) Verifier

+ WithServer func(server net.Addr) Verifier

+ WithSignatureTimestampRange func(timestampRange SignatureTimestampRange) Verifier

+ WithSrc func(src ctrl.SignSrcDef) Verifier

v0.3.1

Sep 24, 2018

v0.3.0

Sep 19, 2018

Changes in this version

type MessageType

+ const IfStateInfos

+ const SegChangesIdReply

+ const SegChangesIdReq

+ const SegChangesReply

+ const SegChangesReq

+ const SegReg

+ const SegReply

+ const SegRequest

+ const SegRev

+ const SegSync

type Messenger

+ GetSegChanges func(ctx context.Context, msg *path_mgmt.SegChangesReq, a net.Addr, id uint64) (*path_mgmt.SegChangesReply, error)

+ GetSegChangesIds func(ctx context.Context, msg *path_mgmt.SegChangesIdReq, a net.Addr, id uint64) (*path_mgmt.SegChangesIdReply, error)

+ GetSegs func(ctx context.Context, msg *path_mgmt.SegReq, a net.Addr, id uint64) (*path_mgmt.SegReply, error)

+ SendSegChangesIdReply func(ctx context.Context, msg *path_mgmt.SegChangesIdReply, a net.Addr, id uint64) error

+ SendSegChangesReply func(ctx context.Context, msg *path_mgmt.SegChangesReply, a net.Addr, id uint64) error

+ SendSegReply func(ctx context.Context, msg *path_mgmt.SegReply, a net.Addr, id uint64) error

+ SendSegSync func(ctx context.Context, msg *path_mgmt.SegSync, a net.Addr, id uint64) error

v0.2.0

Aug 27, 2018

Changes in this version

type Request

+ Logger log.Logger

type TrustStore

+ GetValidCachedTRC func(ctx context.Context, isd addr.ISD) (*trc.TRC, error)

v0.1.1

Jul 31, 2018

Changes in this version

+ type MessageType int

+ const Chain

+ const ChainIssueReply

+ const ChainIssueRequest

+ const ChainRequest

+ const None

+ const PathSegmentReply

+ const PathSegmentRequest

+ const TRC

+ const TRCRequest

+ func (mt MessageType) String() string

type Messenger

+ RequestChainIssue func(ctx context.Context, msg *cert_mgmt.ChainIssReq, a net.Addr, id uint64) (*cert_mgmt.ChainIssRep, error)

+ SendChainIssueReply func(ctx context.Context, msg *cert_mgmt.ChainIssRep, a net.Addr, id uint64) error

v0.1.0

Jul 19, 2018

Changes in this version

+ const StrAdapterError

+ const StrClosedError

+ const StrCtxDoneError

+ const StrInternalError

+ const StrTransportError

+ func NewContextWithMessenger(ctx context.Context, msger Messenger) context.Context

+ func NewCtxDoneError(ctx ...interface{}) error

+ type Handler interface

+ Handle func(*Request)

+ type HandlerFunc func(r *Request)

+ func (f HandlerFunc) Handle(r *Request)

+ type Messenger interface

+ AddHandler func(msgType string, h Handler)

+ CloseServer func() error

+ GetCertChain func(ctx context.Context, msg *cert_mgmt.ChainReq, a net.Addr, id uint64) (*cert_mgmt.Chain, error)

+ GetPathSegs func(ctx context.Context, msg *path_mgmt.SegReq, a net.Addr, id uint64) (*path_mgmt.SegReply, error)

+ GetTRC func(ctx context.Context, msg *cert_mgmt.TRCReq, a net.Addr, id uint64) (*cert_mgmt.TRC, error)

+ ListenAndServe func()

+ SendCertChain func(ctx context.Context, msg *cert_mgmt.Chain, a net.Addr, id uint64) error

+ SendTRC func(ctx context.Context, msg *cert_mgmt.TRC, a net.Addr, id uint64) error

+ func MessengerFromContext(ctx context.Context) (Messenger, bool)

+ type Request struct

+ FullMessage proto.Cerealizable

+ ID uint64

+ Message proto.Cerealizable

+ Peer net.Addr

+ func NewRequest(ctx context.Context, msg, fullMsg proto.Cerealizable, peer net.Addr, id uint64) *Request

+ func (r *Request) Context() context.Context

+ type Transport interface

+ Close func(context.Context) error

+ RecvFrom func(context.Context) (common.RawBytes, net.Addr, error)

+ SendMsgTo func(context.Context, common.RawBytes, net.Addr) error

+ SendUnreliableMsgTo func(context.Context, common.RawBytes, net.Addr) error

+ type TrustStore interface

+ GetChain func(ctx context.Context, ia addr.IA, version uint64) (*cert.Chain, error)

+ GetTRC func(ctx context.Context, isd addr.ISD, version uint64) (*trc.TRC, error)

+ GetValidChain func(ctx context.Context, ia addr.IA, trail ...addr.ISD) (*cert.Chain, error)

+ GetValidTRC func(ctx context.Context, isd addr.ISD, trail ...addr.ISD) (*trc.TRC, error)

+ NewChainReqHandler func(recurseAllowed bool) Handler

+ NewTRCReqHandler func(recurseAllowed bool) Handler

+ SetMessenger func(msger Messenger)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL