util

Documentation

Index

• Constants
• func BoolToString(flag bool) string
• func GetArgs(args ...string) (arg1, arg2, arg3, arg4, arg5, arg6, arg7, arg8, arg9, arg10 string)
• func GetRedisPeerKey(sid, uid string) string
• func GetRedisPeersPrefixKey(sid string) string
• func GetRedisRoomKey(sid string) string
• func GetServiceInfo(nc nrpc.NatsConn, nid string, selfnid string) (map[string][]*reflection.MethodDescriptor, error)
• func NewNatsConn(url string) (*nats.Conn, error)
• func RandomString(n int) string
• func Recover(flag string)
• func StringToBool(flag string) bool
• type AtomicBool
  • func (b *AtomicBool) Get() bool
  • func (b *AtomicBool) Set(value bool) (swapped bool)
• type ClientConnInterface
  • func NewGRPCClientConnForNode(node discovery.Node) (ClientConnInterface, error)
• type ServiceInterface
  • func NewGRPCServiceForNode(node discovery.Node) (ServiceInterface, error)
• type WrapperedGRPCWebServer
  • func NewWrapperedGRPCWebServer(options WrapperedServerOptions, s *grpc.Server) *WrapperedGRPCWebServer
  • func (s *WrapperedGRPCWebServer) Serve() error
• type WrapperedServerOptions
  • func DefaultWrapperedServerOptions() WrapperedServerOptions
  • func NewWrapperedServerOptions(addr, cert, key string, websocket bool) WrapperedServerOptions

Constants

const (
	DefaultStatCycle   = time.Second * 3
	DefaultGRPCTimeout = 15 * time.Second
)

Functions

func BoolToString

func BoolToString(flag bool) string

func GetArgs

func GetArgs(args ...string) (arg1, arg2, arg3, arg4, arg5, arg6, arg7, arg8, arg9, arg10 string)

func GetRedisPeerKey

func GetRedisPeerKey(sid, uid string) string

func GetRedisPeersPrefixKey

func GetRedisPeersPrefixKey(sid string) string

func GetRedisRoomKey

func GetRedisRoomKey(sid string) string

func GetServiceInfo

func GetServiceInfo(nc nrpc.NatsConn, nid string, selfnid string) (map[string][]*reflection.MethodDescriptor, error)

Get service information through reflection, this feature can be used to create json-rpc, restful API

func NewNatsConn

func NewNatsConn(url string) (*nats.Conn, error)

NewNatsConn .

func RandomString

func RandomString(n int) string

RandomString generate a random string

func Recover

func Recover(flag string)

Recover print stack

func StringToBool

func StringToBool(flag string) bool

Types

type AtomicBool

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

AtomicBool represents a atomic bool

func (*AtomicBool) Get

func (b *AtomicBool) Get() bool

Get atomic bool

func (*AtomicBool) Set

func (b *AtomicBool) Set(value bool) (swapped bool)

Set atomic bool

type ClientConnInterface

type ClientConnInterface interface {
	grpc.ClientConnInterface
	Close() error
}

ClientConnInterface .

func NewGRPCClientConnForNode

func NewGRPCClientConnForNode(node discovery.Node) (ClientConnInterface, error)

NewGRPCClientForNode .

type ServiceInterface

type ServiceInterface interface {
	grpc.ServiceRegistrar
	Serve(lis net.Listener) error
	Stop()
}

ServiceInterface .

func NewGRPCServiceForNode

func NewGRPCServiceForNode(node discovery.Node) (ServiceInterface, error)

NewGRPCServiceForNode .

type WrapperedGRPCWebServer

type WrapperedGRPCWebServer struct {
	GRPCServer *grpc.Server
	// contains filtered or unexported fields
}

func NewWrapperedGRPCWebServer

func NewWrapperedGRPCWebServer(options WrapperedServerOptions, s *grpc.Server) *WrapperedGRPCWebServer

func (*WrapperedGRPCWebServer) Serve

func (s *WrapperedGRPCWebServer) Serve() error

type WrapperedServerOptions

type WrapperedServerOptions struct {
	Addr                  string
	Cert                  string
	Key                   string
	AllowAllOrigins       bool
	AllowedOrigins        *[]string
	AllowedHeaders        *[]string
	UseWebSocket          bool
	WebsocketPingInterval time.Duration
}

func DefaultWrapperedServerOptions

func DefaultWrapperedServerOptions() WrapperedServerOptions

func NewWrapperedServerOptions

func NewWrapperedServerOptions(addr, cert, key string, websocket bool) WrapperedServerOptions