whoson

package

Go to main page

Versions in this module

v0

v0.2.9

Dec 19, 2024

v0.2.8

Dec 19, 2024

v0.2.7

May 31, 2022

Changes in this version

+ var File_pkg_whoson_sync_proto protoreflect.FileDescriptor

+ var Sync_ServiceDesc = grpc.ServiceDesc

+ type UnimplementedSyncServer struct

+ func (UnimplementedSyncServer) Del(context.Context, *WSRequest) (*WSResponse, error)

+ func (UnimplementedSyncServer) Dump(context.Context, *WSDumpRequest) (*WSDumpResponse, error)

+ func (UnimplementedSyncServer) Set(context.Context, *WSRequest) (*WSResponse, error)

+ type UnsafeSyncServer interface

type WSDumpRequest

+ func (x *WSDumpRequest) ProtoReflect() protoreflect.Message

type WSDumpResponse

+ func (x *WSDumpResponse) GetJson() []byte

+ func (x *WSDumpResponse) GetMsg() string

+ func (x *WSDumpResponse) GetRcode() int32

+ func (x *WSDumpResponse) ProtoReflect() protoreflect.Message

type WSRequest

+ func (x *WSRequest) GetData() string

+ func (x *WSRequest) GetExpire() int64

+ func (x *WSRequest) GetIP() string

+ func (x *WSRequest) GetMethod() string

+ func (x *WSRequest) ProtoReflect() protoreflect.Message

type WSResponse

+ func (x *WSResponse) GetMsg() string

+ func (x *WSResponse) GetRcode() int32

+ func (x *WSResponse) ProtoReflect() protoreflect.Message

v0.2.6

Nov 19, 2020

Changes in this version

+ const ExpireCheckInterval

+ const SessionTimeOut

+ const StoreDataExpire

+ var ExpvarMap = expvar.NewMap("gowhoson")

+ var IDGenerator *katsubushi.Generator

+ var LogWriter reopen.Writer

+ var Logger *zap.Logger

+ var MainStore Store

+ func InitLog(output, loglevel string) error

+ func ListenAndServe(proto string, addr string) error

+ func Log(status, msg string, ses *Session, err error)

+ func NewIDGenerator(workerID uint) error

+ func NewLogger(output, loglevel string) error

+ func NewMainStore()

+ func NewMainStoreEnableSyncRemote()

+ func RegisterSyncServer(s *grpc.Server, srv SyncServer)

+ func RunExpireChecker(ctx context.Context)

+ func RunSyncRemote(ctx context.Context, hosts []string)

+ func ServeTCP(l *net.TCPListener) error

+ func ServeUDP(c *net.UDPConn) error

+ type Buffer struct

+ func (b *Buffer) Free()

+ type BufferPool struct

+ func NewBufferPool() *BufferPool

+ func (p *BufferPool) Get() *Buffer

+ type Client struct

+ func Dial(proto string, addr string) (*Client, error)

+ func NewClient(conn net.Conn, host string) (*Client, error)

+ func (c *Client) Close() error

+ func (c *Client) Login(ip string, args string) (*Response, error)

+ func (c *Client) Logout(ip string) (*Response, error)

+ func (c *Client) Query(ip string) (*Response, error)

+ func (c *Client) Quit() (*Response, error)

+ type ClientConfig struct

+ Mode string

+ Server string

+ type MemStore struct

+ SyncRemote bool

+ func (ms MemStore) Count() int

+ func (ms MemStore) Del(k string) bool

+ func (ms MemStore) Get(k string) (*StoreData, error)

+ func (ms MemStore) Items() map[string]interface{}

+ func (ms MemStore) ItemsJSON() ([]byte, error)

+ func (ms MemStore) Set(k string, w *StoreData)

+ func (ms MemStore) SyncDel(k string) bool

+ func (ms MemStore) SyncSet(k string, w *StoreData)

+ type MethodType int

+ type ProtocolType int

+ type Response struct

+ Msg string

+ func (r *Response) Parse(req string) error

+ func (r *Response) String() string

+ type ResultType int

+ type ServerConfig struct

+ ControlPort string

+ Expvar bool

