event

Documentation

Overview

Package event is a generated GoMock package.

Index

• type AcceptProcess
• type BootClient
  • func NewBootClient() *BootClient
  • func NewBootClientContext(ctx context.Context) *BootClient
  • func (b *BootClient) CancelFunc()
  • func (b *BootClient) Dial(network string, addr string) (StarterClient, error)
  • func (b *BootClient) DialTcp(addr string) (StarterClient, error)
  • func (b *BootClient) DialTcpTimeout(addr string, timeout time.Duration) (StarterClient, error)
  • func (b *BootClient) DialTimeout(network string, addr string, timeout time.Duration) (StarterClient, error)
  • func (b *BootClient) DialUdp(addr string) (StarterClient, error)
  • func (b *BootClient) DialUdpTimeout(addr string, timeout time.Duration) (StarterClient, error)
• type BootServer
  • func NewBootServer() *BootServer
  • func NewBootServerContext(ctx context.Context) *BootServer
  • func (b *BootServer) BindAddr(network string, addr string) error
  • func (b *BootServer) CancelFunc()
  • func (b *BootServer) ListenTcp(addr string) error
  • func (b *BootServer) ListenUdp(addr string) error
  • func (b *BootServer) Starter() StarterServer
  • func (b *BootServer) Stop() error
• type DisconnectProcess
• type Event
  • func NewEvent() *Event
  • func (e *Event) ProcessList() []interface{}
  • func (e *Event) Register(proc Process)
  • func (e *Event) RegisterPlus(proc any) error
  • func (e *Event) UnRegister(proc Process)
• type MockProcess
  • func NewMockProcess(ctrl *gomock.Controller) *MockProcess
  • func (m *MockProcess) Accept(session *Session) error
  • func (m *MockProcess) Active(session *Session, value any) (any, error)
  • func (m *MockProcess) Disconnect(session *Session) error
  • func (m *MockProcess) EXPECT() *MockProcessMockRecorder
• type MockProcessMockRecorder
  • func (mr *MockProcessMockRecorder) Accept(session any) *gomock.Call
  • func (mr *MockProcessMockRecorder) Active(session, value any) *gomock.Call
  • func (mr *MockProcessMockRecorder) Disconnect(session any) *gomock.Call
• type Process
• type Session
  • func NewSession(socket *socket.Socket) *Session
  • func NewSessionContext(socket *socket.Socket, ctx context.Context) *Session
  • func (s *Session) CancelFunc()
  • func (s *Session) Close() error
  • func (s *Session) Ctx() context.Context
  • func (s *Session) GetAttr(key string) any
  • func (s *Session) SetAttr(key string, value any)
  • func (s *Session) SetState(state SessionState)
  • func (s *Session) State() SessionState
• type SessionState
• type StarterClient
• type StarterServer

Types

type AcceptProcess

type AcceptProcess interface {
	Accept(session *Session) error
}

AcceptProcess 网络建立连接时执行

type BootClient

type BootClient struct {
	*Event
	// contains filtered or unexported fields
}

func NewBootClient

func NewBootClient() *BootClient

func NewBootClientContext

func NewBootClientContext(ctx context.Context) *BootClient

func (*BootClient) CancelFunc

func (b *BootClient) CancelFunc()

func (*BootClient) Dial

func (b *BootClient) Dial(network string, addr string) (StarterClient, error)

func (*BootClient) DialTcp

func (b *BootClient) DialTcp(addr string) (StarterClient, error)

func (*BootClient) DialTcpTimeout

func (b *BootClient) DialTcpTimeout(addr string, timeout time.Duration) (StarterClient, error)

func (*BootClient) DialTimeout

func (b *BootClient) DialTimeout(network string, addr string, timeout time.Duration) (StarterClient, error)

func (*BootClient) DialUdp

func (b *BootClient) DialUdp(addr string) (StarterClient, error)

func (*BootClient) DialUdpTimeout

func (b *BootClient) DialUdpTimeout(addr string, timeout time.Duration) (StarterClient, error)

type BootServer

type BootServer struct {
	*Event
	// contains filtered or unexported fields
}

func NewBootServer

