connections

Documentation

Index

• type Connection
• type LimitedReader
  • func NewReadLimiter(r io.Reader, b *ratelimit.Bucket) *LimitedReader
  • func (r *LimitedReader) Read(buf []byte) (int, error)
• type LimitedWriter
  • func NewWriteLimiter(w io.Writer, b *ratelimit.Bucket) *LimitedWriter
  • func (w *LimitedWriter) Write(buf []byte) (int, error)
• type Model
• type Service
  • func NewService(cfg *config.Wrapper, myID protocol.DeviceID, mdl Model, tlsCfg *tls.Config, ...) *Service
  • func (s *Service) AllAddresses() []string
  • func (s *Service) CommitConfiguration(from, to config.Configuration) bool
  • func (s *Service) ExternalAddresses() []string
  • func (s *Service) Status() map[string]interface{}
  • func (s *Service) VerifyConfiguration(from, to config.Configuration) error

Types

type Connection

type Connection interface {
	protocol.Connection
	io.Closer
	Type() string
	RemoteAddr() net.Addr
}

Connection is what we expose to the outside. It is a protocol.Connection that can be closed and has some metadata.

type LimitedReader

type LimitedReader struct {
	// contains filtered or unexported fields
}

func NewReadLimiter

func NewReadLimiter(r io.Reader, b *ratelimit.Bucket) *LimitedReader

func (*LimitedReader) Read

func (r *LimitedReader) Read(buf []byte) (int, error)

type LimitedWriter

type LimitedWriter struct {
	// contains filtered or unexported fields
}

func NewWriteLimiter

func NewWriteLimiter(w io.Writer, b *ratelimit.Bucket) *LimitedWriter

func (*LimitedWriter) Write

func (w *LimitedWriter) Write(buf []byte) (int, error)

type Model

type Model interface {
	protocol.Model
	AddConnection(conn Connection, hello protocol.HelloResult)
	ConnectedTo(remoteID protocol.DeviceID) bool
	IsPaused(remoteID protocol.DeviceID) bool
	OnHello(protocol.DeviceID, net.Addr, protocol.HelloResult) error
	GetHello(protocol.DeviceID) protocol.HelloIntf
}

type Service

type Service struct {
	*suture.Supervisor
	// contains filtered or unexported fields
}

Service listens and dials all configured unconnected devices, via supported dialers. Successful connections are handed to the model.

func NewService

func NewService(cfg *config.Wrapper, myID protocol.DeviceID, mdl Model, tlsCfg *tls.Config, discoverer discover.Finder,
	bepProtocolName string, tlsDefaultCommonName string, lans []*net.IPNet) *Service

func (*Service) AllAddresses

func (s *Service) AllAddresses() []string

func (*Service) CommitConfiguration

func (s *Service) CommitConfiguration(from, to config.Configuration) bool

func (*Service) ExternalAddresses

func (s *Service) ExternalAddresses() []string

func (*Service) Status

func (s *Service) Status() map[string]interface{}

func (*Service) VerifyConfiguration

func (s *Service) VerifyConfiguration(from, to config.Configuration) error