nomad

Documentation

Index

• func TestParseJob(t *testing.T, path string) *api.Job
• type Source
  • func NewNomadSource(log hclog.Logger, nomad *api.Client, policyProcessor *policy.Processor) *Source
  • func TestNomadSource(t *testing.T, cb func(*api.Config, *policy.ConfigDefaults)) *Source
  • func (s *Source) MonitorIDs(ctx context.Context, req policy.MonitorIDsReq)
  • func (s *Source) MonitorPolicy(ctx context.Context, req policy.MonitorPolicyReq)
  • func (s *Source) Name() policy.SourceName
  • func (s *Source) ReloadIDsMonitor()
  • func (s *Source) SetNomadClient(nomad *api.Client)

Functions

func TestParseJob

func TestParseJob(t *testing.T, path string) *api.Job

TestParseJob parses a file into an *api.Job object.

Types

type Source

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

Source is an implementation of the Source interface that retrieves policies from a Nomad cluster.

func NewNomadSource

func NewNomadSource(log hclog.Logger, nomad *api.Client, policyProcessor *policy.Processor) *Source

NewNomadSource returns a new Nomad policy source.

func TestNomadSource

func TestNomadSource(t *testing.T, cb func(*api.Config, *policy.ConfigDefaults)) *Source

TestNomadSource returns a default policy.Source that retrieves policies from Nomad.

The Nomad client and the agent can be configured by passing a cb function.

func (*Source) MonitorIDs

func (s *Source) MonitorIDs(ctx context.Context, req policy.MonitorIDsReq)

MonitorIDs retrieves a list of policy IDs from a Nomad cluster and sends it in the resultCh channel when change is detected. Errors are sent through the errCh channel.

This function blocks until the context is closed.

func (*Source) MonitorPolicy

func (s *Source) MonitorPolicy(ctx context.Context, req policy.MonitorPolicyReq)

MonitorPolicy monitors a policy and sends it through the resultCh channel when a change is detect. Errors are sent through the errCh channel.

This function blocks until the context is closed.

func (*Source) Name

func (s *Source) Name() policy.SourceName

Name satisfies the Name function of the policy.Source interface.

func (*Source) ReloadIDsMonitor

func (s *Source) ReloadIDsMonitor()

ReloadIDsMonitor satisfies the ReloadIDsMonitor function of the policy.Source interface.

This currently does nothing but in the future will be useful to allow reloading configuration options such as the Nomad client params or the log level.

func (*Source) SetNomadClient

func (s *Source) SetNomadClient(nomad *api.Client)