types

package

Go to main page

Versions in this module

v1

v1.3.0

Mar 22, 2018

v1.2.1

Mar 16, 2018

v1.2.0

Mar 15, 2018

Changes in this version

type GwHosts

+ Http []string

+ Socket []string

+ func (m *GwHosts) GetHttp() []string

+ func (m *GwHosts) GetSocket() []string

v1.1.1

Mar 15, 2018

Changes in this version

type AccessTokenMgr

+ QueryForHttp func(args RequestArgs) string

v1.1.0

Mar 14, 2018

Changes in this version

+ type AccessTokenMgr interface

+ QueryForHTTP func(args RequestArgs) string

+ Verify func(accessToken string) (AccessToken, *tp.Rerror)

+ func DefaultAccessTokenMgr() AccessTokenMgr

+ type HttpHooks interface

+ OnRequest func(RequestArgs, ...AccessToken) ([]socket.PacketSetting, *tp.Rerror)

+ func DefaultHttpHooks() HttpHooks

+ type SocketHooks interface

+ GetSession func(peer tp.Peer, uid string) (tp.Session, *tp.Rerror)

+ OnLogoff func(tp.BaseSession) *tp.Rerror

+ OnLogon func(plugin.AuthSession, AccessToken) *tp.Rerror

+ PreWritePush func(tp.WriteCtx) *tp.Rerror

+ func DefaultSocketHooks() SocketHooks

+ type SocketPushArgs struct

+ Body []byte

+ BodyCodec int32

+ Uid string

+ Uri string

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

+ func (*SocketPushArgs) ProtoMessage()

+ func (m *SocketPushArgs) GetBody() []byte

+ func (m *SocketPushArgs) GetBodyCodec() int32

+ func (m *SocketPushArgs) GetUid() string

+ func (m *SocketPushArgs) GetUri() string

+ func (m *SocketPushArgs) Marshal() (dAtA []byte, err error)

+ func (m *SocketPushArgs) MarshalTo(dAtA []byte) (int, error)

+ func (m *SocketPushArgs) Reset()

+ func (m *SocketPushArgs) Size() (n int)

+ func (m *SocketPushArgs) String() string

+ func (m *SocketPushArgs) Unmarshal(dAtA []byte) error

+ type SocketPushReply = codec.PbEmpty

+ type SocketTotalArgs = codec.PbEmpty

+ type SocketTotalReply struct

+ ConnTotal int32

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

+ func (*SocketTotalReply) ProtoMessage()

+ func (m *SocketTotalReply) GetConnTotal() int32

+ func (m *SocketTotalReply) Marshal() (dAtA []byte, err error)

+ func (m *SocketTotalReply) MarshalTo(dAtA []byte) (int, error)

+ func (m *SocketTotalReply) Reset()

+ func (m *SocketTotalReply) Size() (n int)

+ func (m *SocketTotalReply) String() string

+ func (m *SocketTotalReply) Unmarshal(dAtA []byte) error

v1.0.0

Mar 13, 2018

Changes in this version

+ var ErrIntOverflowApi = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthApi = fmt.Errorf("proto: negative length found during unmarshaling")

+ type AccessToken interface

+ String func() string

+ Uid func() string

+ type AccessTokenVerifier func(accessToken string) (AccessToken, *tp.Rerror)

+ func DefaultAccessTokenVerifier() AccessTokenVerifier

+ type Business struct

+ ApiVersion string

+ func DefaultBusiness() *Business

+ func (biz *Business) Init()

+ type GwHosts struct

+ Hosts []string

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

+ func (*GwHosts) ProtoMessage()

+ func (m *GwHosts) GetHosts() []string

+ func (m *GwHosts) Marshal() (dAtA []byte, err error)

+ func (m *GwHosts) MarshalTo(dAtA []byte) (int, error)

+ func (m *GwHosts) Reset()

+ func (m *GwHosts) Size() (n int)

+ func (m *GwHosts) String() string

+ func (m *GwHosts) Unmarshal(dAtA []byte) error

+ type LongConnHooks interface

+ GetSession func(peer tp.Peer, uid string) (tp.Session, *tp.Rerror)

+ OnLogoff func(tp.BaseSession) *tp.Rerror

+ OnLogon func(AccessToken, plugin.AuthSession) *tp.Rerror

+ PreWritePush func(tp.WriteCtx) *tp.Rerror

+ func DefaultLongConnHooks() LongConnHooks

+ type ProxyHooks interface

+ BeforePull func(uri string, args interface{}, reply interface{}, ...) *tp.Rerror

+ BeforePush func(uri string, args interface{}, setting ...socket.PacketSetting) *tp.Rerror

+ func DefaultProxyHooks() ProxyHooks

+ type PushLongConnArgs struct

+ Body []byte

+ BodyCodec int32

+ Uid string

+ Uri string

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

+ func (*PushLongConnArgs) ProtoMessage()

+ func (m *PushLongConnArgs) GetBody() []byte

+ func (m *PushLongConnArgs) GetBodyCodec() int32

+ func (m *PushLongConnArgs) GetUid() string

+ func (m *PushLongConnArgs) GetUri() string

+ func (m *PushLongConnArgs) Marshal() (dAtA []byte, err error)

+ func (m *PushLongConnArgs) MarshalTo(dAtA []byte) (int, error)

+ func (m *PushLongConnArgs) Reset()

+ func (m *PushLongConnArgs) Size() (n int)

+ func (m *PushLongConnArgs) String() string

+ func (m *PushLongConnArgs) Unmarshal(dAtA []byte) error

+ type PushLongConnReply = codec.PbEmpty

+ type RequestArgs interface

+ Cookie func(key string) string

+ Header func(key string) string

+ Query func(key string) string

+ type ShortConnHooks interface

+ OnRequest func(AccessToken, RequestArgs) ([]socket.PacketSetting, *tp.Rerror)

+ func DefaultShortConnHooks() ShortConnHooks

+ type TotalLongConnArgs = codec.PbEmpty

+ type TotalLongConnReply struct

+ ConnTotal int32

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

+ func (*TotalLongConnReply) ProtoMessage()

+ func (m *TotalLongConnReply) GetConnTotal() int32

+ func (m *TotalLongConnReply) Marshal() (dAtA []byte, err error)

+ func (m *TotalLongConnReply) MarshalTo(dAtA []byte) (int, error)

+ func (m *TotalLongConnReply) Reset()

+ func (m *TotalLongConnReply) Size() (n int)

+ func (m *TotalLongConnReply) String() string

+ func (m *TotalLongConnReply) Unmarshal(dAtA []byte) error

Incompatible versions in this module

v6.0.1+incompatible

Nov 13, 2019

v6.0.0+incompatible

Oct 16, 2019

v2.1.0+incompatible

Jul 29, 2019

v2.0.0+incompatible

Jun 21, 2018

Other modules containing this package

github.com/xiaoenai/tp-micro/v6

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