nsync

README

nsync

Note: This repository should be imported as code.cloudfoundry.org/nsync.

Keeps diego ☆NSYNC with CC

####Learn more about Diego and its components at diego-design-notes

Development

The nsync test suite depends on ginkgo and consul. If these are not running, assuming your $GOPATH is configured correctly, you may:

go get github.com/onsi/ginkgo/ginkgo
brew install consul

To run the test suite:

ginkgo -r .

Documentation

Index

• Constants
• Variables
• func NysncBulkerLockSchemaPath() string
• type ServiceClient
  • func NewServiceClient(consulClient consuladapter.Client, clock clock.Clock) ServiceClient

Constants

const (
	DesireAppRoute = "Desire"
	StopAppRoute   = "StopApp"
	KillIndexRoute = "KillIndex"

	TasksRoute      = "Task"
	CancelTaskRoute = "CancelTask"
)

const NysncBulkerLockSchemaKey = "nsync_bulker_lock"

Variables

var Routes = rata.Routes{
	{Path: "/v1/apps/:process_guid", Method: "PUT", Name: DesireAppRoute},
	{Path: "/v1/apps/:process_guid", Method: "DELETE", Name: StopAppRoute},
	{Path: "/v1/apps/:process_guid/index/:index", Method: "DELETE", Name: KillIndexRoute},

	{Path: "/v1/tasks", Method: "POST", Name: TasksRoute},
	{Path: "/v1/tasks/:task_guid", Method: "DELETE", Name: CancelTaskRoute},
}

Functions

func NysncBulkerLockSchemaPath

func NysncBulkerLockSchemaPath() string

Types

type ServiceClient

type ServiceClient interface {
	NewNsyncBulkerLockRunner(logger lager.Logger, bulkerID string, retryInterval, lockTTL time.Duration) ifrit.Runner
}

func NewServiceClient

func NewServiceClient(consulClient consuladapter.Client, clock clock.Clock) ServiceClient