mocks

Documentation

Index

• type Config
  • func (config *Config) InboundConfig() core.ConnectionConfig
  • func (config *Config) OutboundConfig() core.ConnectionConfig
  • func (config *Config) Port() uint16
• type ConnectionConfig
  • func (config *ConnectionConfig) Content() []byte
  • func (config *ConnectionConfig) Protocol() string
• type InboundConnectionHandler
  • func (handler *InboundConnectionHandler) Communicate(packet v2net.Packet) error
  • func (handler *InboundConnectionHandler) Create(point *core.Point, config []byte) (core.InboundConnectionHandler, error)
  • func (handler *InboundConnectionHandler) Listen(port uint16) error
• type MockUserSet
  • func (us *MockUserSet) AddUser(user user.User) error
  • func (us *MockUserSet) GetUser(userhash []byte) (*user.ID, int64, bool)
• type OutboundConnectionHandler
  • func (handler *OutboundConnectionHandler) Create(point *core.Point, packet v2net.Packet) (core.OutboundConnectionHandler, error)
  • func (handler *OutboundConnectionHandler) Initialize(config []byte) error
  • func (handler *OutboundConnectionHandler) Start(ray core.OutboundRay) error

Types

type Config

type Config struct {
	PortValue           uint16
	InboundConfigValue  *ConnectionConfig
	OutboundConfigValue *ConnectionConfig
}

func (*Config) InboundConfig

func (config *Config) InboundConfig() core.ConnectionConfig

func (*Config) OutboundConfig

func (config *Config) OutboundConfig() core.ConnectionConfig

func (*Config) Port

func (config *Config) Port() uint16

type ConnectionConfig

type ConnectionConfig struct {
	ProtocolValue string
	ContentValue  []byte
}

func (*ConnectionConfig) Content

func (config *ConnectionConfig) Content() []byte

func (*ConnectionConfig) Protocol

func (config *ConnectionConfig) Protocol() string

type InboundConnectionHandler

type InboundConnectionHandler struct {
	Data2Send    []byte
	DataReturned *bytes.Buffer
	Port         uint16
	Server       *core.Point
}

func (*InboundConnectionHandler) Communicate

func (handler *InboundConnectionHandler) Communicate(packet v2net.Packet) error

func (*InboundConnectionHandler) Create

func (handler *InboundConnectionHandler) Create(point *core.Point, config []byte) (core.InboundConnectionHandler, error)

func (*InboundConnectionHandler) Listen

func (handler *InboundConnectionHandler) Listen(port uint16) error

type MockUserSet

type MockUserSet struct {
	UserIds    []user.ID
	UserHashes map[string]int
	Timestamps map[string]int64
}

func (*MockUserSet) AddUser

func (us *MockUserSet) AddUser(user user.User) error

func (*MockUserSet) GetUser

func (us *MockUserSet) GetUser(userhash []byte) (*user.ID, int64, bool)

type OutboundConnectionHandler

type OutboundConnectionHandler struct {
	Data2Send   *bytes.Buffer
	Data2Return []byte
	Destination v2net.Destination
}

func (*OutboundConnectionHandler) Create

func (handler *OutboundConnectionHandler) Create(point *core.Point, packet v2net.Packet) (core.OutboundConnectionHandler, error)

func (*OutboundConnectionHandler) Initialize

func (handler *OutboundConnectionHandler) Initialize(config []byte) error

func (*OutboundConnectionHandler) Start

func (handler *OutboundConnectionHandler) Start(ray core.OutboundRay) error