daemon

Documentation

Index

• Variables
• type Client
  • func NewClient(ctx *broker.Context, core semaphore.Options, provider providers.Options) (*Client, error)
  • func (client *Client) Apply(ctx *broker.Context) error
  • func (client *Client) Close()
  • func (client *Client) Serve() (<-chan struct{}, <-chan error)

Variables

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

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