messenger

package

Go to main page

Versions in this module

v0

v0.6.0

Dec 4, 2020

Changes in this version

type LocalSVCRouter

+ GetUnderlay func(svc addr.HostSVC) (*net.UDPAddr, error)

v0.5.0

Mar 30, 2020

Changes in this version

+ func MsgToSignedPld(msg *capnp.Message) (*ctrl.SignedPld, error)

+ func SignedPldToMsg(signedPld *ctrl.SignedPld) (*capnp.Message, error)

+ func Validate(pld *ctrl.Pld) (infra.MessageType, proto.Cerealizable, error)

type QUICHandler

+ func NewStreamHandler(parentCtx context.Context, timeout time.Duration) *QUICHandler

v0.4.0

Nov 14, 2019

Changes in this version

+ const AckRejectFailedToParse

+ const AckRejectFailedToVerify

+ const AckRejectPolicyError

+ const AckRetryDBError

+ func BuildReply(address *addr.AppAddr) *svc.Reply

+ func NextId() uint64

+ func SendAckHelper(ctx context.Context, rw infra.ResponseWriter) func(proto.Ack_ErrCode, string)

+ type AddressRewriter struct

+ Resolver Resolver

+ Router snet.Router

+ SVCResolutionFraction float64

+ SVCRouter LocalSVCRouter

+ func (r AddressRewriter) RedirectToQUIC(ctx context.Context, a net.Addr) (net.Addr, bool, error)

type Config

+ AddressRewriter *AddressRewriter

+ Dispatcher *disp.Dispatcher

+ IA addr.IA

+ Logger log.Logger

+ QUIC *QUICConfig

+ func (c *Config) InitDefaults()

+ type LocalSVCRouter interface

+ GetOverlay func(svc addr.HostSVC) (*overlay.OverlayAddr, error)

+ func NewSVCRouter(tp itopo.ProviderI) LocalSVCRouter

type Messenger

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

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

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

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

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

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

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

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

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

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

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

+ type QUICConfig struct

+ Conn net.PacketConn

+ QUICConfig *quic.Config

+ TLSConfig *tls.Config

+ type QUICHandler struct

+ func (h *QUICHandler) Handle(msgType infra.MessageType, handler infra.Handler)

+ func (h *QUICHandler) ServeRPC(rw rpc.ReplyWriter, request *rpc.Request)

+ type QUICRequester struct

+ AddressRewriter *AddressRewriter

+ QUICClientConfig *rpc.Client

+ Signer ctrl.Signer

+ func (r *QUICRequester) Request(ctx context.Context, pld *ctrl.Pld, a net.Addr) (*ctrl.Pld, error)

+ type QUICResponseWriter struct

+ ID uint64

+ ReplyWriter rpc.ReplyWriter

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

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

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

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

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

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

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

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

+ type Resolver interface

+ LookupSVC func(ctx context.Context, path snet.Path, svc addr.HostSVC) (*svc.Reply, error)

+ type UDPResponseWriter struct

+ ID uint64

+ Messenger infra.Messenger

+ Remote net.Addr

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

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

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

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

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

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

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

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

v0.3.1

Sep 24, 2018

v0.3.0

Sep 19, 2018

Changes in this version

type Messenger

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

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

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

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

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

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

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

v0.2.0

Aug 27, 2018

Changes in this version

+ func NewPathingRequester(signer ctrl.Signer, sigv ctrl.SigVerifier, d *disp.Dispatcher, local addr.IA) *pathingRequester

v0.1.1

Jul 31, 2018

Changes in this version

+ const DefaultHandlerTimeout

+ type Config struct

+ DisableSignatureVerification bool

+ HandlerTimeout time.Duration

type Messenger

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

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

+ func (m *Messenger) UpdateSigner(signer ctrl.Signer, types []infra.MessageType)

+ func (m *Messenger) UpdateVerifier(verifier ctrl.SigVerifier)

type MockMessenger

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

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

v0.1.0

Jul 19, 2018

Changes in this version

+ const Chain

+ const ChainRequest

+ const PathSegmentReply

+ const PathSegmentRequest

+ const TRC

+ const TRCRequest

+ var DefaultAdapter = &Adapter

+ type Adapter struct

+ func (a *Adapter) MsgKey(msg proto.Cerealizable) string

+ func (a *Adapter) MsgToRaw(msg proto.Cerealizable) (common.RawBytes, error)

+ func (a *Adapter) RawToMsg(b common.RawBytes) (proto.Cerealizable, error)

+ type Counter uint64

+ func (c *Counter) Next() uint64

+ type Messenger struct

+ func New(dispatcher *disp.Dispatcher, store infra.TrustStore, logger log.Logger) *Messenger

+ func (m *Messenger) AddHandler(msgType string, handler infra.Handler)

+ func (m *Messenger) CloseServer() error

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

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

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

+ func (m *Messenger) ListenAndServe()

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

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

+ type MockAddress struct

+ func (f *MockAddress) Network() string

+ func (f *MockAddress) String() string

+ type MockMessenger struct

+ Chains map[addr.IA]*cert.Chain

+ TRCs map[addr.ISD]*trc.TRC

+ func (m *MockMessenger) AddHandler(msgType string, h infra.Handler)

+ func (m *MockMessenger) CloseServer() error

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

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

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

+ func (m *MockMessenger) ListenAndServe()

+ func (m *MockMessenger) RecvMsg(ctx context.Context) (proto.Cerealizable, net.Addr, error)

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

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

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