federation

package

v0.28.0 Latest Latest Go to latest Published: Feb 3, 2024 License: Apache-2.0 Imports: 11 Imported by: 0

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/choria-io/go-choria

Links

Documentation ¶

Index ¶

Constants
func NewChoriaNatsEgest(workers int, mode int, capacity int, broker *FederationBroker, ...) (*pooledWorker, error)
func NewChoriaNatsIngest(workers int, mode int, capacity int, broker *FederationBroker, ...) (*pooledWorker, error)
func NewChoriaReplyTransformer(workers int, capacity int, broker *FederationBroker, logger *log.Entry) (*pooledWorker, error)
func NewChoriaRequestTransformer(workers int, capacity int, broker *FederationBroker, logger *log.Entry) (*pooledWorker, error)
func PooledWorkerFactory(name string, workers int, mode int, capacity int, broker *FederationBroker, ...) (*pooledWorker, error)
type FederationBroker
- func NewFederationBroker(clusterName string, choria inter.Framework) (broker *FederationBroker, err error)
- func (fb *FederationBroker) Start(ctx context.Context, wg *sync.WaitGroup)

Constants ¶

View Source

const (
	Unconnected = iota
	Federation
	Collective
)

Variables ¶

This section is empty.

Functions ¶

func NewChoriaNatsEgest ¶

func NewChoriaNatsEgest(workers int, mode int, capacity int, broker *FederationBroker, logger *log.Entry) (*pooledWorker, error)

func NewChoriaNatsIngest ¶

func NewChoriaNatsIngest(workers int, mode int, capacity int, broker *FederationBroker, logger *log.Entry) (*pooledWorker, error)

func NewChoriaReplyTransformer ¶

func NewChoriaReplyTransformer(workers int, capacity int, broker *FederationBroker, logger *log.Entry) (*pooledWorker, error)

func NewChoriaRequestTransformer ¶

func NewChoriaRequestTransformer(workers int, capacity int, broker *FederationBroker, logger *log.Entry) (*pooledWorker, error)

func PooledWorkerFactory ¶

func PooledWorkerFactory(name string, workers int, mode int, capacity int, broker *FederationBroker, logger *log.Entry, worker func(context.Context, *pooledWorker, int, *log.Entry)) (*pooledWorker, error)

Types ¶

type FederationBroker ¶

type FederationBroker struct {
	Name string
	// contains filtered or unexported fields
}

func NewFederationBroker ¶

func NewFederationBroker(clusterName string, choria inter.Framework) (broker *FederationBroker, err error)

func (*FederationBroker) Start ¶

func (fb *FederationBroker) Start(ctx context.Context, wg *sync.WaitGroup)

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
stats

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