util

package

v1.9.0 Latest Latest Go to latest Published: Apr 10, 2021 License: MIT Imports: 15 Imported by: 7

Details

View Source

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

This section is empty.

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)

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 .