+ Log string

+ Loglevel string

+ SaveFile string

+ ServerID int

+ SyncRemote string

+ TCP string

+ UDP string

+ type ServerCtl struct

+ func NewServerCtl(server string) *ServerCtl

+ func (sc *ServerCtl) Dump() error

+ func (sc *ServerCtl) SetWriter(o io.Writer)

+ func (sc *ServerCtl) WriteJSON() error

+ func (sc *ServerCtl) WriteTable() error

+ type ServerCtlConfig struct

+ EditConfig bool

+ JSON bool

+ Server string

+ type Session struct

+ func NewSessionTCP(s *TCPServer, c net.Conn) (*Session, error)

+ func NewSessionUDP(c *net.UDPConn, r *net.UDPAddr, b *Buffer) (*Session, error)

+ type Store interface

+ Count func() int

+ Del func(k string) bool

+ Get func(k string) (*StoreData, error)

+ Items func() map[string]interface{}

+ ItemsJSON func() ([]byte, error)

+ Set func(k string, w *StoreData)

+ SyncDel func(k string) bool

+ SyncSet func(k string, w *StoreData)

+ func NewMemStore() Store

+ type StoreData struct

+ Data string

+ Expire time.Time

+ IP net.IP

+ func (sd *StoreData) Key() string

+ func (sd *StoreData) UpdateExpire()

+ type Sync struct

+ func (s *Sync) Del(c context.Context, wreq *WSRequest) (*WSResponse, error)

+ func (s *Sync) Dump(c context.Context, wreq *WSDumpRequest) (*WSDumpResponse, error)

+ func (s *Sync) Set(c context.Context, wreq *WSRequest) (*WSResponse, error)

+ type SyncClient interface

+ Del func(ctx context.Context, in *WSRequest, opts ...grpc.CallOption) (*WSResponse, error)

+ Dump func(ctx context.Context, in *WSDumpRequest, opts ...grpc.CallOption) (*WSDumpResponse, error)

+ Set func(ctx context.Context, in *WSRequest, opts ...grpc.CallOption) (*WSResponse, error)

+ func NewSyncClient(cc *grpc.ClientConn) SyncClient

+ type SyncServer interface

+ Del func(context.Context, *WSRequest) (*WSResponse, error)

+ Dump func(context.Context, *WSDumpRequest) (*WSDumpResponse, error)

+ Set func(context.Context, *WSRequest) (*WSResponse, error)

+ type TCPServer struct

+ Addr string

+ func NewTCPServer() *TCPServer

+ func (s *TCPServer) ListenAndServe() error

+ func (s *TCPServer) ServeTCP(l *net.TCPListener) error

+ type UDPServer struct

+ Addr string

+ func NewUDPServer() *UDPServer

+ func (s *UDPServer) ListenAndServe() error

+ func (s *UDPServer) ServeUDP(c *net.UDPConn) error

+ type WSDumpRequest struct

+ func (*WSDumpRequest) Descriptor() ([]byte, []int)

+ func (*WSDumpRequest) ProtoMessage()

+ func (m *WSDumpRequest) Reset()

+ func (m *WSDumpRequest) String() string

+ type WSDumpResponse struct

+ Json []byte

+ Msg string

+ Rcode int32

+ func (*WSDumpResponse) Descriptor() ([]byte, []int)

+ func (*WSDumpResponse) ProtoMessage()

+ func (m *WSDumpResponse) Reset()

+ func (m *WSDumpResponse) String() string

+ type WSRequest struct

+ Data string

+ Expire int64

+ IP string

+ Method string

+ func (*WSRequest) Descriptor() ([]byte, []int)

+ func (*WSRequest) ProtoMessage()

+ func (m *WSRequest) Reset()

+ func (m *WSRequest) String() string

+ type WSResponse struct

+ Msg string

+ Rcode int32

+ func (*WSResponse) Descriptor() ([]byte, []int)

+ func (*WSResponse) ProtoMessage()

+ func (m *WSResponse) Reset()

+ func (m *WSResponse) String() string

+ type Worker struct

+ func (w *Worker) Run(ctx context.Context)

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