conn_store

Documentation

Index

• Variables
• type Conn
• type ConnInstance
  • func (c *ConnInstance) Aes() aes_store.Key
  • func (c *ConnInstance) IP() string
  • func (c *ConnInstance) LastUsed() time.Time
  • func (c *ConnInstance) Name() string
  • func (c *ConnInstance) Stop()
  • func (c *ConnInstance) WriteTCP(pkt packet.TcpPacket) error
  • func (c *ConnInstance) WriteUDP(pkt packet.TcpPacket) error
• type ConnStore
  • func (c *ConnStore) Get(ip string) Conn
  • func (c *ConnStore) New(ip string) Conn
  • func (c *ConnStore) Stop(ip string)
• type MockConnInstance
  • func (c MockConnInstance) Aes() aes_store.Key
  • func (c MockConnInstance) IP() string
  • func (c MockConnInstance) LastUsed() time.Time
  • func (c MockConnInstance) Name() string
  • func (c MockConnInstance) Stop()
  • func (c MockConnInstance) WriteTCP(pkt packet.TcpPacket) error
  • func (c MockConnInstance) WriteUDP(pkt packet.TcpPacket) error
• type MockConnStore
  • func (c MockConnStore) Get(ip string) Conn
  • func (c MockConnStore) New(ip string) Conn
  • func (c MockConnStore) Stop(ip string)
• type Store
  • func New(nodes node_store.Store, ourIP *string) Store

Variables

var ErrNoRoute = fmt.Errorf("unable to route")

Types

type Conn

type Conn interface {
	Aes() aes_store.Key
	WriteUDP(pkt packet.TcpPacket) error
	WriteTCP(pkt packet.TcpPacket) error
	LastUsed() time.Time
	IP() string
	Name() string
	Stop()
}

type ConnInstance

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

func (*ConnInstance) Aes

func (c *ConnInstance) Aes() aes_store.Key

func (*ConnInstance) IP

func (c *ConnInstance) IP() string

func (*ConnInstance) LastUsed

func (c *ConnInstance) LastUsed() time.Time

func (*ConnInstance) Name

func (c *ConnInstance) Name() string

func (*ConnInstance) Stop

func (c *ConnInstance) Stop()

func (*ConnInstance) WriteTCP

func (c *ConnInstance) WriteTCP(pkt packet.TcpPacket) error

func (*ConnInstance) WriteUDP

func (c *ConnInstance) WriteUDP(pkt packet.TcpPacket) error

type ConnStore

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

func (*ConnStore) Get

func (c *ConnStore) Get(ip string) Conn

func (*ConnStore) New

func (c *ConnStore) New(ip string) Conn

func (*ConnStore) Stop

func (c *ConnStore) Stop(ip string)

type MockConnInstance

type MockConnInstance struct {
	AesFunc      func() aes_store.Key
	WriteUDPFunc func(pkt packet.TcpPacket) error
	WriteTCPFunc func(pkt packet.TcpPacket) error
	LastUsedFunc func() time.Time
	IPFunc       func() string
	NameFunc     func() string
	StopFunc     func()
}

func (MockConnInstance) Aes

func (c MockConnInstance) Aes() aes_store.Key

func (MockConnInstance) IP

func (c MockConnInstance) IP() string

func (MockConnInstance) LastUsed

func (c MockConnInstance) LastUsed() time.Time

func (MockConnInstance) Name

func (c MockConnInstance) Name() string

func (MockConnInstance) Stop

func (c MockConnInstance) Stop()

func (MockConnInstance) WriteTCP

func (c MockConnInstance) WriteTCP(pkt packet.TcpPacket) error

func (MockConnInstance) WriteUDP

func (c MockConnInstance) WriteUDP(pkt packet.TcpPacket) error

type MockConnStore

type MockConnStore struct {
	StopFunc func(ip string)
	GetFunc  func(ip string) Conn
	NewFunc  func(ip string) Conn
}

func (MockConnStore) Get

func (c MockConnStore) Get(ip string) Conn

func (MockConnStore) New

func (c MockConnStore) New(ip string) Conn

func (MockConnStore) Stop

func (c MockConnStore) Stop(ip string)

type Store

type Store interface {
	Stop(ip string)
	Get(ip string) Conn
	New(ip string) Conn
}

func New

func New(nodes node_store.Store, ourIP *string) Store