evilnet

package
v0.0.0-...-b569211 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 9, 2020 License: MIT Imports: 12 Imported by: 0

Documentation

Index

Constants

View Source
const (
	MSG_MAX_SIZE         int    = math.MaxInt16
	CONN_MSG_BUFFER_SIZE int    = 100 * 1024
	CONN_MSG_LIST_SIZE   int    = 100
	MSG_RC4_KEY          string = "deadbeef"
)

Variables

View Source
var EvilNetMsg_TYPE_name = map[int32]string{
	0: "REQREG",
	1: "RSPREG",
	2: "ROUTER",
	3: "REQCONN",
	4: "RSPCONN",
	5: "PING",
	6: "PONG",
}
View Source
var EvilNetMsg_TYPE_value = map[string]int32{
	"REQREG":  0,
	"RSPREG":  1,
	"ROUTER":  2,
	"REQCONN": 3,
	"RSPCONN": 4,
	"PING":    5,
	"PONG":    6,
}

Functions

This section is empty.

Types

type EvilNet

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

func NewEvilNet

func NewEvilNet(plugins []PluginCreator, config *EvilNetConfig) *EvilNet

func (*EvilNet) Connect

func (ev *EvilNet) Connect(rpcid string, dst string, eproto string, param []string, timeoutms int)

func (*EvilNet) GetSonConnNum

func (ev *EvilNet) GetSonConnNum() int

func (*EvilNet) Globalname

func (ev *EvilNet) Globalname() string

func (*EvilNet) IsFatherConnected

func (ev *EvilNet) IsFatherConnected() bool

func (*EvilNet) Ping

func (ev *EvilNet) Ping(rpcid string, dst string)

func (*EvilNet) Run

func (ev *EvilNet) Run() error

func (*EvilNet) SendTo

func (ev *EvilNet) SendTo(conn *rudp.Conn, data []byte)

func (*EvilNet) Stop

func (ev *EvilNet) Stop()

type EvilNetConfig

type EvilNetConfig struct {
	Name string

	ListenSonPort int
	ListenOutPort int
	Fatheraddr    string

	RegFatherInterSec int

	Key        string
	FatherKey  string
	ConnectKey string

	Rudpconfig rudp.ConnConfig
}

func (*EvilNetConfig) Check

func (evc *EvilNetConfig) Check()

type EvilNetMsg