func NewBootServer() *BootServer

func NewBootServerContext

func NewBootServerContext(ctx context.Context) *BootServer

func (*BootServer) BindAddr

func (b *BootServer) BindAddr(network string, addr string) error

BindAddr 绑定监听地址, 如：localhost:8080, 0.0.0.0:8080, :8080, [::1]:0

func (*BootServer) CancelFunc

func (b *BootServer) CancelFunc()

func (*BootServer) ListenTcp

func (b *BootServer) ListenTcp(addr string) error

ListenTcp 启动监听

func (*BootServer) ListenUdp

func (b *BootServer) ListenUdp(addr string) error

func (*BootServer) Starter

func (b *BootServer) Starter() StarterServer

func (*BootServer) Stop

func (b *BootServer) Stop() error

type DisconnectProcess

type DisconnectProcess interface {
	Disconnect(session *Session) error
}

DisconnectProcess 网络连接断开时执行

type Event

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

func NewEvent

func NewEvent() *Event

func (*Event) ProcessList

func (e *Event) ProcessList() []interface{}

func (*Event) Register

func (e *Event) Register(proc Process)

func (*Event) RegisterPlus

func (e *Event) RegisterPlus(proc any) error

func (*Event) UnRegister

func (e *Event) UnRegister(proc Process)

type MockProcess

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

MockProcess is a mock of Process interface.

func NewMockProcess

func NewMockProcess(ctrl *gomock.Controller) *MockProcess

NewMockProcess creates a new mock instance.

func (*MockProcess) Accept

func (m *MockProcess) Accept(session *Session) error

Accept mocks base method.

func (*MockProcess) Active

func (m *MockProcess) Active(session *Session, value any) (any, error)

Active mocks base method.

func (*MockProcess) Disconnect

func (m *MockProcess) Disconnect(session *Session) error

Disconnect mocks base method.

func (*MockProcess) EXPECT

func (m *MockProcess) EXPECT() *MockProcessMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

type MockProcessMockRecorder

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

MockProcessMockRecorder is the mock recorder for MockProcess.

func (*MockProcessMockRecorder) Accept

func (mr *MockProcessMockRecorder) Accept(session any) *gomock.Call

Accept indicates an expected call of Accept.

func (*MockProcessMockRecorder) Active

func (mr *MockProcessMockRecorder) Active(session, value any) *gomock.Call

Active indicates an expected call of Active.

func (*MockProcessMockRecorder) Disconnect

func (mr *MockProcessMockRecorder) Disconnect(session any) *gomock.Call

Disconnect indicates an expected call of Disconnect.

type Process

type Process interface {
	Active(session *Session, value any) (any, error)
}

Process 有请求数据时执行

type Session

type Session struct {
	Socket *socket.Socket
	// contains filtered or unexported fields
}

Session 会话对象, 每个连接都有唯一会话

func NewSession

func NewSession(socket *socket.Socket) *Session

func NewSessionContext

func NewSessionContext(socket *socket.Socket, ctx context.Context) *Session

func (*Session) CancelFunc

func (s *Session) CancelFunc()

func (*Session) Close

func (s *Session) Close() error

func (*Session) Ctx

func (s *Session) Ctx() context.Context

func (*Session) GetAttr

func (s *Session) GetAttr(key string) any

func (*Session) SetAttr

func (s *Session) SetAttr(key string, value any)

func (*Session) SetState

func (s *Session) SetState(state SessionState)

func (*Session) State

func (s *Session) State() SessionState

type SessionState

type SessionState int

SessionState 会话状态

const (
	Accept     SessionState = iota // 新建连接
	Active                         // 活动连接
	Disconnect                     // 断开连接
)

type StarterClient

type StarterClient interface {
	Dial(addr string) (*Session, error)
	DialTimeout(addr string, timeout time.Duration) (*Session, error)
	Session() (session *Session)

	Request(body any) (any, error)
	Close() error
	// contains filtered or unexported methods
}

StarterClient 客户端启动器接口

type StarterServer

type StarterServer interface {
	Listen() error
	Listener() net.Listener
	Close() error
}

StarterServer 服务端启动器接口