defaults

package

v2.1.2+incompatible Latest Latest Go to latest Published: Jul 10, 2020 License: AGPL-3.0 Imports: 16 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

gitproxy.zycloud.tk/pydio/cells

Links

Open Source Insights

Documentation ¶

Overview ¶

Package defaults initializes the defaults GRPC clients and servers used by services

Index ¶

Variables
func Broker() broker.Broker
func InitClient(opt ...func() client.Option)
func InitHTTPServer(opt ...func() server.Option)
func InitServer(opt ...func() server.Option)
func NetworkClientWrapper(c client.Client) client.Client
func NewClient(new ...client.Option) client.Client
func NewHTTPServer(new ...server.Option) server.Server
func NewServer(new ...server.Option) server.Server
func Registry() registry.Registry
func RuntimeIsCluster() bool
func RuntimeIsFork() bool
func StartupRegistry() registry.Registry
func Transport() transport.Transport
type Option
type Options

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	DefaultStartupRegistry registry.Registry
)

Functions ¶

func Broker ¶

func Broker() broker.Broker

func InitClient ¶

func InitClient(opt ...func() client.Option)

func InitHTTPServer ¶

func InitHTTPServer(opt ...func() server.Option)

func InitServer ¶

func InitServer(opt ...func() server.Option)

func NetworkClientWrapper ¶

func NetworkClientWrapper(c client.Client) client.Client

func NewClient ¶

func NewClient(new ...client.Option) client.Client

NewClient returns a client attached to the defaults

func NewHTTPServer ¶

func NewHTTPServer(new ...server.Option) server.Server

func NewServer ¶

func NewServer(new ...server.Option) server.Server

NewServer returns a server attached to the defaults

func Registry ¶

func Registry() registry.Registry

func RuntimeIsCluster ¶

func RuntimeIsCluster() bool

func RuntimeIsFork ¶

func RuntimeIsFork() bool

func StartupRegistry ¶

func StartupRegistry() registry.Registry

func Transport ¶

func Transport() transport.Transport

Types ¶

type Option ¶

type Option func(*Options)

func WithBroker ¶

func WithBroker(b broker.Broker) Option

func WithCert ¶

func WithCert(c string, k string) Option

func WithRegistry ¶

func WithRegistry(r registry.Registry) Option

func WithTransport ¶

func WithTransport(t transport.Transport) Option

type Options ¶

type Options struct {
	Selector  selector.Selector
	Registry  registry.Registry
	Broker    broker.Broker
	Transport transport.Transport
	CertFile  string
	KeyFile   string
	Client    func(new ...client.Option) client.Client
	Server    func(new ...server.Option) server.Server
}

Source Files ¶

defaults.go
network-errors.go
options.go
runtime.go

Directories ¶

Path	Synopsis
broker
http
nats
rcache
registry
nats
router Package router provides api service routing	Package router provides api service routing
transport
grpc

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