type EvilNetMsg struct {
	Type                 int32              `protobuf:"varint,1,opt,name=type,proto3" json:"type,omitempty"`
	ReqRegMsg            *EvilNetReqRegMsg  `protobuf:"bytes,2,opt,name=reqRegMsg,proto3" json:"reqRegMsg,omitempty"`
	RspRegMsg            *EvilNetRspRegMsg  `protobuf:"bytes,3,opt,name=rspRegMsg,proto3" json:"rspRegMsg,omitempty"`
	RouterMsg            *EvilNetRouterMsg  `protobuf:"bytes,4,opt,name=routerMsg,proto3" json:"routerMsg,omitempty"`
	ReqConnMsg           *EvilNetReqConnMsg `protobuf:"bytes,5,opt,name=reqConnMsg,proto3" json:"reqConnMsg,omitempty"`
	RspConnMsg           *EvilNetRspConnMsg `protobuf:"bytes,6,opt,name=rspConnMsg,proto3" json:"rspConnMsg,omitempty"`
	PingMsg              *EvilNetPingMsg    `protobuf:"bytes,7,opt,name=pingMsg,proto3" json:"pingMsg,omitempty"`
	PongMsg              *EvilNetPongMsg    `protobuf:"bytes,8,opt,name=pongMsg,proto3" json:"pongMsg,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*EvilNetMsg) Descriptor

func (*EvilNetMsg) Descriptor() ([]byte, []int)

func (*EvilNetMsg) GetPingMsg

func (m *EvilNetMsg) GetPingMsg() *EvilNetPingMsg

func (*EvilNetMsg) GetPongMsg

func (m *EvilNetMsg) GetPongMsg() *EvilNetPongMsg

func (*EvilNetMsg) GetReqConnMsg

func (m *EvilNetMsg) GetReqConnMsg() *EvilNetReqConnMsg

func (*EvilNetMsg) GetReqRegMsg

func (m *EvilNetMsg) GetReqRegMsg() *EvilNetReqRegMsg

func (*EvilNetMsg) GetRouterMsg

func (m *EvilNetMsg) GetRouterMsg() *EvilNetRouterMsg

func (*EvilNetMsg) GetRspConnMsg

func (m *EvilNetMsg) GetRspConnMsg() *EvilNetRspConnMsg

func (*EvilNetMsg) GetRspRegMsg

func (m *EvilNetMsg) GetRspRegMsg() *EvilNetRspRegMsg

func (*EvilNetMsg) GetType

func (m *EvilNetMsg) GetType() int32

func (*EvilNetMsg) ProtoMessage

func (*EvilNetMsg) ProtoMessage()

func (*EvilNetMsg) Reset

func (m *EvilNetMsg) Reset()

func (*EvilNetMsg) String

func (m *EvilNetMsg) String() string

func (*EvilNetMsg) XXX_DiscardUnknown

func (m *EvilNetMsg) XXX_DiscardUnknown()

func (*EvilNetMsg) XXX_Marshal

func (m *EvilNetMsg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EvilNetMsg) XXX_Merge

func (m *EvilNetMsg) XXX_Merge(src proto.Message)

func (*EvilNetMsg) XXX_Size

func (m *EvilNetMsg) XXX_Size() int

func (*EvilNetMsg) XXX_Unmarshal

func (m *EvilNetMsg) XXX_Unmarshal(b []byte) error

type EvilNetMsg_TYPE

type EvilNetMsg_TYPE int32
const (
	EvilNetMsg_REQREG  EvilNetMsg_TYPE = 0
	EvilNetMsg_RSPREG  EvilNetMsg_TYPE = 1
	EvilNetMsg_ROUTER  EvilNetMsg_TYPE = 2
	EvilNetMsg_REQCONN EvilNetMsg_TYPE = 3
	EvilNetMsg_RSPCONN EvilNetMsg_TYPE = 4
	EvilNetMsg_PING    EvilNetMsg_TYPE = 5
	EvilNetMsg_PONG    EvilNetMsg_TYPE = 6
)

func (EvilNetMsg_TYPE) EnumDescriptor

func (EvilNetMsg_TYPE) EnumDescriptor() ([]byte, []int)

func (EvilNetMsg_TYPE) String

func (x EvilNetMsg_TYPE) String() string

type EvilNetPingMsg

type EvilNetPingMsg struct {
	Time                 int64    `protobuf:"varint,1,opt,name=time,proto3" json:"time,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*EvilNetPingMsg) Descriptor

func (*EvilNetPingMsg) Descriptor() ([]byte, []int)

func (*EvilNetPingMsg) GetTime

func (m *EvilNetPingMsg) GetTime() int64

func (*EvilNetPingMsg) ProtoMessage

func (*EvilNetPingMsg) ProtoMessage()

func (*EvilNetPingMsg) Reset

func (m *EvilNetPingMsg) Reset()

func (*EvilNetPingMsg) String

func (m *EvilNetPingMsg) String() string

func (*EvilNetPingMsg) XXX_DiscardUnknown

func (m *EvilNetPingMsg) XXX_DiscardUnknown()

func (*EvilNetPingMsg) XXX_Marshal

func (m *EvilNetPingMsg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EvilNetPingMsg) XXX_Merge

func (m *EvilNetPingMsg) XXX_Merge(src proto.Message)

func (*EvilNetPingMsg) XXX_Size

func (m *EvilNetPingMsg) XXX_Size() int

func (*EvilNetPingMsg) XXX_Unmarshal

func (m *EvilNetPingMsg) XXX_Unmarshal(b []byte) error

type EvilNetPongMsg

type EvilNetPongMsg struct {
	Time                 int64    `protobuf:"varint,1,opt,name=time,proto3" json:"time,omitempty"`
	Proto                []string `protobuf:"bytes,2,rep,name=proto,proto3" json:"proto,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*EvilNetPongMsg) Descriptor

func (*EvilNetPongMsg) Descriptor() ([]byte, []int)

func (*EvilNetPongMsg) GetProto

func (m *EvilNetPongMsg) GetProto() []string

func (*EvilNetPongMsg) GetTime

func (m *EvilNetPongMsg) GetTime() int64

func (*EvilNetPongMsg) ProtoMessage

func (*EvilNetPongMsg) ProtoMessage()

func (*EvilNetPongMsg) Reset

func (m *EvilNetPongMsg) Reset()

func (*EvilNetPongMsg) String

func (m *EvilNetPongMsg) String() string

func (*EvilNetPongMsg) XXX_DiscardUnknown

func (m *EvilNetPongMsg) XXX_DiscardUnknown()

func (*EvilNetPongMsg) XXX_Marshal

func (m *EvilNetPongMsg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EvilNetPongMsg) XXX_Merge

func (m *EvilNetPongMsg) XXX_Merge(src proto.Message)

func (*EvilNetPongMsg) XXX_Size

func (m *EvilNetPongMsg) XXX_Size() int

func (*EvilNetPongMsg) XXX_Unmarshal

func (m *EvilNetPongMsg) XXX_Unmarshal(b []byte) error

type EvilNetReqConnMsg

type EvilNetReqConnMsg struct {
	Key                  string   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Proto                string   `protobuf:"bytes,2,opt,name=proto,proto3" json:"proto,omitempty"`
	Localaddr            string   `protobuf:"bytes,3,opt,name=localaddr,proto3" json:"localaddr,omitempty"`
	Globaladdr           string   `protobuf:"bytes,4,opt,name=globaladdr,proto3" json:"globaladdr,omitempty"`
	Param                []string `protobuf:"bytes,5,rep,name=param,proto3" json:"param,omitempty"`
	Randomkey            string   `protobuf:"bytes,6,opt,name=randomkey,proto3" json:"randomkey,omitempty"`
	Timeoutms            int32    `protobuf:"varint,7,opt,name=timeoutms,proto3" json:"timeoutms,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*EvilNetReqConnMsg) Descriptor

func (*EvilNetReqConnMsg) Descriptor() ([]byte, []int)

func (*EvilNetReqConnMsg) GetGlobaladdr

func (m *EvilNetReqConnMsg) GetGlobaladdr() string

func (*EvilNetReqConnMsg) GetKey

func (m *EvilNetReqConnMsg) GetKey() string

func (*EvilNetReqConnMsg) GetLocaladdr

func (m *EvilNetReqConnMsg) GetLocaladdr() string

func (*EvilNetReqConnMsg) GetParam

func (m *EvilNetReqConnMsg) GetParam() []string

func (*EvilNetReqConnMsg) GetProto

func (m *EvilNetReqConnMsg) GetProto() string

func (*EvilNetReqConnMsg) GetRandomkey

func (m *EvilNetReqConnMsg) GetRandomkey() string

func (*EvilNetReqConnMsg) GetTimeoutms

func (m *EvilNetReqConnMsg) GetTimeoutms() int32

func (*EvilNetReqConnMsg) ProtoMessage

func (*EvilNetReqConnMsg) ProtoMessage()

func (*EvilNetReqConnMsg) Reset

func (m *EvilNetReqConnMsg) Reset()

func (*EvilNetReqConnMsg) String

func (m *EvilNetReqConnMsg) String() string

func (*EvilNetReqConnMsg) XXX_DiscardUnknown

func (m *EvilNetReqConnMsg) XXX_DiscardUnknown()

func (*EvilNetReqConnMsg) XXX_Marshal

func (m *EvilNetReqConnMsg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EvilNetReqConnMsg) XXX_Merge

func (m *EvilNetReqConnMsg) XXX_Merge(src proto.Message)

func (*EvilNetReqConnMsg) XXX_Size

func (m *EvilNetReqConnMsg) XXX_Size() int

func (*EvilNetReqConnMsg) XXX_Unmarshal

func (m *EvilNetReqConnMsg) XXX_Unmarshal(b []byte) error

type EvilNetReqRegMsg

type EvilNetReqRegMsg struct {
	Key                  string   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Sonkey               string   `protobuf:"bytes,2,opt,name=sonkey,proto3" json:"sonkey,omitempty"`
	Name                 string   `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	Localaddr            string   `protobuf:"bytes,4,opt,name=localaddr,proto3" json:"localaddr,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*EvilNetReqRegMsg) Descriptor

func (*EvilNetReqRegMsg) Descriptor() ([]byte, []int)

func (*EvilNetReqRegMsg) GetKey

func (m *EvilNetReqRegMsg) GetKey() string

func (*EvilNetReqRegMsg) GetLocaladdr

func (m *EvilNetReqRegMsg) GetLocaladdr() string

func (*EvilNetReqRegMsg) GetName

func (m *EvilNetReqRegMsg) GetName() string

func (*EvilNetReqRegMsg) GetSonkey

func (m *EvilNetReqRegMsg) GetSonkey() string

func (*EvilNetReqRegMsg) ProtoMessage

func (*EvilNetReqRegMsg) ProtoMessage()

func (*EvilNetReqRegMsg) Reset

func (m *EvilNetReqRegMsg) Reset()

func (*EvilNetReqRegMsg) String

func (m *EvilNetReqRegMsg) String() string

func (*EvilNetReqRegMsg) XXX_DiscardUnknown

func (m *EvilNetReqRegMsg) XXX_DiscardUnknown()

func (*EvilNetReqRegMsg) XXX_Marshal

func (m *EvilNetReqRegMsg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EvilNetReqRegMsg) XXX_Merge

func (m *EvilNetReqRegMsg) XXX_Merge(src proto.Message)

func (*EvilNetReqRegMsg) XXX_Size

func (m *EvilNetReqRegMsg) XXX_Size() int

func (*EvilNetReqRegMsg) XXX_Unmarshal

func (m *EvilNetReqRegMsg) XXX_Unmarshal(b []byte) error

type EvilNetRouterMsg

type EvilNetRouterMsg struct {
	Src                  string   `protobuf:"bytes,1,opt,name=src,proto3" json:"src,omitempty"`
	Dst                  string   `protobuf:"bytes,2,opt,name=dst,proto3" json:"dst,omitempty"`
	Data                 []byte   `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	Id                   string   `protobuf:"bytes,4,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*EvilNetRouterMsg) Descriptor

func (*EvilNetRouterMsg) Descriptor() ([]byte, []int)

func (*EvilNetRouterMsg) GetData

func (m *EvilNetRouterMsg) GetData() []byte

func (*EvilNetRouterMsg) GetDst

func (m *EvilNetRouterMsg) GetDst() string

func (*EvilNetRouterMsg) GetId

func (m *EvilNetRouterMsg) GetId() string

func (*EvilNetRouterMsg) GetSrc

func (m *EvilNetRouterMsg) GetSrc() string

func (*EvilNetRouterMsg) ProtoMessage

func (*EvilNetRouterMsg) ProtoMessage()

func (*EvilNetRouterMsg) Reset

func (m *EvilNetRouterMsg) Reset()

func (*EvilNetRouterMsg) String

func (m *EvilNetRouterMsg) String() string

func (*EvilNetRouterMsg) XXX_DiscardUnknown

func (m *EvilNetRouterMsg) XXX_DiscardUnknown()

func (*EvilNetRouterMsg) XXX_Marshal

func (m *EvilNetRouterMsg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EvilNetRouterMsg) XXX_Merge

func (m *EvilNetRouterMsg) XXX_Merge(src proto.Message)

func (*EvilNetRouterMsg) XXX_Size

func (m *EvilNetRouterMsg) XXX_Size() int

func (*EvilNetRouterMsg) XXX_Unmarshal

func (m *EvilNetRouterMsg) XXX_Unmarshal(b []byte) error

type EvilNetRspConnMsg

type EvilNetRspConnMsg struct {
	Key                  string   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Proto                string   `protobuf:"bytes,2,opt,name=proto,proto3" json:"proto,omitempty"`
	Result               string   `protobuf:"bytes,3,opt,name=result,proto3" json:"result,omitempty"`
	Localaddr            string   `protobuf:"bytes,4,opt,name=localaddr,proto3" json:"localaddr,omitempty"`
	Globaladdr           string   `protobuf:"bytes,5,opt,name=globaladdr,proto3" json:"globaladdr,omitempty"`
	Param                []string `protobuf:"bytes,6,rep,name=param,proto3" json:"param,omitempty"`
	Randomkey            string   `protobuf:"bytes,7,opt,name=randomkey,proto3" json:"randomkey,omitempty"`
	Timeoutms            int32    `protobuf:"varint,8,opt,name=timeoutms,proto3" json:"timeoutms,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*EvilNetRspConnMsg) Descriptor

func (*EvilNetRspConnMsg) Descriptor() ([]byte, []int)

func (*EvilNetRspConnMsg) GetGlobaladdr

func (m *EvilNetRspConnMsg) GetGlobaladdr() string

func (*EvilNetRspConnMsg) GetKey

func (m *EvilNetRspConnMsg) GetKey() string

func (*EvilNetRspConnMsg) GetLocaladdr

func (m *EvilNetRspConnMsg) GetLocaladdr() string

func (*EvilNetRspConnMsg) GetParam

func (m *EvilNetRspConnMsg) GetParam() []string

func (*EvilNetRspConnMsg) GetProto

func (m *EvilNetRspConnMsg) GetProto() string

func (*EvilNetRspConnMsg) GetRandomkey

func (m *EvilNetRspConnMsg) GetRandomkey() string

func (*EvilNetRspConnMsg) GetResult

func (m *EvilNetRspConnMsg) GetResult() string

func (*EvilNetRspConnMsg) GetTimeoutms

func (m *EvilNetRspConnMsg) GetTimeoutms() int32

func (*EvilNetRspConnMsg) ProtoMessage

func (*EvilNetRspConnMsg) ProtoMessage()

func (*EvilNetRspConnMsg) Reset

func (m *EvilNetRspConnMsg) Reset()

func (*EvilNetRspConnMsg) String

func (m *EvilNetRspConnMsg) String() string

func (*EvilNetRspConnMsg) XXX_DiscardUnknown

func (m *EvilNetRspConnMsg) XXX_DiscardUnknown()

func (*EvilNetRspConnMsg) XXX_Marshal

func (m *EvilNetRspConnMsg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EvilNetRspConnMsg) XXX_Merge

func (m *EvilNetRspConnMsg) XXX_Merge(src proto.Message)

func (*EvilNetRspConnMsg) XXX_Size

func (m *EvilNetRspConnMsg) XXX_Size() int

func (*EvilNetRspConnMsg) XXX_Unmarshal

func (m *EvilNetRspConnMsg) XXX_Unmarshal(b []byte) error

type EvilNetRspRegMsg

type EvilNetRspRegMsg struct {
	Sonkey               string   `protobuf:"bytes,1,opt,name=sonkey,proto3" json:"sonkey,omitempty"`
	Fathername           string   `protobuf:"bytes,2,opt,name=fathername,proto3" json:"fathername,omitempty"`
	Newname              string   `protobuf:"bytes,3,opt,name=newname,proto3" json:"newname,omitempty"`
	Localaddr            string   `protobuf:"bytes,4,opt,name=localaddr,proto3" json:"localaddr,omitempty"`
	Globaladdr           string   `protobuf:"bytes,5,opt,name=globaladdr,proto3" json:"globaladdr,omitempty"`
	Result               string   `protobuf:"bytes,6,opt,name=result,proto3" json:"result,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*EvilNetRspRegMsg) Descriptor

func (*EvilNetRspRegMsg) Descriptor() ([]byte, []int)

func (*EvilNetRspRegMsg) GetFathername

func (m *EvilNetRspRegMsg) GetFathername() string

func (*EvilNetRspRegMsg) GetGlobaladdr

func (m *EvilNetRspRegMsg) GetGlobaladdr() string

func (*EvilNetRspRegMsg) GetLocaladdr

func (m *EvilNetRspRegMsg) GetLocaladdr() string

func (*EvilNetRspRegMsg) GetNewname

func (m *EvilNetRspRegMsg) GetNewname() string

func (*EvilNetRspRegMsg) GetResult

func (m *EvilNetRspRegMsg) GetResult() string

func (*EvilNetRspRegMsg) GetSonkey

func (m *EvilNetRspRegMsg) GetSonkey() string

func (*EvilNetRspRegMsg) ProtoMessage

func (*EvilNetRspRegMsg) ProtoMessage()

func (*EvilNetRspRegMsg) Reset

func (m *EvilNetRspRegMsg) Reset()

func (*EvilNetRspRegMsg) String

func (m *EvilNetRspRegMsg) String() string

func (*EvilNetRspRegMsg) XXX_DiscardUnknown

func (m *EvilNetRspRegMsg) XXX_DiscardUnknown()

func (*EvilNetRspRegMsg) XXX_Marshal

func (m *EvilNetRspRegMsg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EvilNetRspRegMsg) XXX_Merge

func (m *EvilNetRspRegMsg) XXX_Merge(src proto.Message)

func (*EvilNetRspRegMsg) XXX_Size

func (m *EvilNetRspRegMsg) XXX_Size() int

func (*EvilNetRspRegMsg) XXX_Unmarshal

func (m *EvilNetRspRegMsg) XXX_Unmarshal(b []byte) error

type EvilNetSon

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

type Plugin

type Plugin interface {
	Close(ev *EvilNet, conn *rudp.Conn)
	IsClose(ev *EvilNet, conn *rudp.Conn) bool

	OnConnected(ev *EvilNet, conn *rudp.Conn)
	OnRecv(ev *EvilNet, conn *rudp.Conn, data []byte)
	OnClose(ev *EvilNet, conn *rudp.Conn)
}

type PluginCreator

type PluginCreator interface {
	Name() string
	Create() Plugin
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL