server

Documentation

Index

• Constants
• func WaitForSignals(sigs ...os.Signal) <-chan os.Signal
• func WithAuth(ctx context.Context, appId, appSecret string) context.Context
• func WithMD(ctx context.Context, kv ...string) context.Context
• type Call
  • func FromIncomingContext(ctx context.Context) (call *Call, ok bool)
• type Client
  • func Dial(addr string, opts ...grpc.DialOption) (_ *Client, err error)
  • func (cli *Client) AddAuth(appId, appSecret string)
• type Server
  • func NewServer(opts ...grpc.ServerOption) *Server
  • func (srv *Server) Done() <-chan struct{}
  • func (srv *Server) ListenAndServe(addr string) (err error)
  • func (srv *Server) Serve(lis net.Listener) (err error)
  • func (srv *Server) Stop()

Constants

const (
	// for convenience
	SIGHUP  = syscall.SIGHUP
	SIGINT  = syscall.SIGINT
	SIGTERM = syscall.SIGTERM
	SIGUSR1 = syscall.SIGUSR1
	SIGUSR2 = syscall.SIGUSR2
)

Functions

func WaitForSignals

func WaitForSignals(sigs ...os.Signal) <-chan os.Signal

wait for terminate signals this method can only be used at one place at then same time

func WithAuth

func WithAuth(ctx context.Context, appId, appSecret string) context.Context

func WithMD

func WithMD(ctx context.Context, kv ...string) context.Context

Types

type Call

type Call struct {
	log.Recorder
	// these fields can be truested
	AppId     string
	UserId    string
	RoleId    string
	RoleIndex int32
}

func FromIncomingContext

func FromIncomingContext(ctx context.Context) (call *Call, ok bool)

type Client

type Client struct {
	Gateway     v1pb.GatewayClient
	Database    v1pb.DatabaseClient
	Mailbox     v1pb.MailboxClient
	Distlock    v1pb.DistlockClient
	Leaderboard v1pb.LeaderboardClient
	BubbleChart v1pb.BubbleChartClient
	// contains filtered or unexported fields
}

func Dial

func Dial(addr string, opts ...grpc.DialOption) (_ *Client, err error)

func (*Client) AddAuth

func (cli *Client) AddAuth(appId, appSecret string)

type Server

type Server struct {
	grpc.ServiceRegistrar
	// contains filtered or unexported fields
}

func NewServer

func NewServer(opts ...grpc.ServerOption) *Server

func (*Server) Done

func (srv *Server) Done() <-chan struct{}

func (*Server) ListenAndServe

func (srv *Server) ListenAndServe(addr string) (err error)

func (*Server) Serve

func (srv *Server) Serve(lis net.Listener) (err error)

func (*Server) Stop

func (srv *Server) Stop()