app

Documentation

Index

• type App
  • func NewApp(p Conf) App
  • func (a *App) Deregister()
  • func (a *App) Register()
  • func (a *App) StartGrpcServer(register func(srv *grpc.Server), opt ...grpc.ServerOption)
  • func (a *App) StartHttpServer(handler http.Handler)
• type Conf
  • func FromEnv(serviceName string) Conf
  • func RPCFromEnv(serviceName string) Conf
• type UniqueID
  • func NewUniqueID(p Conf) *UniqueID
  • func (u *UniqueID) GetID() int64

Types

type App

type App struct {
	AppName     string
	ServiceName string
	ServerHost  string
	ServerPort  uint64
	MaxConns    int
	EtcdClient  *clientv3.Client
}

func NewApp

func NewApp(p Conf) App

func (*App) Deregister

func (a *App) Deregister()

func (*App) Register

func (a *App) Register()

func (*App) StartGrpcServer

func (a *App) StartGrpcServer(register func(srv *grpc.Server), opt ...grpc.ServerOption)

func (*App) StartHttpServer

func (a *App) StartHttpServer(handler http.Handler)

type Conf

type Conf struct {
	AppName     string `yaml:"app_name"`
	ServiceName string
	ServerHost  string `yaml:"server_host"`
	ServerPort  uint64 `yaml:"server_port"`
	EtcdAddress string `yaml:"etcd_address"`
	MaxConns    int    `yaml:"max_conns"`
}

func FromEnv

func FromEnv(serviceName string) Conf

func RPCFromEnv

func RPCFromEnv(serviceName string) Conf

type UniqueID

type UniqueID struct {
	NodeID int64
	// contains filtered or unexported fields
}

func NewUniqueID

func NewUniqueID(p Conf) *UniqueID

func (*UniqueID) GetID

func (u *UniqueID) GetID() int64