daemon

package
v0.0.0-...-3cc3ff2 Latest Latest
Warning

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

Go to latest
Published: May 17, 2021 License: MIT Imports: 17 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var Command = &cobra.Command{
	Use:          "daemon",
	Short:        "Starts the Semaphore daemon, it will execute with the passed definitions and expose the configured endpoints",
	RunE:         run,
	SilenceUsage: true,
}

Command represents the semaphore daemon command

Functions

This section is empty.

Types

type Client

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

Client represents a semaphore instance

func NewClient

func NewClient(ctx *broker.Context, core semaphore.Options, provider providers.Options) (*Client, error)

NewClient constructs a new Semaphore instance

func (*Client) Apply

func (client *Client) Apply(ctx *broker.Context) error

Apply updates the listeners with the given specs collection. Transporters are created from the available endpoints and flows. The created transporters are passed to the listeners to be hot-swapped.

This method does not perform any checks ensuring that the given specification is valid.

func (*Client) Close

func (client *Client) Close()

Close gracefully closes the given client

func (*Client) Serve

func (client *Client) Serve() (<-chan struct{}, <-chan error)

Serve opens all listeners inside the given semaphore client

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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