server

Documentation

Index

• Constants
• type AuthKeyConfig
• type AuthKeyServer
  • func NewAuthKeyServer(configPath string) *AuthKeyServer
  • func (s *AuthKeyServer) Destroy()
  • func (s *AuthKeyServer) Initialize() error
  • func (s *AuthKeyServer) OnConnectionClosed(conn *net2.TcpConnection)
  • func (s *AuthKeyServer) OnConnectionDataArrived(conn *net2.TcpConnection, msg interface{}) error
  • func (s *AuthKeyServer) OnNewConnection(conn *net2.TcpConnection)
  • func (s *AuthKeyServer) RunLoop()
• type AuthKeyServiceImpl
  • func (s *AuthKeyServiceImpl) QueryAuthKey(ctx context.Context, request *mtproto.AuthKeyRequest) (*mtproto.AuthKeyData, error)
  • func (s *AuthKeyServiceImpl) QueryUserId(ctx context.Context, request *mtproto.AuthKeyIdRequest) (*mtproto.UserIdResponse, error)
• type ServerConfig

Constants

const (
	SHA_DIGEST_LENGTH = 20
)

Types

type AuthKeyConfig

type AuthKeyConfig struct {
	ServerId  int32 // 服务器ID
	Mysql     []mysql_client.MySQLConfig
	Server    ServerConfig
	Discovery service_discovery.ServiceDiscoveryServerConfig

	RpcServer    *rpcServerConfig
	RpcDiscovery service_discovery.ServiceDiscoveryServerConfig
}

type AuthKeyServer

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

func NewAuthKeyServer

func NewAuthKeyServer(configPath string) *AuthKeyServer

func (*AuthKeyServer) Destroy

func (s *AuthKeyServer) Destroy()

func (*AuthKeyServer) Initialize

func (s *AuthKeyServer) Initialize() error

////////////////////////////////////////////////////////////////////////////////////////////////// AppInstance interface

func (*AuthKeyServer) OnConnectionClosed

func (s *AuthKeyServer) OnConnectionClosed(conn *net2.TcpConnection)

func (*AuthKeyServer) OnConnectionDataArrived

func (s *AuthKeyServer) OnConnectionDataArrived(conn *net2.TcpConnection, msg interface{}) error

func (*AuthKeyServer) OnNewConnection

func (s *AuthKeyServer) OnNewConnection(conn *net2.TcpConnection)

////////////////////////////////////////////////////////////////////////////////////////////////// TcpConnectionCallback

func (*AuthKeyServer) RunLoop

func (s *AuthKeyServer) RunLoop()

type AuthKeyServiceImpl

type AuthKeyServiceImpl struct {
}

func (*AuthKeyServiceImpl) QueryAuthKey

func (s *AuthKeyServiceImpl) QueryAuthKey(ctx context.Context, request *mtproto.AuthKeyRequest) (*mtproto.AuthKeyData, error)

rpc QueryAuthKey(AuthKeyRequest) returns (AuthKeyData);

func (*AuthKeyServiceImpl) QueryUserId

func (s *AuthKeyServiceImpl) QueryUserId(ctx context.Context, request *mtproto.AuthKeyIdRequest) (*mtproto.UserIdResponse, error)

rpc QueryUserId(AuthKeyIdRequest) returns (UserIdResponse);

type ServerConfig

type ServerConfig struct {
	Name      string
	ProtoName string
	Addr      string
}