util

package

v1.9.2 Latest Latest Go to latest Published: Oct 24, 2021 License: MIT Imports: 19 Imported by: 7

Details

View Source

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

This section is empty.

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(url string) (*nats.Conn, error)

NewNatsConn .

func ParseSDP(sdpstr string) ([]*ion.Stream, error)

ParseSDP .

func RandomString(n int) string

RandomString generate a random string

func Recover(flag string)

Recover print stack

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

AtomicBool represents a atomic bool

func (b *AtomicBool) Get() bool

Get atomic bool

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

Set atomic bool

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

ClientConnInterface .

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

NewGRPCClientForNode .

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

ServiceInterface .

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

NewGRPCServiceForNode .