service

package
v0.0.0-...-9098a98 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 7, 2019 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewHandler

func NewHandler(coreEndpoints string) (http.Handler, error)

NewHandler creates a customized http handler to the http server.

func NewResolver

func NewResolver() naming.Resolver

NewResolver creates a simple resolver which returns saved addrs

Types

type Hub

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

Hub manages the gRPC connections to ult servers and works as a load balancer to the backend ult servers.

func NewHub

func NewHub(coreEndpoints string) (*Hub, error)

func (*Hub) QueryTx

func (h *Hub) QueryTx(request *restful.Request, response *restful.Response)

QueryTx query the tx status from ult servers and return current tx status.

func (*Hub) SummitTx

func (h *Hub) SummitTx(request *restful.Request, response *restful.Response)

SummitTx summits the tx to ult servers and return appropriate response messages to client.

Jump to

Keyboard shortcuts

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