Documentation
¶
Index ¶
- Constants
- type ACMESynchronization
- type Config
- type GossipConfig
- type Meta
- type MultiplexerConfig
- type Network
- type Server
- func (s *Server) AckPayload() []byte
- func (s *Server) Direct(ctx context.Context, link multiplexer.Link) (net.Conn, error)
- func (s *Server) Forward(ctx context.Context, conn net.Conn, link multiplexer.Link) (<-chan error, error)
- func (s *Server) GetBroadcasts(overhead, limit int) [][]byte
- func (s *Server) Gossip() error
- func (s *Server) ListenForClients()
- func (s *Server) ListenForPeers()
- func (s *Server) LocalState(join bool) []byte
- func (s *Server) MergeRemoteState(buf []byte, join bool)
- func (s *Server) NodeMeta(limit int) []byte
- func (s *Server) NotifyJoin(node *memberlist.Node)
- func (s *Server) NotifyLeave(node *memberlist.Node)
- func (s *Server) NotifyMsg(msg []byte)
- func (s *Server) NotifyPingComplete(other *memberlist.Node, rtt time.Duration, payload []byte)
- func (s *Server) NotifyUpdate(node *memberlist.Node)
- func (s *Server) PeerID() uint64
Constants ¶
View Source
const (
MetaSize = 26
)
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ACMESynchronization ¶
type ACMESynchronization struct {
From uint64
AccountFile *acme.AccountFile
Bundle *acme.Bundle
}
type Config ¶
type Config struct {
Context context.Context
Logger *zap.Logger
Network Network
PeerTLSListener net.Listener
PeerQUICListener quic.Listener
PeerTLSConfig *tls.Config
ClientTLSListener net.Listener
ClientQUICListener quic.Listener
Multiplexer MultiplexerConfig
Gossip GossipConfig
CertManager *acme.CertManager
Debug bool
Domain string
}
type GossipConfig ¶
type Meta ¶
type Meta struct {
ConnectIP string
ConnectPort uint64
PeerID uint64
Protocol protocol.Protocol
RespondOnly bool
}
func (*Meta) MarshalBinary ¶ added in v0.5.1
func (Meta) MarshalLogObject ¶ added in v0.5.0
func (m Meta) MarshalLogObject(enc zapcore.ObjectEncoder) error
func (*Meta) UnmarshalBinary ¶ added in v0.5.1
type MultiplexerConfig ¶
type Server ¶
type Server struct {
// contains filtered or unexported fields
}
func (*Server) AckPayload ¶ added in v0.5.3
func (*Server) GetBroadcasts ¶
func (*Server) ListenForClients ¶
func (s *Server) ListenForClients()
func (*Server) ListenForPeers ¶
func (s *Server) ListenForPeers()
func (*Server) LocalState ¶
func (*Server) MergeRemoteState ¶
func (*Server) NotifyJoin ¶
func (s *Server) NotifyJoin(node *memberlist.Node)
func (*Server) NotifyLeave ¶
func (s *Server) NotifyLeave(node *memberlist.Node)
func (*Server) NotifyPingComplete ¶ added in v0.5.3
func (*Server) NotifyUpdate ¶
func (s *Server) NotifyUpdate(node *memberlist.Node)
Click to show internal directories.
Click to hide internal directories.