Versions in this module Expand all Collapse all v0 v0.1.2 Jun 20, 2024 Changes in this version + func NewSession(private authentication.ECDHPrivateKey, vin string) (*session, error) + func SessionInfoRequest(domain universal.Domain, publicBytes []byte) *universal.RoutableMessage + type CacheEntry struct + CreatedAt time.Time + Domain int + SessionInfo []byte + type Dispatcher struct + func New(conn connector.Connector, privateKey authentication.ECDHPrivateKey) (*Dispatcher, error) + func (d *Dispatcher) Cache() []CacheEntry + func (d *Dispatcher) LoadCache(entries []CacheEntry) error + func (d *Dispatcher) RequestSessionInfo(ctx context.Context, domain universal.Domain) (protocol.Receiver, error) + func (d *Dispatcher) RetryInterval() time.Duration + func (d *Dispatcher) Send(ctx context.Context, message *universal.RoutableMessage, ...) (protocol.Receiver, error) + func (d *Dispatcher) SetMaxLatency(latency time.Duration) + func (d *Dispatcher) Start(ctx context.Context) error + func (d *Dispatcher) StartSession(ctx context.Context, domain universal.Domain) error + func (d *Dispatcher) StartSessions(ctx context.Context, domains []universal.Domain) error + func (d *Dispatcher) Stop()
Go to main page