service

package

v0.2.18 Latest Latest Go to latest Published: May 11, 2019 License: Apache-2.0 Imports: 27 Imported by: 5

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/pjoc-team/base-service

Links

Open Source Insights

Documentation ¶

Index ¶

func BuildPath(dirRoot string, c model.Config) string
func GetEndpoint(addr string) discovery.ServiceEndpoint
func InitConfig(etcdPeers string, dirRoot string, c model.Config)
func InitConfigByEtcd(etcdPeers string, target interface{}, dir string)
func StartPProf()
func StartPProfWithAddr(addr string)
func StartPProfWithPort(port int)
func WithConfigDir(path string) string
type GatewayConfig
- func InitGatewayConfig(etcdPeers string, dirRoot string) *GatewayConfig
type RegisterGrpcFunc
type Service
- func InitService(listenAddr string, configURI string, tlsEnable bool, logLevel string, ...) (service *Service)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func BuildPath ¶

func BuildPath(dirRoot string, c model.Config) string

func GetEndpoint ¶

func GetEndpoint(addr string) discovery.ServiceEndpoint

func InitConfig ¶

func InitConfig(etcdPeers string, dirRoot string, c model.Config)

func InitConfigByEtcd ¶

func InitConfigByEtcd(etcdPeers string, target interface{}, dir string)

func StartPProf ¶

func StartPProf()

func StartPProfWithAddr ¶

func StartPProfWithAddr(addr string)

func StartPProfWithPort ¶

func StartPProfWithPort(port int)

func WithConfigDir ¶

func WithConfigDir(path string) string

Types ¶

type GatewayConfig ¶

type GatewayConfig struct {
	// 集群配置
	PayConfig *model.PayConfig
	// 通知配置
	NoticeConfig *model.NoticeConfig
	// AppId和费率配置
	AppIdAndChannelConfigMap *model.AppIdAndChannelConfigMap
	// AppId和商户配置
	AppIdAndMerchantMap *model.MerchantConfigMap
	// 服务和对应的部署服务名映射
	ServiceMap *model.ServiceConfigMap
	// Channel和对应host配置
	ChannelServiceMap *model.ChannelServiceConfigMap
}

func InitGatewayConfig ¶

func InitGatewayConfig(etcdPeers string, dirRoot string) *GatewayConfig

type RegisterGrpcFunc ¶

type RegisterGrpcFunc = func(server *grpc.Server)

type Service ¶

type Service struct {
	DiscoveryService      discovery.DiscoveryService
	ListenAddr            string
	ConfigURI             string
	TlsEnable             bool
	LogLevel              string
	LogFormat             string
	CaCert                string
	TlsCert               string
	TlsKey                string
	ServiceName           string
	RegisterServiceToEtcd bool
	EtcdPeers             string
	ServiceDir            string
	// contains filtered or unexported fields
}

func InitService ¶

func InitService(
	listenAddr string,
	configURI string,
	tlsEnable bool,
	logLevel string,
	logFormat string,
	caCert string,
	tlsCert string,
	tlsKey string,
	serviceName string,
	registerServiceToEtcd bool,
	etcdPeers string,
	serviceDir string,
) (service *Service)

func (*Service) Dial ¶

func (svc *Service) Dial(host string, port string, options ...grpc.DialOption) (*grpc.ClientConn, error)

func (*Service) GetGrpcConnectionByDiscoveryService ¶

func (svc *Service) GetGrpcConnectionByDiscoveryService(serviceName string, port string, options ...grpc.DialOption) (*grpc.ClientConn, error)

func (*Service) StartGrpc ¶

func (service *Service) StartGrpc(register RegisterGrpcFunc)

func (*Service) TlsDialGrpcOptions ¶

func (service *Service) TlsDialGrpcOptions() []grpc.DialOption

func (*Service) TlsGrpcOptions ¶

func (service *Service) TlsGrpcOptions() []grpc.ServerOption

Source Files ¶

View all Source files

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