tagit

type CmdExecutor ¶ added in v0.0.2

type CmdExecutor struct{}

func (e *CmdExecutor) Execute(command string) ([]byte, error)

type CommandExecutor ¶ added in v0.0.2

type CommandExecutor interface {
	Execute(command string) ([]byte, error)
}

CommandExecutor is an interface for running commands.

type ConsulAPIWrapper ¶ added in v0.0.2

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

ConsulAPIWrapper wraps the Consul API client to conform to the ConsulClient interface.

func NewConsulAPIWrapper(client *api.Client) *ConsulAPIWrapper

func (w *ConsulAPIWrapper) Agent() ConsulAgent

type ConsulAgent ¶ added in v0.0.2

type ConsulAgent interface {
	Services() (map[string]*api.AgentService, error)
	ServiceRegister(*api.AgentServiceRegistration) error
}

ConsulClientAgent is an interface for the Consul agent.

type ConsulClient ¶ added in v0.0.2

type ConsulClient interface {
	Agent() ConsulAgent
}

ConsulClient is an interface for the Consul client.

type TagIt ¶

type TagIt struct {
	ConsulAddr string
	ServiceID  string
	Script     string
	Interval   time.Duration
	Token      string
	TagPrefix  string
	// contains filtered or unexported fields
}

TagIt is the main struct for the tagit flow.

func New(consulClient ConsulClient, commandExecutor CommandExecutor, serviceID string, script string, interval time.Duration, tagPrefix string) *TagIt

func (t *TagIt) CleanupTags() error

func (t *TagIt) Run(ctx context.Context)