models

package
v0.0.0-...-045538f Latest Latest
Warning

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

 Go to latest Published: Feb 27, 2016 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Overview

Package models is a generated protocol buffer package.

It is generated from these files: 

actions.proto
actual_lrp.proto
actual_lrp_requests.proto
cached_dependency.proto
cells.proto
desired_lrp.proto
desired_lrp_requests.proto
domain.proto
environment_variables.proto
error.proto
evacuation.proto
events.proto
lrp_convergence_request.proto
modification_tag.proto
ping.proto
security_group.proto
task.proto
task_requests.proto

It has these top-level messages: 

Action
DownloadAction
UploadAction
RunAction
TimeoutAction
EmitProgressAction
TryAction
ParallelAction
SerialAction
CodependentAction
ResourceLimits

Index

Constants

View Source 
const (
	ActionTypeDownload     = "download"
	ActionTypeEmitProgress = "emit_progress"
	ActionTypeRun          = "run"
	ActionTypeUpload       = "upload"
	ActionTypeTimeout      = "timeout"
	ActionTypeTry          = "try"
	ActionTypeParallel     = "parallel"
	ActionTypeSerial       = "serial"
	ActionTypeCodependent  = "codependent"
)
View Source 
const (
	ActualLRPStateUnclaimed = "UNCLAIMED"
	ActualLRPStateClaimed   = "CLAIMED"
	ActualLRPStateRunning   = "RUNNING"
	ActualLRPStateCrashed   = "CRASHED"

	CrashResetTimeout            = 5 * time.Minute
	RetireActualLRPRetryAttempts = 5
)
View Source 
const (
	EventTypeInvalid = ""

	EventTypeDesiredLRPCreated = "desired_lrp_created"
	EventTypeDesiredLRPChanged = "desired_lrp_changed"
	EventTypeDesiredLRPRemoved = "desired_lrp_removed"

	EventTypeActualLRPCreated = "actual_lrp_created"
	EventTypeActualLRPChanged = "actual_lrp_changed"
	EventTypeActualLRPRemoved = "actual_lrp_removed"

	EventTypeTaskCreated = "task_created"
	EventTypeTaskChanged = "task_changed"
	EventTypeTaskRemoved = "task_removed"
)
View Source 
const (
	TCPProtocol  = "tcp"
	UDPProtocol  = "udp"
	ICMPProtocol = "icmp"
	AllProtocol  = "all"
)
View Source 
const CrashBackoffMinDuration = 30 * time.Second
View Source 
const DefaultImmediateRestarts = 3
View Source 
const DefaultMaxBackoffDuration = 16 * time.Minute
View Source 
const DefaultMaxRestarts = 200
View Source 
const (
	EventTypeCellDisappeared = "cell_disappeared"
)
View Source 
const PreloadedRootFSScheme = "preloaded"
View Source 
const StaleUnclaimedActualLRPDuration = 30 * time.Second

Variables

View Source 
var (
	ErrResourceNotFound = &Error{
		Type:    Error_ResourceNotFound,
		Message: "the requested resource could not be found",
	}

	ErrResourceExists = &Error{
		Type:    Error_ResourceExists,
		Message: "the requested resource already exists",
	}

	ErrResourceConflict = &Error{
		Type:    Error_ResourceConflict,
		Message: "the requested resource is in a conflicting state",
	}

	ErrBadRequest = &Error{
		Type:    Error_InvalidRequest,
		Message: "the request received is invalid",
	}

	ErrUnknownError = &Error{
		Type:    Error_UnknownError,
		Message: "the request failed for an unknown reason",
	}

	ErrSerializeJSON = &Error{
		Type:    Error_InvalidJSON,
		Message: "could not serialize JSON",
	}

	ErrDeserializeJSON = &Error{
		Type:    Error_InvalidJSON,
		Message: "could not deserialize JSON",
	}

	ErrFailedToOpenEnvelope = &Error{
		Type:    Error_FailedToOpenEnvelope,
		Message: "could not open envelope",
	}

	ErrActualLRPCannotBeClaimed = &Error{
		Type:    Error_ActualLRPCannotBeClaimed,
		Message: "cannot claim actual LRP",
	}

	ErrActualLRPCannotBeStarted = &Error{
		Type:    Error_ActualLRPCannotBeStarted,
		Message: "cannot start actual LRP",
	}

	ErrActualLRPCannotBeCrashed = &Error{
		Type:    Error_ActualLRPCannotBeCrashed,
		Message: "cannot crash actual LRP",
	}

	ErrActualLRPCannotBeFailed = &Error{
		Type:    Error_ActualLRPCannotBeFailed,
		Message: "cannot fail actual LRP",
	}

	ErrActualLRPCannotBeRemoved = &Error{
		Type:    Error_ActualLRPCannotBeRemoved,
		Message: "cannot remove actual LRP",
	}

	ErrActualLRPCannotBeStopped = &Error{
		Type:    Error_ActualLRPCannotBeStopped,
		Message: "cannot stop actual LRP",
	}

	ErrActualLRPCannotBeUnclaimed = &Error{
		Type:    Error_ActualLRPCannotBeUnclaimed,
		Message: "cannot unclaim actual LRP",
	}

	ErrActualLRPCannotBeEvacuated = &Error{
		Type:    Error_ActualLRPCannotBeEvacuated,
		Message: "cannot evacuate actual LRP",
	}

	ErrDesiredLRPCannotBeUpdated = &Error{
		Type:    Error_DesiredLRPCannotBeUpdated,
		Message: "cannot update desired LRP",
	}
)
View Source 
var ActualLRPStates = []string{
	ActualLRPStateUnclaimed,
	ActualLRPStateClaimed,
	ActualLRPStateRunning,
	ActualLRPStateCrashed,
}
View Source 
var ErrActualLRPGroupInvalid = errors.New("ActualLRPGroup invalid")
View Source 
var ErrInvalidActionType = errors.New("invalid action type")
View Source 
var (
	ErrInvalidLengthActions = fmt.Errorf("proto: negative length found during unmarshaling")
)
View Source 
var (
	ErrInvalidLengthActualLrp = fmt.Errorf("proto: negative length found during unmarshaling")
)
View Source 
var (
	ErrInvalidLengthActualLrpRequests = fmt.Errorf("proto: negative length found during unmarshaling")
)
View Source 
var (
	ErrInvalidLengthCachedDependency = fmt.Errorf("proto: negative length found during unmarshaling")
)
View Source 
var (
	ErrInvalidLengthCells = fmt.Errorf("proto: negative length found during unmarshaling")
)
View Source 
var (
	ErrInvalidLengthDesiredLrp = fmt.Errorf("proto: negative length found during unmarshaling")
)
View Source 
var (
	ErrInvalidLengthDesiredLrpRequests = fmt.Errorf("proto: negative length found during unmarshaling")
)
View Source 
var (
	ErrInvalidLengthDomain = fmt.Errorf("proto: negative length found during unmarshaling")
)
View Source 
var (
	ErrInvalidLengthEnvironmentVariables = fmt.Errorf("proto: negative length found during unmarshaling")
)
View Source 
var (
	ErrInvalidLengthError = fmt.Errorf("proto: negative length found during unmarshaling")
)
View Source 
var (
	ErrInvalidLengthEvacuation = fmt.Errorf("proto: negative length found during unmarshaling")
)
View Source 
var (
	ErrInvalidLengthEvents = fmt.Errorf("proto: negative length found during unmarshaling")
)
View Source 
var (
	ErrInvalidLengthLrpConvergenceRequest = fmt.Errorf("proto: negative length found during unmarshaling")
)
View Source 
var (
	ErrInvalidLengthModificationTag = fmt.Errorf("proto: negative length found during unmarshaling")
)
View Source 
var (
	ErrInvalidLengthPing = fmt.Errorf("proto: negative length found during unmarshaling")
)
View Source 
var (
	ErrInvalidLengthSecurityGroup = fmt.Errorf("proto: negative length found during unmarshaling")
)
View Source 
var (
	ErrInvalidLengthTask = fmt.Errorf("proto: negative length found during unmarshaling")
)
View Source 
var (
	ErrInvalidLengthTaskRequests = fmt.Errorf("proto: negative length found during unmarshaling")
)
View Source 
var Error_Type_name = map[int32]string{
	0:  "UnknownError",
	1:  "InvalidDomain",
	2:  "UnkownVersion",
	3:  "InvalidRecord",
	4:  "InvalidRequest",
	5:  "InvalidResponse",
	6:  "InvalidProtobufMessage",
	7:  "InvalidJSON",
	8:  "FailedToOpenEnvelope",
	9:  "InvalidStateTransition",
	10: "Unauthorized",
	11: "ResourceConflict",
	12: "ResourceExists",
	13: "ResourceNotFound",
	14: "RouterError",
	15: "ActualLRPCannotBeClaimed",
	16: "ActualLRPCannotBeStarted",
	17: "ActualLRPCannotBeCrashed",
	18: "ActualLRPCannotBeFailed",
	19: "ActualLRPCannotBeRemoved",
	20: "ActualLRPCannotBeStopped",
	21: "ActualLRPCannotBeUnclaimed",
	22: "ActualLRPCannotBeEvacuated",
	23: "DesiredLRPCannotBeUpdated",
	24: "RunningOnDifferentCell",
	25: "DesiredLRPSchedulingInfoCannotBeUpdated",
}
View Source 
var Error_Type_value = map[string]int32{
	"UnknownError":                            0,
	"InvalidDomain":                           1,
	"UnkownVersion":                           2,
	"InvalidRecord":                           3,
	"InvalidRequest":                          4,
	"InvalidResponse":                         5,
	"InvalidProtobufMessage":                  6,
	"InvalidJSON":                             7,
	"FailedToOpenEnvelope":                    8,
	"InvalidStateTransition":                  9,
	"Unauthorized":                            10,
	"ResourceConflict":                        11,
	"ResourceExists":                          12,
	"ResourceNotFound":                        13,
	"RouterError":                             14,
	"ActualLRPCannotBeClaimed":                15,
	"ActualLRPCannotBeStarted":                16,
	"ActualLRPCannotBeCrashed":                17,
	"ActualLRPCannotBeFailed":                 18,
	"ActualLRPCannotBeRemoved":                19,
	"ActualLRPCannotBeStopped":                20,
	"ActualLRPCannotBeUnclaimed":              21,
	"ActualLRPCannotBeEvacuated":              22,
	"DesiredLRPCannotBeUpdated":               23,
	"RunningOnDifferentCell":                  24,
	"DesiredLRPSchedulingInfoCannotBeUpdated": 25,
}
View Source 
var Task_State_name = map[int32]string{
	0: "Invalid",
	1: "Pending",
	2: "Running",
	3: "Completed",
	4: "Resolving",
}
View Source 
var Task_State_value = map[string]int32{
	"Invalid":   0,
	"Pending":   1,
	"Running":   2,
	"Completed": 3,
	"Resolving": 4,
}

Functions

func FromJSON 

func FromJSON(payload []byte, v Validator) error

func PreloadedRootFS 

func PreloadedRootFS(stack string) string

func ToJSON 

func ToJSON(v Validator) ([]byte, error)

func ToJSONArray 

func ToJSONArray(vs ...Validator) ([]byte, error)

Types

type Action 

type Action struct {
	DownloadAction     *DownloadAction     `protobuf:"bytes,1,opt,name=download_action" json:"download,omitempty"`
	UploadAction       *UploadAction       `protobuf:"bytes,2,opt,name=upload_action" json:"upload,omitempty"`
	RunAction          *RunAction          `protobuf:"bytes,3,opt,name=run_action" json:"run,omitempty"`
	TimeoutAction      *TimeoutAction      `protobuf:"bytes,4,opt,name=timeout_action" json:"timeout,omitempty"`
	EmitProgressAction *EmitProgressAction `protobuf:"bytes,5,opt,name=emit_progress_action" json:"emit_progress,omitempty"`
	TryAction          *TryAction          `protobuf:"bytes,6,opt,name=try_action" json:"try,omitempty"`
	ParallelAction     *ParallelAction     `protobuf:"bytes,7,opt,name=parallel_action" json:"parallel,omitempty"`
	SerialAction       *SerialAction       `protobuf:"bytes,8,opt,name=serial_action" json:"serial,omitempty"`
	CodependentAction  *CodependentAction  `protobuf:"bytes,9,opt,name=codependent_action" json:"codependent,omitempty"`
}

func WrapAction 

func WrapAction(action ActionInterface) *Action

func WrapActions 

func WrapActions(actions []ActionInterface) []*Action

func (*Action) Equal 

func (this *Action) Equal(that interface{}) bool

func (*Action) GetCodependentAction 

func (m *Action) GetCodependentAction() *CodependentAction

func (*Action) GetDownloadAction 

func (m *Action) GetDownloadAction() *DownloadAction

func (*Action) GetEmitProgressAction 

func (m *Action) GetEmitProgressAction() *EmitProgressAction

func (*Action) GetParallelAction 

func (m *Action) GetParallelAction() *ParallelAction

func (*Action) GetRunAction 

func (m *Action) GetRunAction() *RunAction

func (*Action) GetSerialAction 

func (m *Action) GetSerialAction() *SerialAction

func (*Action) GetTimeoutAction 

func (m *Action) GetTimeoutAction() *TimeoutAction

func (*Action) GetTryAction 

func (m *Action) GetTryAction() *TryAction

func (*Action) GetUploadAction 

func (m *Action) GetUploadAction() *UploadAction

func (*Action) GetValue 

func (this *Action) GetValue() interface{}

func (*Action) GoString 

func (this *Action) GoString() string

func (*Action) Marshal 

func (m *Action) Marshal() (data []byte, err error)

func (*Action) MarshalTo 

func (m *Action) MarshalTo(data []byte) (int, error)

func (*Action) MigrateFromVersion 

func (*Action) MigrateFromVersion(v format.Version) error

func (*Action) ProtoMessage 

func (*Action) ProtoMessage()

func (*Action) Reset 

func (m *Action) Reset()

func (*Action) SetValue 

func (this *Action) SetValue(value interface{}) bool

func (*Action) Size 

func (m *Action) Size() (n int)

func (*Action) String 

func (this *Action) String() string

func (*Action) Unmarshal 

func (m *Action) Unmarshal(data []byte) error

func (*Action) Validate 

func (a *Action) Validate() error

func (*Action) Version 

func (*Action) Version() format.Version

type ActionInterface 

type ActionInterface interface {
	ActionType() string
	Validate() error
}

func UnwrapAction 

func UnwrapAction(action *Action) ActionInterface

type ActualLRP 

type ActualLRP struct {
	ActualLRPKey         `protobuf:"bytes,1,opt,name=actual_lrp_key,embedded=actual_lrp_key" json:""`
	ActualLRPInstanceKey `protobuf:"bytes,2,opt,name=actual_lrp_instance_key,embedded=actual_lrp_instance_key" json:""`
	ActualLRPNetInfo     `protobuf:"bytes,3,opt,name=actual_lrp_net_info,embedded=actual_lrp_net_info" json:""`
	CrashCount           int32           `protobuf:"varint,4,opt,name=crash_count" json:"crash_count"`
	CrashReason          string          `protobuf:"bytes,5,opt,name=crash_reason" json:"crash_reason,omitempty"`
	State                string          `protobuf:"bytes,6,opt,name=state" json:"state"`
	PlacementError       string          `protobuf:"bytes,7,opt,name=placement_error" json:"placement_error,omitempty"`
	Since                int64           `protobuf:"varint,8,opt,name=since" json:"since"`
	ModificationTag      ModificationTag `protobuf:"bytes,9,opt,name=modification_tag" json:"modification_tag"`
}

func NewClaimedActualLRP 

func NewClaimedActualLRP(lrpKey ActualLRPKey, instanceKey ActualLRPInstanceKey, since int64) *ActualLRP

func NewRunningActualLRP 

func NewRunningActualLRP(lrpKey ActualLRPKey, instanceKey ActualLRPInstanceKey, netInfo ActualLRPNetInfo, since int64) *ActualLRP

func NewUnclaimedActualLRP 

func NewUnclaimedActualLRP(lrpKey ActualLRPKey, since int64) *ActualLRP

func (ActualLRP) AllowsTransitionTo 

func (before ActualLRP) AllowsTransitionTo(lrpKey *ActualLRPKey, instanceKey *ActualLRPInstanceKey, newState string) bool

func (ActualLRP) CellIsMissing 

func (actual ActualLRP) CellIsMissing(cellSet CellSet) bool

func (*ActualLRP) Equal 

func (this *ActualLRP) Equal(that interface{}) bool

func (*ActualLRP) GetCrashCount 

func (m *ActualLRP) GetCrashCount() int32

func (*ActualLRP) GetCrashReason 

func (m *ActualLRP) GetCrashReason() string

func (*ActualLRP) GetModificationTag 

func (m *ActualLRP) GetModificationTag() ModificationTag

func (*ActualLRP) GetPlacementError 

func (m *ActualLRP) GetPlacementError() string

func (*ActualLRP) GetSince 

func (m *ActualLRP) GetSince() int64

func (*ActualLRP) GetState 

func (m *ActualLRP) GetState() string

func (*ActualLRP) GoString 

func (this *ActualLRP) GoString() string

func (*ActualLRP) Marshal 

func (m *ActualLRP) Marshal() (data []byte, err error)

func (*ActualLRP) MarshalTo 

func (m *ActualLRP) MarshalTo(data []byte) (int, error)

func (*ActualLRP) MigrateFromVersion 

func (*ActualLRP) MigrateFromVersion(v format.Version) error

func (*ActualLRP) ProtoMessage 

func (*ActualLRP) ProtoMessage()

func (*ActualLRP) Reset 

func (m *ActualLRP) Reset()

func (ActualLRP) ShouldRestartCrash 

func (actual ActualLRP) ShouldRestartCrash(now time.Time, calc RestartCalculator) bool

func (ActualLRP) ShouldRestartImmediately 

func (actual ActualLRP) ShouldRestartImmediately(calc RestartCalculator) bool

func (ActualLRP) ShouldStartUnclaimed 

func (actual ActualLRP) ShouldStartUnclaimed(now time.Time) bool

func (*ActualLRP) Size 

func (m *ActualLRP) Size() (n int)

func (*ActualLRP) String 

func (this *ActualLRP) String() string

func (*ActualLRP) Unmarshal 

func (m *ActualLRP) Unmarshal(data []byte) error

func (ActualLRP) Validate 

func (actual ActualLRP) Validate() error

func (*ActualLRP) Version 

func (*ActualLRP) Version() format.Version

type ActualLRPChange 

type ActualLRPChange struct {
	Before *ActualLRPGroup
	After  *ActualLRPGroup
}

type ActualLRPChangedEvent 

type ActualLRPChangedEvent struct {
	Before *ActualLRPGroup `protobuf:"bytes,1,opt,name=before" json:"before,omitempty"`
	After  *ActualLRPGroup `protobuf:"bytes,2,opt,name=after" json:"after,omitempty"`
}

func NewActualLRPChangedEvent 

func NewActualLRPChangedEvent(before, after *ActualLRPGroup) *ActualLRPChangedEvent

func (*ActualLRPChangedEvent) Equal 

func (this *ActualLRPChangedEvent) Equal(that interface{}) bool

func (*ActualLRPChangedEvent) EventType 

func (event *ActualLRPChangedEvent) EventType() string

func (*ActualLRPChangedEvent) GetAfter 

func (m *ActualLRPChangedEvent) GetAfter() *ActualLRPGroup

func (*ActualLRPChangedEvent) GetBefore 

func (m *ActualLRPChangedEvent) GetBefore() *ActualLRPGroup

func (*ActualLRPChangedEvent) GoString 

func (this *ActualLRPChangedEvent) GoString() string

func (*ActualLRPChangedEvent) Key 

func (event *ActualLRPChangedEvent) Key() string

func (*ActualLRPChangedEvent) Marshal 

func (m *ActualLRPChangedEvent) Marshal() (data []byte, err error)

func (*ActualLRPChangedEvent) MarshalTo 

func (m *ActualLRPChangedEvent) MarshalTo(data []byte) (int, error)

func (*ActualLRPChangedEvent) ProtoMessage 

func (*ActualLRPChangedEvent) ProtoMessage()

func (*ActualLRPChangedEvent) Reset 

func (m *ActualLRPChangedEvent) Reset()

func (*ActualLRPChangedEvent) Size 

func (m *ActualLRPChangedEvent) Size() (n int)

func (*ActualLRPChangedEvent) String 

func (this *ActualLRPChangedEvent) String() string

func (*ActualLRPChangedEvent) Unmarshal 

func (m *ActualLRPChangedEvent) Unmarshal(data []byte) error

type ActualLRPCreatedEvent 

type ActualLRPCreatedEvent struct {
	ActualLrpGroup *ActualLRPGroup `protobuf:"bytes,1,opt,name=actual_lrp_group" json:"actual_lrp_group,omitempty"`
}

func NewActualLRPCreatedEvent 

func NewActualLRPCreatedEvent(actualLRPGroup *ActualLRPGroup) *ActualLRPCreatedEvent

func (*ActualLRPCreatedEvent) Equal 

func (this *ActualLRPCreatedEvent) Equal(that interface{}) bool

func (*ActualLRPCreatedEvent) EventType 

func (event *ActualLRPCreatedEvent) EventType() string

func (*ActualLRPCreatedEvent) GetActualLrpGroup 

func (m *ActualLRPCreatedEvent) GetActualLrpGroup() *ActualLRPGroup

func (*ActualLRPCreatedEvent) GoString 

func (this *ActualLRPCreatedEvent) GoString() string

func (*ActualLRPCreatedEvent) Key 

func (event *ActualLRPCreatedEvent) Key() string

func (*ActualLRPCreatedEvent) Marshal 

func (m *ActualLRPCreatedEvent) Marshal() (data []byte, err error)

func (*ActualLRPCreatedEvent) MarshalTo 

func (m *ActualLRPCreatedEvent) MarshalTo(data []byte) (int, error)

func (*ActualLRPCreatedEvent) ProtoMessage 

func (*ActualLRPCreatedEvent) ProtoMessage()

func (*ActualLRPCreatedEvent) Reset 

func (m *ActualLRPCreatedEvent) Reset()

func (*ActualLRPCreatedEvent) Size 

func (m *ActualLRPCreatedEvent) Size() (n int)

func (*ActualLRPCreatedEvent) String 

func (this *ActualLRPCreatedEvent) String() string

func (*ActualLRPCreatedEvent) Unmarshal 

func (m *ActualLRPCreatedEvent) Unmarshal(data []byte) error

type ActualLRPFilter 

type ActualLRPFilter struct {
	Domain string
	CellID string
}

type ActualLRPGroup 

type ActualLRPGroup struct {
	Instance   *ActualLRP `protobuf:"bytes,1,opt,name=instance" json:"instance,omitempty"`
	Evacuating *ActualLRP `protobuf:"bytes,2,opt,name=evacuating" json:"evacuating,omitempty"`
}

func NewRunningActualLRPGroup 

func NewRunningActualLRPGroup(actualLRP *ActualLRP) *ActualLRPGroup

func (*ActualLRPGroup) Equal 

func (this *ActualLRPGroup) Equal(that interface{}) bool

func (*ActualLRPGroup) GetEvacuating 

func (m *ActualLRPGroup) GetEvacuating() *ActualLRP

func (*ActualLRPGroup) GetInstance 

func (m *ActualLRPGroup) GetInstance() *ActualLRP

func (*ActualLRPGroup) GoString 

func (this *ActualLRPGroup) GoString() string

func (*ActualLRPGroup) Marshal 

func (m *ActualLRPGroup) Marshal() (data []byte, err error)

func (*ActualLRPGroup) MarshalTo 

func (m *ActualLRPGroup) MarshalTo(data []byte) (int, error)

func (*ActualLRPGroup) ProtoMessage 

func (*ActualLRPGroup) ProtoMessage()

func (*ActualLRPGroup) Reset 

func (m *ActualLRPGroup) Reset()

func (ActualLRPGroup) Resolve 

func (group ActualLRPGroup) Resolve() (*ActualLRP, bool)

func (*ActualLRPGroup) Size 

func (m *ActualLRPGroup) Size() (n int)

func (*ActualLRPGroup) String 

func (this *ActualLRPGroup) String() string

func (*ActualLRPGroup) Unmarshal 

func (m *ActualLRPGroup) Unmarshal(data []byte) error

type ActualLRPGroupByProcessGuidAndIndexRequest 

type ActualLRPGroupByProcessGuidAndIndexRequest struct {
	ProcessGuid string `protobuf:"bytes,1,opt,name=process_guid" json:"process_guid"`
	Index       int32  `protobuf:"varint,2,opt,name=index" json:"index"`
}

func (*ActualLRPGroupByProcessGuidAndIndexRequest) Equal 

func (this *ActualLRPGroupByProcessGuidAndIndexRequest) Equal(that interface{}) bool

func (*ActualLRPGroupByProcessGuidAndIndexRequest) GetIndex 

func (m *ActualLRPGroupByProcessGuidAndIndexRequest) GetIndex() int32

func (*ActualLRPGroupByProcessGuidAndIndexRequest) GetProcessGuid 

func (m *ActualLRPGroupByProcessGuidAndIndexRequest) GetProcessGuid() string

func (*ActualLRPGroupByProcessGuidAndIndexRequest) GoString 

func (this *ActualLRPGroupByProcessGuidAndIndexRequest) GoString() string

func (*ActualLRPGroupByProcessGuidAndIndexRequest) Marshal 

func (m *ActualLRPGroupByProcessGuidAndIndexRequest) Marshal() (data []byte, err error)

func (*ActualLRPGroupByProcessGuidAndIndexRequest) MarshalTo 

func (m *ActualLRPGroupByProcessGuidAndIndexRequest) MarshalTo(data []byte) (int, error)

func (*ActualLRPGroupByProcessGuidAndIndexRequest) ProtoMessage 

func (*ActualLRPGroupByProcessGuidAndIndexRequest) ProtoMessage()

func (*ActualLRPGroupByProcessGuidAndIndexRequest) Reset 

func (m *ActualLRPGroupByProcessGuidAndIndexRequest) Reset()

func (*ActualLRPGroupByProcessGuidAndIndexRequest) Size 

func (m *ActualLRPGroupByProcessGuidAndIndexRequest) Size() (n int)

func (*ActualLRPGroupByProcessGuidAndIndexRequest) String 

func (this *ActualLRPGroupByProcessGuidAndIndexRequest) String() string

func (*ActualLRPGroupByProcessGuidAndIndexRequest) Unmarshal 

func (m *ActualLRPGroupByProcessGuidAndIndexRequest) Unmarshal(data []byte) error

func (*ActualLRPGroupByProcessGuidAndIndexRequest) Validate 

func (request *ActualLRPGroupByProcessGuidAndIndexRequest) Validate() error

type ActualLRPGroupResponse 

type ActualLRPGroupResponse struct {
	Error          *Error          `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	ActualLrpGroup *ActualLRPGroup `protobuf:"bytes,2,opt,name=actual_lrp_group" json:"actual_lrp_group,omitempty"`
}

func (*ActualLRPGroupResponse) Equal 

func (this *ActualLRPGroupResponse) Equal(that interface{}) bool

func (*ActualLRPGroupResponse) GetActualLrpGroup 

func (m *ActualLRPGroupResponse) GetActualLrpGroup() *ActualLRPGroup

func (*ActualLRPGroupResponse) GetError 

func (m *ActualLRPGroupResponse) GetError() *Error

func (*ActualLRPGroupResponse) GoString 

func (this *ActualLRPGroupResponse) GoString() string

func (*ActualLRPGroupResponse) Marshal 

func (m *ActualLRPGroupResponse) Marshal() (data []byte, err error)

func (*ActualLRPGroupResponse) MarshalTo 

func (m *ActualLRPGroupResponse) MarshalTo(data []byte) (int, error)

func (*ActualLRPGroupResponse) ProtoMessage 

func (*ActualLRPGroupResponse) ProtoMessage()

func (*ActualLRPGroupResponse) Reset 

func (m *ActualLRPGroupResponse) Reset()

func (*ActualLRPGroupResponse) Size 

func (m *ActualLRPGroupResponse) Size() (n int)

func (*ActualLRPGroupResponse) String 

func (this *ActualLRPGroupResponse) String() string

func (*ActualLRPGroupResponse) Unmarshal 

func (m *ActualLRPGroupResponse) Unmarshal(data []byte) error

type ActualLRPGroupsByProcessGuidRequest 

type ActualLRPGroupsByProcessGuidRequest struct {
	ProcessGuid string `protobuf:"bytes,1,opt,name=process_guid" json:"process_guid"`
}

func (*ActualLRPGroupsByProcessGuidRequest) Equal 

func (this *ActualLRPGroupsByProcessGuidRequest) Equal(that interface{}) bool

func (*ActualLRPGroupsByProcessGuidRequest) GetProcessGuid 

func (m *ActualLRPGroupsByProcessGuidRequest) GetProcessGuid() string

func (*ActualLRPGroupsByProcessGuidRequest) GoString 

func (this *ActualLRPGroupsByProcessGuidRequest) GoString() string

func (*ActualLRPGroupsByProcessGuidRequest) Marshal 

func (m *ActualLRPGroupsByProcessGuidRequest) Marshal() (data []byte, err error)

func (*ActualLRPGroupsByProcessGuidRequest) MarshalTo 

func (m *ActualLRPGroupsByProcessGuidRequest) MarshalTo(data []byte) (int, error)

func (*ActualLRPGroupsByProcessGuidRequest) ProtoMessage 

func (*ActualLRPGroupsByProcessGuidRequest) ProtoMessage()

func (*ActualLRPGroupsByProcessGuidRequest) Reset 

func (m *ActualLRPGroupsByProcessGuidRequest) Reset()

func (*ActualLRPGroupsByProcessGuidRequest) Size 

func (m *ActualLRPGroupsByProcessGuidRequest) Size() (n int)

func (*ActualLRPGroupsByProcessGuidRequest) String 

func (this *ActualLRPGroupsByProcessGuidRequest) String() string

func (*ActualLRPGroupsByProcessGuidRequest) Unmarshal 

func (m *ActualLRPGroupsByProcessGuidRequest) Unmarshal(data []byte) error

func (*ActualLRPGroupsByProcessGuidRequest) Validate 

func (request *ActualLRPGroupsByProcessGuidRequest) Validate() error

type ActualLRPGroupsRequest 

type ActualLRPGroupsRequest struct {
	Domain string `protobuf:"bytes,1,opt,name=domain" json:"domain"`
	CellId string `protobuf:"bytes,2,opt,name=cell_id" json:"cell_id"`
}

func (*ActualLRPGroupsRequest) Equal 

func (this *ActualLRPGroupsRequest) Equal(that interface{}) bool

func (*ActualLRPGroupsRequest) GetCellId 

func (m *ActualLRPGroupsRequest) GetCellId() string

func (*ActualLRPGroupsRequest) GetDomain 

func (m *ActualLRPGroupsRequest) GetDomain() string

func (*ActualLRPGroupsRequest) GoString 

func (this *ActualLRPGroupsRequest) GoString() string

func (*ActualLRPGroupsRequest) Marshal 

func (m *ActualLRPGroupsRequest) Marshal() (data []byte, err error)

func (*ActualLRPGroupsRequest) MarshalTo 

func (m *ActualLRPGroupsRequest) MarshalTo(data []byte) (int, error)

func (*ActualLRPGroupsRequest) ProtoMessage 

func (*ActualLRPGroupsRequest) ProtoMessage()

func (*ActualLRPGroupsRequest) Reset 

func (m *ActualLRPGroupsRequest) Reset()

func (*ActualLRPGroupsRequest) Size 

func (m *ActualLRPGroupsRequest) Size() (n int)

func (*ActualLRPGroupsRequest) String 

func (this *ActualLRPGroupsRequest) String() string

func (*ActualLRPGroupsRequest) Unmarshal 

func (m *ActualLRPGroupsRequest) Unmarshal(data []byte) error

func (*ActualLRPGroupsRequest) Validate 

func (request *ActualLRPGroupsRequest) Validate() error

type ActualLRPGroupsResponse 

type ActualLRPGroupsResponse struct {
	Error           *Error            `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	ActualLrpGroups []*ActualLRPGroup `protobuf:"bytes,2,rep,name=actual_lrp_groups" json:"actual_lrp_groups,omitempty"`
}

func (*ActualLRPGroupsResponse) Equal 

func (this *ActualLRPGroupsResponse) Equal(that interface{}) bool

func (*ActualLRPGroupsResponse) GetActualLrpGroups 

func (m *ActualLRPGroupsResponse) GetActualLrpGroups() []*ActualLRPGroup

func (*ActualLRPGroupsResponse) GetError 

func (m *ActualLRPGroupsResponse) GetError() *Error

func (*ActualLRPGroupsResponse) GoString 

func (this *ActualLRPGroupsResponse) GoString() string

func (*ActualLRPGroupsResponse) Marshal 

func (m *ActualLRPGroupsResponse) Marshal() (data []byte, err error)

func (*ActualLRPGroupsResponse) MarshalTo 

func (m *ActualLRPGroupsResponse) MarshalTo(data []byte) (int, error)

func (*ActualLRPGroupsResponse) ProtoMessage 

func (*ActualLRPGroupsResponse) ProtoMessage()

func (*ActualLRPGroupsResponse) Reset 

func (m *ActualLRPGroupsResponse) Reset()

func (*ActualLRPGroupsResponse) Size 

func (m *ActualLRPGroupsResponse) Size() (n int)

func (*ActualLRPGroupsResponse) String 

func (this *ActualLRPGroupsResponse) String() string

func (*ActualLRPGroupsResponse) Unmarshal 

func (m *ActualLRPGroupsResponse) Unmarshal(data []byte) error

type ActualLRPInstanceKey 

type ActualLRPInstanceKey struct {
	InstanceGuid string `protobuf:"bytes,1,opt,name=instance_guid" json:"instance_guid"`
	CellId       string `protobuf:"bytes,2,opt,name=cell_id" json:"cell_id"`
}

func NewActualLRPInstanceKey 

func NewActualLRPInstanceKey(instanceGuid string, cellId string) ActualLRPInstanceKey

func (ActualLRPInstanceKey) Empty 

func (key ActualLRPInstanceKey) Empty() bool

func (*ActualLRPInstanceKey) Equal 

func (this *ActualLRPInstanceKey) Equal(that interface{}) bool

func (*ActualLRPInstanceKey) GetCellId 

func (m *ActualLRPInstanceKey) GetCellId() string

func (*ActualLRPInstanceKey) GetInstanceGuid 

func (m *ActualLRPInstanceKey) GetInstanceGuid() string

func (*ActualLRPInstanceKey) GoString 

func (this *ActualLRPInstanceKey) GoString() string

func (*ActualLRPInstanceKey) Marshal 

func (m *ActualLRPInstanceKey) Marshal() (data []byte, err error)

func (*ActualLRPInstanceKey) MarshalTo 

func (m *ActualLRPInstanceKey) MarshalTo(data []byte) (int, error)

func (*ActualLRPInstanceKey) ProtoMessage 

func (*ActualLRPInstanceKey) ProtoMessage()

func (*ActualLRPInstanceKey) Reset 

func (m *ActualLRPInstanceKey) Reset()

func (*ActualLRPInstanceKey) Size 

func (m *ActualLRPInstanceKey) Size() (n int)

func (*ActualLRPInstanceKey) String 

func (this *ActualLRPInstanceKey) String() string

func (*ActualLRPInstanceKey) Unmarshal 

func (m *ActualLRPInstanceKey) Unmarshal(data []byte) error

func (*ActualLRPInstanceKey) Validate 

func (key *ActualLRPInstanceKey) Validate() error

type ActualLRPKey 

type ActualLRPKey struct {
	ProcessGuid string `protobuf:"bytes,1,opt,name=process_guid" json:"process_guid"`
	Index       int32  `protobuf:"varint,2,opt,name=index" json:"index"`
	Domain      string `protobuf:"bytes,3,opt,name=domain" json:"domain"`
}

func NewActualLRPKey 

func NewActualLRPKey(processGuid string, index int32, domain string) ActualLRPKey

func (*ActualLRPKey) Equal 

func (this *ActualLRPKey) Equal(that interface{}) bool

func (*ActualLRPKey) GetDomain 

func (m *ActualLRPKey) GetDomain() string

func (*ActualLRPKey) GetIndex 

func (m *ActualLRPKey) GetIndex() int32

func (*ActualLRPKey) GetProcessGuid 

func (m *ActualLRPKey) GetProcessGuid() string

func (*ActualLRPKey) GoString 

func (this *ActualLRPKey) GoString() string

func (*ActualLRPKey) Marshal 

func (m *ActualLRPKey) Marshal() (data []byte, err error)

func (*ActualLRPKey) MarshalTo 

func (m *ActualLRPKey) MarshalTo(data []byte) (int, error)

func (*ActualLRPKey) ProtoMessage 

func (*ActualLRPKey) ProtoMessage()

func (*ActualLRPKey) Reset 

func (m *ActualLRPKey) Reset()

func (*ActualLRPKey) Size 

func (m *ActualLRPKey) Size() (n int)

func (*ActualLRPKey) String 

func (this *ActualLRPKey) String() string

func (*ActualLRPKey) Unmarshal 

func (m *ActualLRPKey) Unmarshal(data []byte) error

func (*ActualLRPKey) Validate 

func (key *ActualLRPKey) Validate() error

type ActualLRPLifecycleResponse 

type ActualLRPLifecycleResponse struct {
	Error *Error `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
}

func (*ActualLRPLifecycleResponse) Equal 

func (this *ActualLRPLifecycleResponse) Equal(that interface{}) bool

func (*ActualLRPLifecycleResponse) GetError 

func (m *ActualLRPLifecycleResponse) GetError() *Error

func (*ActualLRPLifecycleResponse) GoString 

func (this *ActualLRPLifecycleResponse) GoString() string

func (*ActualLRPLifecycleResponse) Marshal 

func (m *ActualLRPLifecycleResponse) Marshal() (data []byte, err error)

func (*ActualLRPLifecycleResponse) MarshalTo 

func (m *ActualLRPLifecycleResponse) MarshalTo(data []byte) (int, error)

func (*ActualLRPLifecycleResponse) ProtoMessage 

func (*ActualLRPLifecycleResponse) ProtoMessage()

func (*ActualLRPLifecycleResponse) Reset 

func (m *ActualLRPLifecycleResponse) Reset()

func (*ActualLRPLifecycleResponse) Size 

func (m *ActualLRPLifecycleResponse) Size() (n int)

func (*ActualLRPLifecycleResponse) String 

func (this *ActualLRPLifecycleResponse) String() string

func (*ActualLRPLifecycleResponse) Unmarshal 

func (m *ActualLRPLifecycleResponse) Unmarshal(data []byte) error

type ActualLRPNetInfo 

type ActualLRPNetInfo struct {
	Address string         `protobuf:"bytes,1,opt,name=address" json:"address"`
	Ports   []*PortMapping `protobuf:"bytes,2,rep,name=ports" json:"ports"`
}

func EmptyActualLRPNetInfo 

func EmptyActualLRPNetInfo() ActualLRPNetInfo

func NewActualLRPNetInfo 

func NewActualLRPNetInfo(address string, ports ...*PortMapping) ActualLRPNetInfo

func (ActualLRPNetInfo) Empty 

func (info ActualLRPNetInfo) Empty() bool

func (*ActualLRPNetInfo) Equal 

func (this *ActualLRPNetInfo) Equal(that interface{}) bool

func (*ActualLRPNetInfo) GetAddress 

func (m *ActualLRPNetInfo) GetAddress() string

func (*ActualLRPNetInfo) GetPorts 

func (m *ActualLRPNetInfo) GetPorts() []*PortMapping

func (*ActualLRPNetInfo) GoString 

func (this *ActualLRPNetInfo) GoString() string

func (*ActualLRPNetInfo) Marshal 

func (m *ActualLRPNetInfo) Marshal() (data []byte, err error)

func (*ActualLRPNetInfo) MarshalTo 

func (m *ActualLRPNetInfo) MarshalTo(data []byte) (int, error)

func (*ActualLRPNetInfo) ProtoMessage 

func (*ActualLRPNetInfo) ProtoMessage()

func (*ActualLRPNetInfo) Reset 

func (m *ActualLRPNetInfo) Reset()

func (*ActualLRPNetInfo) Size 

func (m *ActualLRPNetInfo) Size() (n int)

func (*ActualLRPNetInfo) String 

func (this *ActualLRPNetInfo) String() string

func (*ActualLRPNetInfo) Unmarshal 

func (m *ActualLRPNetInfo) Unmarshal(data []byte) error

func (*ActualLRPNetInfo) Validate 

func (key *ActualLRPNetInfo) Validate() error

type ActualLRPRemovedEvent 

type ActualLRPRemovedEvent struct {
	ActualLrpGroup *ActualLRPGroup `protobuf:"bytes,1,opt,name=actual_lrp_group" json:"actual_lrp_group,omitempty"`
}

func NewActualLRPRemovedEvent 

func NewActualLRPRemovedEvent(actualLRPGroup *ActualLRPGroup) *ActualLRPRemovedEvent

func (*ActualLRPRemovedEvent) Equal 

func (this *ActualLRPRemovedEvent) Equal(that interface{}) bool

func (*ActualLRPRemovedEvent) EventType 

func (event *ActualLRPRemovedEvent) EventType() string

func (*ActualLRPRemovedEvent) GetActualLrpGroup 

func (m *ActualLRPRemovedEvent) GetActualLrpGroup() *ActualLRPGroup

func (*ActualLRPRemovedEvent) GoString 

func (this *ActualLRPRemovedEvent) GoString() string

func (*ActualLRPRemovedEvent) Key 

func (event *ActualLRPRemovedEvent) Key() string

func (*ActualLRPRemovedEvent) Marshal 

func (m *ActualLRPRemovedEvent) Marshal() (data []byte, err error)

func (*ActualLRPRemovedEvent) MarshalTo 

func (m *ActualLRPRemovedEvent) MarshalTo(data []byte) (int, error)

func (*ActualLRPRemovedEvent) ProtoMessage 

func (*ActualLRPRemovedEvent) ProtoMessage()

func (*ActualLRPRemovedEvent) Reset 

func (m *ActualLRPRemovedEvent) Reset()

func (*ActualLRPRemovedEvent) Size 

func (m *ActualLRPRemovedEvent) Size() (n int)

func (*ActualLRPRemovedEvent) String 

func (this *ActualLRPRemovedEvent) String() string

func (*ActualLRPRemovedEvent) Unmarshal 

func (m *ActualLRPRemovedEvent) Unmarshal(data []byte) error

type BBSPresence 

type BBSPresence struct {
	ID  string `json:"id"`
	URL string `json:"url"`
}

func NewBBSPresence 

func NewBBSPresence(id, url string) BBSPresence

func (BBSPresence) Validate 

func (p BBSPresence) Validate() error

type CachedDependency 

type CachedDependency struct {
	Name      string `protobuf:"bytes,1,opt,name=name" json:"name"`
	From      string `protobuf:"bytes,2,opt,name=from" json:"from"`
	To        string `protobuf:"bytes,3,opt,name=to" json:"to"`
	CacheKey  string `protobuf:"bytes,4,opt,name=cache_key" json:"cache_key"`
	LogSource string `protobuf:"bytes,5,opt,name=log_source" json:"log_source"`
}

func (*CachedDependency) Equal 

func (this *CachedDependency) Equal(that interface{}) bool

func (*CachedDependency) GetCacheKey 

func (m *CachedDependency) GetCacheKey() string

func (*CachedDependency) GetFrom 

func (m *CachedDependency) GetFrom() string

func (*CachedDependency) GetLogSource 

func (m *CachedDependency) GetLogSource() string

func (*CachedDependency) GetName 

func (m *CachedDependency) GetName() string

func (*CachedDependency) GetTo 

func (m *CachedDependency) GetTo() string

func (*CachedDependency) GoString 

func (this *CachedDependency) GoString() string

func (*CachedDependency) Marshal 

func (m *CachedDependency) Marshal() (data []byte, err error)

func (*CachedDependency) MarshalTo 

func (m *CachedDependency) MarshalTo(data []byte) (int, error)

func (*CachedDependency) MigrateFromVersion 

func (c *CachedDependency) MigrateFromVersion(v format.Version) error

func (*CachedDependency) ProtoMessage 

func (*CachedDependency) ProtoMessage()

func (*CachedDependency) Reset 

func (m *CachedDependency) Reset()

func (*CachedDependency) Size 

func (m *CachedDependency) Size() (n int)

func (*CachedDependency) String 

func (this *CachedDependency) String() string

func (*CachedDependency) Unmarshal 

func (m *CachedDependency) Unmarshal(data []byte) error

func (*CachedDependency) Validate 

func (a *CachedDependency) Validate() error

func (*CachedDependency) Version 

func (c *CachedDependency) Version() format.Version

type CellCapacity 

type CellCapacity struct {
	MemoryMb   int32 `protobuf:"varint,1,opt,name=memory_mb" json:"memory_mb"`
	DiskMb     int32 `protobuf:"varint,2,opt,name=disk_mb" json:"disk_mb"`
	Containers int32 `protobuf:"varint,3,opt,name=containers" json:"containers"`
}

func NewCellCapacity 

func NewCellCapacity(memoryMB, diskMB, containers int32) CellCapacity

func (*CellCapacity) Equal 

func (this *CellCapacity) Equal(that interface{}) bool

func (*CellCapacity) GetContainers 

func (m *CellCapacity) GetContainers() int32

func (*CellCapacity) GetDiskMb 

func (m *CellCapacity) GetDiskMb() int32

func (*CellCapacity) GetMemoryMb 

func (m *CellCapacity) GetMemoryMb() int32

func (*CellCapacity) GoString 

func (this *CellCapacity) GoString() string

func (*CellCapacity) Marshal 

func (m *CellCapacity) Marshal() (data []byte, err error)

func (*CellCapacity) MarshalTo 

func (m *CellCapacity) MarshalTo(data []byte) (int, error)

func (*CellCapacity) ProtoMessage 

func (*CellCapacity) ProtoMessage()

func (*CellCapacity) Reset 

func (m *CellCapacity) Reset()

func (*CellCapacity) Size 

func (m *CellCapacity) Size() (n int)

func (*CellCapacity) String 

func (this *CellCapacity) String() string

func (*CellCapacity) Unmarshal 

func (m *CellCapacity) Unmarshal(data []byte) error

func (CellCapacity) Validate 

func (cap CellCapacity) Validate() error

type CellDisappearedEvent 

type CellDisappearedEvent struct {
	IDs []string
}

func NewCellDisappearedEvent 

func NewCellDisappearedEvent(ids []string) CellDisappearedEvent

func (CellDisappearedEvent) CellIDs 

func (e CellDisappearedEvent) CellIDs() []string

func (CellDisappearedEvent) EventType 

func (CellDisappearedEvent) EventType() string

type CellEvent 

type CellEvent interface {
	EventType() string
	CellIDs() []string
}

type CellPresence 

type CellPresence struct {
	CellId     string        `protobuf:"bytes,1,opt,name=cell_id" json:"cell_id"`
	RepAddress string        `protobuf:"bytes,2,opt,name=rep_address" json:"rep_address"`
	Zone       string        `protobuf:"bytes,3,opt,name=zone" json:"zone"`
	Capacity   *CellCapacity `protobuf:"bytes,4,opt,name=capacity" json:"capacity,omitempty"`
}

func NewCellPresence 

func NewCellPresence(cellID, repAddress, zone string, capacity CellCapacity, rootFSProviders, preloadedRootFSes []string) CellPresence

func (*CellPresence) Equal 

func (this *CellPresence) Equal(that interface{}) bool

func (*CellPresence) GetCapacity 

func (m *CellPresence) GetCapacity() *CellCapacity

func (*CellPresence) GetCellId 

func (m *CellPresence) GetCellId() string

func (*CellPresence) GetRepAddress 

func (m *CellPresence) GetRepAddress() string

func (*CellPresence) GetZone 

func (m *CellPresence) GetZone() string

func (*CellPresence) GoString 

func (this *CellPresence) GoString() string

func (*CellPresence) Marshal 

func (m *CellPresence) Marshal() (data []byte, err error)

func (*CellPresence) MarshalTo 

func (m *CellPresence) MarshalTo(data []byte) (int, error)

func (*CellPresence) ProtoMessage 

func (*CellPresence) ProtoMessage()

func (*CellPresence) Reset 

func (m *CellPresence) Reset()

func (*CellPresence) Size 

func (m *CellPresence) Size() (n int)

func (*CellPresence) String 

func (this *CellPresence) String() string

func (*CellPresence) Unmarshal 

func (m *CellPresence) Unmarshal(data []byte) error

func (CellPresence) Validate 

func (c CellPresence) Validate() error

type CellSet 

type CellSet map[string]*CellPresence

func NewCellSet 

func NewCellSet() CellSet

func NewCellSetFromList 

func NewCellSetFromList(cells []*CellPresence) CellSet

func (CellSet) Add 

func (set CellSet) Add(cell *CellPresence)

func (CellSet) Each 

func (set CellSet) Each(predicate func(cell *CellPresence))

func (CellSet) HasCellID 

func (set CellSet) HasCellID(cellID string) bool

type CellsResponse 

type CellsResponse struct {
	Error *Error          `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	Cells []*CellPresence `protobuf:"bytes,2,rep,name=cells" json:"cells,omitempty"`
}

func (*CellsResponse) Equal 

func (this *CellsResponse) Equal(that interface{}) bool

func (*CellsResponse) GetCells 

func (m *CellsResponse) GetCells() []*CellPresence

func (*CellsResponse) GetError 

func (m *CellsResponse) GetError() *Error

func (*CellsResponse) GoString 

func (this *CellsResponse) GoString() string

func (*CellsResponse) Marshal 

func (m *CellsResponse) Marshal() (data []byte, err error)

func (*CellsResponse) MarshalTo 

func (m *CellsResponse) MarshalTo(data []byte) (int, error)

func (*CellsResponse) ProtoMessage 

func (*CellsResponse) ProtoMessage()

func (*CellsResponse) Reset 

func (m *CellsResponse) Reset()

func (*CellsResponse) Size 

func (m *CellsResponse) Size() (n int)

func (*CellsResponse) String 

func (this *CellsResponse) String() string

func (*CellsResponse) Unmarshal 

func (m *CellsResponse) Unmarshal(data []byte) error

type ClaimActualLRPRequest 

type ClaimActualLRPRequest struct {
	ProcessGuid          string                `protobuf:"bytes,1,opt,name=process_guid" json:"process_guid"`
	Index                int32                 `protobuf:"varint,2,opt,name=index" json:"index"`
	ActualLrpInstanceKey *ActualLRPInstanceKey `protobuf:"bytes,3,opt,name=actual_lrp_instance_key" json:"actual_lrp_instance_key,omitempty"`
}

func (*ClaimActualLRPRequest) Equal 

func (this *ClaimActualLRPRequest) Equal(that interface{}) bool

func (*ClaimActualLRPRequest) GetActualLrpInstanceKey 

func (m *ClaimActualLRPRequest) GetActualLrpInstanceKey() *ActualLRPInstanceKey

func (*ClaimActualLRPRequest) GetIndex 

func (m *ClaimActualLRPRequest) GetIndex() int32

func (*ClaimActualLRPRequest) GetProcessGuid 

func (m *ClaimActualLRPRequest) GetProcessGuid() string

func (*ClaimActualLRPRequest) GoString 

func (this *ClaimActualLRPRequest) GoString() string

func (*ClaimActualLRPRequest) Marshal 

func (m *ClaimActualLRPRequest) Marshal() (data []byte, err error)

func (*ClaimActualLRPRequest) MarshalTo 

func (m *ClaimActualLRPRequest) MarshalTo(data []byte) (int, error)

func (*ClaimActualLRPRequest) ProtoMessage 

func (*ClaimActualLRPRequest) ProtoMessage()

func (*ClaimActualLRPRequest) Reset 

func (m *ClaimActualLRPRequest) Reset()

func (*ClaimActualLRPRequest) Size 

func (m *ClaimActualLRPRequest) Size() (n int)

func (*ClaimActualLRPRequest) String 

func (this *ClaimActualLRPRequest) String() string

func (*ClaimActualLRPRequest) Unmarshal 

func (m *ClaimActualLRPRequest) Unmarshal(data []byte) error

func (*ClaimActualLRPRequest) Validate 

func (request *ClaimActualLRPRequest) Validate() error

type CodependentAction 

type CodependentAction struct {
	Actions   []*Action `protobuf:"bytes,1,rep,name=actions" json:"actions,omitempty"`
	LogSource string    `protobuf:"bytes,2,opt,name=log_source" json:"log_source,omitempty"`
}

func Codependent 

func Codependent(actions ...ActionInterface) *CodependentAction

func (*CodependentAction) ActionType 

func (a *CodependentAction) ActionType() string

func (*CodependentAction) Equal 

func (this *CodependentAction) Equal(that interface{}) bool

func (*CodependentAction) GetActions 

func (m *CodependentAction) GetActions() []*Action

func (*CodependentAction) GetLogSource 

func (m *CodependentAction) GetLogSource() string

func (*CodependentAction) GoString 

func (this *CodependentAction) GoString() string

func (*CodependentAction) Marshal 

func (m *CodependentAction) Marshal() (data []byte, err error)

func (*CodependentAction) MarshalTo 

func (m *CodependentAction) MarshalTo(data []byte) (int, error)

func (*CodependentAction) MigrateFromVersion 

func (*CodependentAction) MigrateFromVersion(v format.Version) error

func (*CodependentAction) ProtoMessage 

func (*CodependentAction) ProtoMessage()

func (*CodependentAction) Reset 

func (m *CodependentAction) Reset()

func (*CodependentAction) Size 

func (m *CodependentAction) Size() (n int)

func (*CodependentAction) String 

func (this *CodependentAction) String() string

func (*CodependentAction) Unmarshal 

func (m *CodependentAction) Unmarshal(data []byte) error

func (CodependentAction) Validate 

func (a CodependentAction) Validate() error

func (*CodependentAction) Version 

func (*CodependentAction) Version() format.Version

type CompleteTaskRequest 

type CompleteTaskRequest struct {
	TaskGuid      string `protobuf:"bytes,1,opt,name=task_guid" json:"task_guid"`
	CellId        string `protobuf:"bytes,2,opt,name=cell_id" json:"cell_id"`
	Failed        bool   `protobuf:"varint,3,opt,name=failed" json:"failed"`
	FailureReason string `protobuf:"bytes,4,opt,name=failure_reason" json:"failure_reason"`
	Result        string `protobuf:"bytes,5,opt,name=result" json:"result"`
}

func (*CompleteTaskRequest) Equal 

func (this *CompleteTaskRequest) Equal(that interface{}) bool

func (*CompleteTaskRequest) GetCellId 

func (m *CompleteTaskRequest) GetCellId() string

func (*CompleteTaskRequest) GetFailed 

func (m *CompleteTaskRequest) GetFailed() bool

func (*CompleteTaskRequest) GetFailureReason 

func (m *CompleteTaskRequest) GetFailureReason() string

func (*CompleteTaskRequest) GetResult 

func (m *CompleteTaskRequest) GetResult() string

func (*CompleteTaskRequest) GetTaskGuid 

func (m *CompleteTaskRequest) GetTaskGuid() string

func (*CompleteTaskRequest) GoString 

func (this *CompleteTaskRequest) GoString() string

func (*CompleteTaskRequest) Marshal 

func (m *CompleteTaskRequest) Marshal() (data []byte, err error)

func (*CompleteTaskRequest) MarshalTo 

func (m *CompleteTaskRequest) MarshalTo(data []byte) (int, error)

func (*CompleteTaskRequest) ProtoMessage 

func (*CompleteTaskRequest) ProtoMessage()

func (*CompleteTaskRequest) Reset 

func (m *CompleteTaskRequest) Reset()

func (*CompleteTaskRequest) Size 

func (m *CompleteTaskRequest) Size() (n int)

func (*CompleteTaskRequest) String 

func (this *CompleteTaskRequest) String() string

func (*CompleteTaskRequest) Unmarshal 

func (m *CompleteTaskRequest) Unmarshal(data []byte) error

func (*CompleteTaskRequest) Validate 

func (req *CompleteTaskRequest) Validate() error

type ConvergeLRPsResponse 

type ConvergeLRPsResponse struct {
	Error *Error `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
}

func (*ConvergeLRPsResponse) Equal 

func (this *ConvergeLRPsResponse) Equal(that interface{}) bool

func (*ConvergeLRPsResponse) GetError 

func (m *ConvergeLRPsResponse) GetError() *Error

func (*ConvergeLRPsResponse) GoString 

func (this *ConvergeLRPsResponse) GoString() string

func (*ConvergeLRPsResponse) Marshal 

func (m *ConvergeLRPsResponse) Marshal() (data []byte, err error)

func (*ConvergeLRPsResponse) MarshalTo 

func (m *ConvergeLRPsResponse) MarshalTo(data []byte) (int, error)

func (*ConvergeLRPsResponse) ProtoMessage 

func (*ConvergeLRPsResponse) ProtoMessage()

func (*ConvergeLRPsResponse) Reset 

func (m *ConvergeLRPsResponse) Reset()

func (*ConvergeLRPsResponse) Size 

func (m *ConvergeLRPsResponse) Size() (n int)

func (*ConvergeLRPsResponse) String 

func (this *ConvergeLRPsResponse) String() string

func (*ConvergeLRPsResponse) Unmarshal 

func (m *ConvergeLRPsResponse) Unmarshal(data []byte) error

type ConvergeTasksRequest 

type ConvergeTasksRequest struct {
	KickTaskDuration            int64 `protobuf:"varint,1,opt,name=kick_task_duration" json:"kick_task_duration"`
	ExpirePendingTaskDuration   int64 `protobuf:"varint,2,opt,name=expire_pending_task_duration" json:"expire_pending_task_duration"`
	ExpireCompletedTaskDuration int64 `protobuf:"varint,3,opt,name=expire_completed_task_duration" json:"expire_completed_task_duration"`
}

func (*ConvergeTasksRequest) Equal 

func (this *ConvergeTasksRequest) Equal(that interface{}) bool

func (*ConvergeTasksRequest) GetExpireCompletedTaskDuration 

func (m *ConvergeTasksRequest) GetExpireCompletedTaskDuration() int64

func (*ConvergeTasksRequest) GetExpirePendingTaskDuration 

func (m *ConvergeTasksRequest) GetExpirePendingTaskDuration() int64

func (*ConvergeTasksRequest) GetKickTaskDuration 

func (m *ConvergeTasksRequest) GetKickTaskDuration() int64

func (*ConvergeTasksRequest) GoString 

func (this *ConvergeTasksRequest) GoString() string

func (*ConvergeTasksRequest) Marshal 

func (m *ConvergeTasksRequest) Marshal() (data []byte, err error)

func (*ConvergeTasksRequest) MarshalTo 

func (m *ConvergeTasksRequest) MarshalTo(data []byte) (int, error)

func (*ConvergeTasksRequest) ProtoMessage 

func (*ConvergeTasksRequest) ProtoMessage()

func (*ConvergeTasksRequest) Reset 

func (m *ConvergeTasksRequest) Reset()

func (*ConvergeTasksRequest) Size 

func (m *ConvergeTasksRequest) Size() (n int)

func (*ConvergeTasksRequest) String 

func (this *ConvergeTasksRequest) String() string

func (*ConvergeTasksRequest) Unmarshal 

func (m *ConvergeTasksRequest) Unmarshal(data []byte) error

func (*ConvergeTasksRequest) Validate 

func (request *ConvergeTasksRequest) Validate() error

type ConvergeTasksResponse 

type ConvergeTasksResponse struct {
	Error *Error `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
}

func (*ConvergeTasksResponse) Equal 

func (this *ConvergeTasksResponse) Equal(that interface{}) bool

func (*ConvergeTasksResponse) GetError 

func (m *ConvergeTasksResponse) GetError() *Error

func (*ConvergeTasksResponse) GoString 

func (this *ConvergeTasksResponse) GoString() string

func (*ConvergeTasksResponse) Marshal 

func (m *ConvergeTasksResponse) Marshal() (data []byte, err error)

func (*ConvergeTasksResponse) MarshalTo 

func (m *ConvergeTasksResponse) MarshalTo(data []byte) (int, error)

func (*ConvergeTasksResponse) ProtoMessage 

func (*ConvergeTasksResponse) ProtoMessage()

func (*ConvergeTasksResponse) Reset 

func (m *ConvergeTasksResponse) Reset()

func (*ConvergeTasksResponse) Size 

func (m *ConvergeTasksResponse) Size() (n int)

func (*ConvergeTasksResponse) String 

func (this *ConvergeTasksResponse) String() string

func (*ConvergeTasksResponse) Unmarshal 

func (m *ConvergeTasksResponse) Unmarshal(data []byte) error

type ConvergenceChanges 

type ConvergenceChanges struct {
	ActualLRPsForExtraIndices      []*ActualLRP
	ActualLRPKeysForMissingIndices []*ActualLRPKey
	ActualLRPsWithMissingCells     []*ActualLRP
	RestartableCrashedActualLRPs   []*ActualLRP
	StaleUnclaimedActualLRPs       []*ActualLRP
}

type ConvergenceInput 

type ConvergenceInput struct {
	AllProcessGuids map[string]struct{}
	DesiredLRPs     map[string]*DesiredLRP
	ActualLRPs      map[string]map[int32]*ActualLRP
	Domains         DomainSet
	Cells           CellSet
}

type CrashActualLRPRequest 

type CrashActualLRPRequest struct {
	ActualLrpKey         *ActualLRPKey         `protobuf:"bytes,1,opt,name=actual_lrp_key" json:"actual_lrp_key,omitempty"`
	ActualLrpInstanceKey *ActualLRPInstanceKey `protobuf:"bytes,2,opt,name=actual_lrp_instance_key" json:"actual_lrp_instance_key,omitempty"`
	ErrorMessage         string                `protobuf:"bytes,3,opt,name=error_message" json:"error_message"`
}

func (*CrashActualLRPRequest) Equal 

func (this *CrashActualLRPRequest) Equal(that interface{}) bool

func (*CrashActualLRPRequest) GetActualLrpInstanceKey 

func (m *CrashActualLRPRequest) GetActualLrpInstanceKey() *ActualLRPInstanceKey

func (*CrashActualLRPRequest) GetActualLrpKey 

func (m *CrashActualLRPRequest) GetActualLrpKey() *ActualLRPKey

func (*CrashActualLRPRequest) GetErrorMessage 

func (m *CrashActualLRPRequest) GetErrorMessage() string

func (*CrashActualLRPRequest) GoString 

func (this *CrashActualLRPRequest) GoString() string

func (*CrashActualLRPRequest) Marshal 

func (m *CrashActualLRPRequest) Marshal() (data []byte, err error)

func (*CrashActualLRPRequest) MarshalTo 

func (m *CrashActualLRPRequest) MarshalTo(data []byte) (int, error)

func (*CrashActualLRPRequest) ProtoMessage 

func (*CrashActualLRPRequest) ProtoMessage()

func (*CrashActualLRPRequest) Reset 

func (m *CrashActualLRPRequest) Reset()

func (*CrashActualLRPRequest) Size 

func (m *CrashActualLRPRequest) Size() (n int)

func (*CrashActualLRPRequest) String 

func (this *CrashActualLRPRequest) String() string

func (*CrashActualLRPRequest) Unmarshal 

func (m *CrashActualLRPRequest) Unmarshal(data []byte) error

func (*CrashActualLRPRequest) Validate 

func (request *CrashActualLRPRequest) Validate() error

type DesireLRPRequest 

type DesireLRPRequest struct {
	DesiredLrp *DesiredLRP `protobuf:"bytes,1,opt,name=desired_lrp" json:"desired_lrp,omitempty"`
}

func (*DesireLRPRequest) Equal 

func (this *DesireLRPRequest) Equal(that interface{}) bool

func (*DesireLRPRequest) GetDesiredLrp 

func (m *DesireLRPRequest) GetDesiredLrp() *DesiredLRP

func (*DesireLRPRequest) GoString 

func (this *DesireLRPRequest) GoString() string

func (*DesireLRPRequest) Marshal 

func (m *DesireLRPRequest) Marshal() (data []byte, err error)

func (*DesireLRPRequest) MarshalTo 

func (m *DesireLRPRequest) MarshalTo(data []byte) (int, error)

func (*DesireLRPRequest) ProtoMessage 

func (*DesireLRPRequest) ProtoMessage()

func (*DesireLRPRequest) Reset 

func (m *DesireLRPRequest) Reset()

func (*DesireLRPRequest) Size 

func (m *DesireLRPRequest) Size() (n int)

func (*DesireLRPRequest) String 

func (this *DesireLRPRequest) String() string

func (*DesireLRPRequest) Unmarshal 

func (m *DesireLRPRequest) Unmarshal(data []byte) error

func (*DesireLRPRequest) Validate 

func (request *DesireLRPRequest) Validate() error

type DesireTaskRequest 

type DesireTaskRequest struct {
	TaskDefinition *TaskDefinition `protobuf:"bytes,1,opt,name=task_definition" json:"task_definition"`
	TaskGuid       string          `protobuf:"bytes,2,opt,name=task_guid" json:"task_guid"`
	Domain         string          `protobuf:"bytes,3,opt,name=domain" json:"domain"`
}

func (*DesireTaskRequest) Equal 

func (this *DesireTaskRequest) Equal(that interface{}) bool

func (*DesireTaskRequest) GetDomain 

func (m *DesireTaskRequest) GetDomain() string

func (*DesireTaskRequest) GetTaskDefinition 

func (m *DesireTaskRequest) GetTaskDefinition() *TaskDefinition

func (*DesireTaskRequest) GetTaskGuid 

func (m *DesireTaskRequest) GetTaskGuid() string

func (*DesireTaskRequest) GoString 

func (this *DesireTaskRequest) GoString() string

func (*DesireTaskRequest) Marshal 

func (m *DesireTaskRequest) Marshal() (data []byte, err error)

func (*DesireTaskRequest) MarshalTo 

func (m *DesireTaskRequest) MarshalTo(data []byte) (int, error)

func (*DesireTaskRequest) ProtoMessage 

func (*DesireTaskRequest) ProtoMessage()

func (*DesireTaskRequest) Reset 

func (m *DesireTaskRequest) Reset()

func (*DesireTaskRequest) Size 

func (m *DesireTaskRequest) Size() (n int)

func (*DesireTaskRequest) String 

func (this *DesireTaskRequest) String() string

func (*DesireTaskRequest) Unmarshal 

func (m *DesireTaskRequest) Unmarshal(data []byte) error

func (*DesireTaskRequest) Validate 

func (req *DesireTaskRequest) Validate() error

type DesiredLRP 

type DesiredLRP struct {
	ProcessGuid                   string                 `protobuf:"bytes,1,opt,name=process_guid" json:"process_guid"`
	Domain                        string                 `protobuf:"bytes,2,opt,name=domain" json:"domain"`
	RootFs                        string                 `protobuf:"bytes,3,opt,name=root_fs" json:"rootfs"`
	Instances                     int32                  `protobuf:"varint,4,opt,name=instances" json:"instances"`
	EnvironmentVariables          []*EnvironmentVariable `protobuf:"bytes,5,rep,name=environment_variables" json:"env"`
	Setup                         *Action                `protobuf:"bytes,6,opt,name=setup" json:"setup,omitempty"`
	Action                        *Action                `protobuf:"bytes,7,opt,name=action" json:"action,omitempty"`
	StartTimeout                  uint32                 `protobuf:"varint,8,opt,name=start_timeout" json:"start_timeout"`
	Monitor                       *Action                `protobuf:"bytes,9,opt,name=monitor" json:"monitor,omitempty"`
	DiskMb                        int32                  `protobuf:"varint,10,opt,name=disk_mb" json:"disk_mb"`
	MemoryMb                      int32                  `protobuf:"varint,11,opt,name=memory_mb" json:"memory_mb"`
	CpuWeight                     uint32                 `protobuf:"varint,12,opt,name=cpu_weight" json:"cpu_weight"`
	Privileged                    bool                   `protobuf:"varint,13,opt,name=privileged" json:"privileged"`
	Ports                         []uint32               `protobuf:"varint,14,rep,name=ports" json:"ports,omitempty"`
	Routes                        *Routes                `protobuf:"bytes,15,opt,name=routes,customtype=Routes" json:"routes,omitempty"`
	LogSource                     string                 `protobuf:"bytes,16,opt,name=log_source" json:"log_source"`
	LogGuid                       string                 `protobuf:"bytes,17,opt,name=log_guid" json:"log_guid"`
	MetricsGuid                   string                 `protobuf:"bytes,18,opt,name=metrics_guid" json:"metrics_guid"`
	Annotation                    string                 `protobuf:"bytes,19,opt,name=annotation" json:"annotation"`
	EgressRules                   []*SecurityGroupRule   `protobuf:"bytes,20,rep,name=egress_rules" json:"egress_rules,omitempty"`
	ModificationTag               *ModificationTag       `protobuf:"bytes,21,opt,name=modification_tag" json:"modification_tag,omitempty"`
	CachedDependencies            []*CachedDependency    `protobuf:"bytes,22,rep,name=cached_dependencies" json:"cached_dependencies,omitempty"`
	LegacyDownloadUser            string                 `protobuf:"bytes,23,opt,name=legacy_download_user" json:"legacy_download_user,omitempty"`
	TrustedSystemCertificatesPath string                 `protobuf:"bytes,24,opt,name=trusted_system_certificates_path" json:"trusted_system_certificates_path,omitempty"`
}

func NewDesiredLRP 

func NewDesiredLRP(schedInfo DesiredLRPSchedulingInfo, runInfo DesiredLRPRunInfo) DesiredLRP

func (*DesiredLRP) ApplyUpdate 

func (desired *DesiredLRP) ApplyUpdate(update *DesiredLRPUpdate) *DesiredLRP

func (*DesiredLRP) Copy 

func (d *DesiredLRP) Copy() *DesiredLRP

func (*DesiredLRP) CreateComponents 

func (d *DesiredLRP) CreateComponents(createdAt time.Time) (DesiredLRPSchedulingInfo, DesiredLRPRunInfo)

func (*DesiredLRP) DesiredLRPKey 

func (d *DesiredLRP) DesiredLRPKey() DesiredLRPKey

func (*DesiredLRP) DesiredLRPResource 

func (d *DesiredLRP) DesiredLRPResource() DesiredLRPResource

func (*DesiredLRP) DesiredLRPRunInfo 

func (d *DesiredLRP) DesiredLRPRunInfo(createdAt time.Time) DesiredLRPRunInfo

func (*DesiredLRP) DesiredLRPSchedulingInfo 

func (d *DesiredLRP) DesiredLRPSchedulingInfo() DesiredLRPSchedulingInfo

func (*DesiredLRP) Equal 

func (this *DesiredLRP) Equal(that interface{}) bool

func (*DesiredLRP) GetAction 

func (m *DesiredLRP) GetAction() *Action

func (*DesiredLRP) GetAnnotation 

func (m *DesiredLRP) GetAnnotation() string

func (*DesiredLRP) GetCachedDependencies 

func (m *DesiredLRP) GetCachedDependencies() []*CachedDependency

func (*DesiredLRP) GetCpuWeight 

func (m *DesiredLRP) GetCpuWeight() uint32

func (*DesiredLRP) GetDiskMb 

func (m *DesiredLRP) GetDiskMb() int32

func (*DesiredLRP) GetDomain 

func (m *DesiredLRP) GetDomain() string

func (*DesiredLRP) GetEgressRules 

func (m *DesiredLRP) GetEgressRules() []*SecurityGroupRule

func (*DesiredLRP) GetEnvironmentVariables 

func (m *DesiredLRP) GetEnvironmentVariables() []*EnvironmentVariable

func (*DesiredLRP) GetInstances 

func (m *DesiredLRP) GetInstances() int32

func (*DesiredLRP) GetLegacyDownloadUser 

func (m *DesiredLRP) GetLegacyDownloadUser() string

func (*DesiredLRP) GetLogGuid 

func (m *DesiredLRP) GetLogGuid() string

func (*DesiredLRP) GetLogSource 

func (m *DesiredLRP) GetLogSource() string

func (*DesiredLRP) GetMemoryMb 

func (m *DesiredLRP) GetMemoryMb() int32

func (*DesiredLRP) GetMetricsGuid 

func (m *DesiredLRP) GetMetricsGuid() string

func (*DesiredLRP) GetModificationTag 

func (m *DesiredLRP) GetModificationTag() *ModificationTag

func (*DesiredLRP) GetMonitor 

func (m *DesiredLRP) GetMonitor() *Action

func (*DesiredLRP) GetPorts 

func (m *DesiredLRP) GetPorts() []uint32

func (*DesiredLRP) GetPrivileged 

func (m *DesiredLRP) GetPrivileged() bool

func (*DesiredLRP) GetProcessGuid 

func (m *DesiredLRP) GetProcessGuid() string

func (*DesiredLRP) GetRootFs 

func (m *DesiredLRP) GetRootFs() string

func (*DesiredLRP) GetSetup 

func (m *DesiredLRP) GetSetup() *Action

func (*DesiredLRP) GetStartTimeout 

func (m *DesiredLRP) GetStartTimeout() uint32

func (*DesiredLRP) GetTrustedSystemCertificatesPath 

func (m *DesiredLRP) GetTrustedSystemCertificatesPath() string

func (*DesiredLRP) GoString 

func (this *DesiredLRP) GoString() string

func (*DesiredLRP) Marshal 

func (m *DesiredLRP) Marshal() (data []byte, err error)

func (*DesiredLRP) MarshalTo 

func (m *DesiredLRP) MarshalTo(data []byte) (int, error)

func (*DesiredLRP) MigrateFromVersion 

func (*DesiredLRP) MigrateFromVersion(v format.Version) error

func (*DesiredLRP) ProtoMessage 

func (*DesiredLRP) ProtoMessage()

func (*DesiredLRP) Reset 

func (m *DesiredLRP) Reset()

func (*DesiredLRP) Size 

func (m *DesiredLRP) Size() (n int)

func (*DesiredLRP) String 

func (this *DesiredLRP) String() string

func (*DesiredLRP) Unmarshal 

func (m *DesiredLRP) Unmarshal(data []byte) error

func (DesiredLRP) Validate 

func (desired DesiredLRP) Validate() error

func (*DesiredLRP) Version 

func (*DesiredLRP) Version() format.Version

func (*DesiredLRP) VersionDownTo 

func (d *DesiredLRP) VersionDownTo(v format.Version) *DesiredLRP

type DesiredLRPByProcessGuidRequest 

type DesiredLRPByProcessGuidRequest struct {
	ProcessGuid string `protobuf:"bytes,1,opt,name=process_guid" json:"process_guid"`
}

func (*DesiredLRPByProcessGuidRequest) Equal 

func (this *DesiredLRPByProcessGuidRequest) Equal(that interface{}) bool

func (*DesiredLRPByProcessGuidRequest) GetProcessGuid 

func (m *DesiredLRPByProcessGuidRequest) GetProcessGuid() string

func (*DesiredLRPByProcessGuidRequest) GoString 

func (this *DesiredLRPByProcessGuidRequest) GoString() string

func (*DesiredLRPByProcessGuidRequest) Marshal 

func (m *DesiredLRPByProcessGuidRequest) Marshal() (data []byte, err error)

func (*DesiredLRPByProcessGuidRequest) MarshalTo 

func (m *DesiredLRPByProcessGuidRequest) MarshalTo(data []byte) (int, error)

func (*DesiredLRPByProcessGuidRequest) ProtoMessage 

func (*DesiredLRPByProcessGuidRequest) ProtoMessage()

func (*DesiredLRPByProcessGuidRequest) Reset 

func (m *DesiredLRPByProcessGuidRequest) Reset()

func (*DesiredLRPByProcessGuidRequest) Size 

func (m *DesiredLRPByProcessGuidRequest) Size() (n int)

func (*DesiredLRPByProcessGuidRequest) String 

func (this *DesiredLRPByProcessGuidRequest) String() string

func (*DesiredLRPByProcessGuidRequest) Unmarshal 

func (m *DesiredLRPByProcessGuidRequest) Unmarshal(data []byte) error

func (*DesiredLRPByProcessGuidRequest) Validate 

func (request *DesiredLRPByProcessGuidRequest) Validate() error

type DesiredLRPChange 

type DesiredLRPChange struct {
	Before *DesiredLRP
	After  *DesiredLRP
}

type DesiredLRPChangedEvent 

type DesiredLRPChangedEvent struct {
	Before *DesiredLRP `protobuf:"bytes,1,opt,name=before" json:"before,omitempty"`
	After  *DesiredLRP `protobuf:"bytes,2,opt,name=after" json:"after,omitempty"`
}

func NewDesiredLRPChangedEvent 

func NewDesiredLRPChangedEvent(before, after *DesiredLRP) *DesiredLRPChangedEvent

func (*DesiredLRPChangedEvent) Equal 

func (this *DesiredLRPChangedEvent) Equal(that interface{}) bool

func (*DesiredLRPChangedEvent) EventType 

func (event *DesiredLRPChangedEvent) EventType() string

func (*DesiredLRPChangedEvent) GetAfter 

func (m *DesiredLRPChangedEvent) GetAfter() *DesiredLRP

func (*DesiredLRPChangedEvent) GetBefore 

func (m *DesiredLRPChangedEvent) GetBefore() *DesiredLRP

func (*DesiredLRPChangedEvent) GoString 

func (this *DesiredLRPChangedEvent) GoString() string

func (*DesiredLRPChangedEvent) Key 

func (event *DesiredLRPChangedEvent) Key() string

func (*DesiredLRPChangedEvent) Marshal 

func (m *DesiredLRPChangedEvent) Marshal() (data []byte, err error)

func (*DesiredLRPChangedEvent) MarshalTo 

func (m *DesiredLRPChangedEvent) MarshalTo(data []byte) (int, error)

func (*DesiredLRPChangedEvent) ProtoMessage 

func (*DesiredLRPChangedEvent) ProtoMessage()

func (*DesiredLRPChangedEvent) Reset 

func (m *DesiredLRPChangedEvent) Reset()

func (*DesiredLRPChangedEvent) Size 

func (m *DesiredLRPChangedEvent) Size() (n int)

func (*DesiredLRPChangedEvent) String 

func (this *DesiredLRPChangedEvent) String() string

func (*DesiredLRPChangedEvent) Unmarshal 

func (m *DesiredLRPChangedEvent) Unmarshal(data []byte) error

type DesiredLRPCreatedEvent 

type DesiredLRPCreatedEvent struct {
	DesiredLrp *DesiredLRP `protobuf:"bytes,1,opt,name=desired_lrp" json:"desired_lrp,omitempty"`
}

func NewDesiredLRPCreatedEvent 

func NewDesiredLRPCreatedEvent(desiredLRP *DesiredLRP) *DesiredLRPCreatedEvent

func (*DesiredLRPCreatedEvent) Equal 

func (this *DesiredLRPCreatedEvent) Equal(that interface{}) bool

func (*DesiredLRPCreatedEvent) EventType 

func (event *DesiredLRPCreatedEvent) EventType() string

func (*DesiredLRPCreatedEvent) GetDesiredLrp 

func (m *DesiredLRPCreatedEvent) GetDesiredLrp() *DesiredLRP

func (*DesiredLRPCreatedEvent) GoString 

func (this *DesiredLRPCreatedEvent) GoString() string

func (*DesiredLRPCreatedEvent) Key 

func (event *DesiredLRPCreatedEvent) Key() string

func (*DesiredLRPCreatedEvent) Marshal 

func (m *DesiredLRPCreatedEvent) Marshal() (data []byte, err error)

func (*DesiredLRPCreatedEvent) MarshalTo 

func (m *DesiredLRPCreatedEvent) MarshalTo(data []byte) (int, error)

func (*DesiredLRPCreatedEvent) ProtoMessage 

func (*DesiredLRPCreatedEvent) ProtoMessage()

func (*DesiredLRPCreatedEvent) Reset 

func (m *DesiredLRPCreatedEvent) Reset()

func (*DesiredLRPCreatedEvent) Size 

func (m *DesiredLRPCreatedEvent) Size() (n int)

func (*DesiredLRPCreatedEvent) String 

func (this *DesiredLRPCreatedEvent) String() string

func (*DesiredLRPCreatedEvent) Unmarshal 

func (m *DesiredLRPCreatedEvent) Unmarshal(data []byte) error

type DesiredLRPFilter 

type DesiredLRPFilter struct {
	Domain string
}

type DesiredLRPKey 

type DesiredLRPKey struct {
	ProcessGuid string `protobuf:"bytes,1,opt,name=process_guid" json:"process_guid"`
	Domain      string `protobuf:"bytes,2,opt,name=domain" json:"domain"`
	LogGuid     string `protobuf:"bytes,3,opt,name=log_guid" json:"log_guid"`
}

func NewDesiredLRPKey 

func NewDesiredLRPKey(processGuid, domain, logGuid string) DesiredLRPKey

func (*DesiredLRPKey) Equal 

func (this *DesiredLRPKey) Equal(that interface{}) bool

func (*DesiredLRPKey) GetDomain 

func (m *DesiredLRPKey) GetDomain() string

func (*DesiredLRPKey) GetLogGuid 

func (m *DesiredLRPKey) GetLogGuid() string

func (*DesiredLRPKey) GetProcessGuid 

func (m *DesiredLRPKey) GetProcessGuid() string

func (*DesiredLRPKey) GoString 

func (this *DesiredLRPKey) GoString() string

func (*DesiredLRPKey) Marshal 

func (m *DesiredLRPKey) Marshal() (data []byte, err error)

func (*DesiredLRPKey) MarshalTo 

func (m *DesiredLRPKey) MarshalTo(data []byte) (int, error)

func (*DesiredLRPKey) ProtoMessage 

func (*DesiredLRPKey) ProtoMessage()

func (*DesiredLRPKey) Reset 

func (m *DesiredLRPKey) Reset()

func (*DesiredLRPKey) Size 

func (m *DesiredLRPKey) Size() (n int)

func (*DesiredLRPKey) String 

func (this *DesiredLRPKey) String() string

func (*DesiredLRPKey) Unmarshal 

func (m *DesiredLRPKey) Unmarshal(data []byte) error

func (DesiredLRPKey) Validate 

func (key DesiredLRPKey) Validate() error

type DesiredLRPLifecycleResponse 

type DesiredLRPLifecycleResponse struct {
	Error *Error `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
}

func (*DesiredLRPLifecycleResponse) Equal 

func (this *DesiredLRPLifecycleResponse) Equal(that interface{}) bool

func (*DesiredLRPLifecycleResponse) GetError 

func (m *DesiredLRPLifecycleResponse) GetError() *Error

func (*DesiredLRPLifecycleResponse) GoString 

func (this *DesiredLRPLifecycleResponse) GoString() string

func (*DesiredLRPLifecycleResponse) Marshal 

func (m *DesiredLRPLifecycleResponse) Marshal() (data []byte, err error)

func (*DesiredLRPLifecycleResponse) MarshalTo 

func (m *DesiredLRPLifecycleResponse) MarshalTo(data []byte) (int, error)

func (*DesiredLRPLifecycleResponse) ProtoMessage 

func (*DesiredLRPLifecycleResponse) ProtoMessage()

func (*DesiredLRPLifecycleResponse) Reset 

func (m *DesiredLRPLifecycleResponse) Reset()

func (*DesiredLRPLifecycleResponse) Size 

func (m *DesiredLRPLifecycleResponse) Size() (n int)

func (*DesiredLRPLifecycleResponse) String 

func (this *DesiredLRPLifecycleResponse) String() string

func (*DesiredLRPLifecycleResponse) Unmarshal 

func (m *DesiredLRPLifecycleResponse) Unmarshal(data []byte) error

type DesiredLRPRemovedEvent 

type DesiredLRPRemovedEvent struct {
	DesiredLrp *DesiredLRP `protobuf:"bytes,1,opt,name=desired_lrp" json:"desired_lrp,omitempty"`
}

func NewDesiredLRPRemovedEvent 

func NewDesiredLRPRemovedEvent(desiredLRP *DesiredLRP) *DesiredLRPRemovedEvent

func (*DesiredLRPRemovedEvent) Equal 

func (this *DesiredLRPRemovedEvent) Equal(that interface{}) bool

func (*DesiredLRPRemovedEvent) EventType 

func (event *DesiredLRPRemovedEvent) EventType() string

func (*DesiredLRPRemovedEvent) GetDesiredLrp 

func (m *DesiredLRPRemovedEvent) GetDesiredLrp() *DesiredLRP

func (*DesiredLRPRemovedEvent) GoString 

func (this *DesiredLRPRemovedEvent) GoString() string

func (DesiredLRPRemovedEvent) Key 

func (event DesiredLRPRemovedEvent) Key() string

func (*DesiredLRPRemovedEvent) Marshal 

func (m *DesiredLRPRemovedEvent) Marshal() (data []byte, err error)

func (*DesiredLRPRemovedEvent) MarshalTo 

func (m *DesiredLRPRemovedEvent) MarshalTo(data []byte) (int, error)

func (*DesiredLRPRemovedEvent) ProtoMessage 

func (*DesiredLRPRemovedEvent) ProtoMessage()

func (*DesiredLRPRemovedEvent) Reset 

func (m *DesiredLRPRemovedEvent) Reset()

func (*DesiredLRPRemovedEvent) Size 

func (m *DesiredLRPRemovedEvent) Size() (n int)

func (*DesiredLRPRemovedEvent) String 

func (this *DesiredLRPRemovedEvent) String() string

func (*DesiredLRPRemovedEvent) Unmarshal 

func (m *DesiredLRPRemovedEvent) Unmarshal(data []byte) error

type DesiredLRPResource 

type DesiredLRPResource struct {
	MemoryMb int32  `protobuf:"varint,1,opt,name=memory_mb" json:"memory_mb"`
	DiskMb   int32  `protobuf:"varint,2,opt,name=disk_mb" json:"disk_mb"`
	RootFs   string `protobuf:"bytes,3,opt,name=root_fs" json:"rootfs"`
}

func NewDesiredLRPResource 

func NewDesiredLRPResource(memoryMb, diskMb int32, rootFs string) DesiredLRPResource

func (*DesiredLRPResource) Equal 

func (this *DesiredLRPResource) Equal(that interface{}) bool

func (*DesiredLRPResource) GetDiskMb 

func (m *DesiredLRPResource) GetDiskMb() int32

func (*DesiredLRPResource) GetMemoryMb 

func (m *DesiredLRPResource) GetMemoryMb() int32

func (*DesiredLRPResource) GetRootFs 

func (m *DesiredLRPResource) GetRootFs() string

func (*DesiredLRPResource) GoString 

func (this *DesiredLRPResource) GoString() string

func (*DesiredLRPResource) Marshal 

func (m *DesiredLRPResource) Marshal() (data []byte, err error)

func (*DesiredLRPResource) MarshalTo 

func (m *DesiredLRPResource) MarshalTo(data []byte) (int, error)

func (*DesiredLRPResource) ProtoMessage 

func (*DesiredLRPResource) ProtoMessage()

func (*DesiredLRPResource) Reset 

func (m *DesiredLRPResource) Reset()

func (*DesiredLRPResource) Size 

func (m *DesiredLRPResource) Size() (n int)

func (*DesiredLRPResource) String 

func (this *DesiredLRPResource) String() string

func (*DesiredLRPResource) Unmarshal 

func (m *DesiredLRPResource) Unmarshal(data []byte) error

func (DesiredLRPResource) Validate 

func (resource DesiredLRPResource) Validate() error

type DesiredLRPResponse 

type DesiredLRPResponse struct {
	Error      *Error      `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	DesiredLrp *DesiredLRP `protobuf:"bytes,2,opt,name=desired_lrp" json:"desired_lrp,omitempty"`
}

func (*DesiredLRPResponse) Equal 

func (this *DesiredLRPResponse) Equal(that interface{}) bool

func (*DesiredLRPResponse) GetDesiredLrp 

func (m *DesiredLRPResponse) GetDesiredLrp() *DesiredLRP

func (*DesiredLRPResponse) GetError 

func (m *DesiredLRPResponse) GetError() *Error

func (*DesiredLRPResponse) GoString 

func (this *DesiredLRPResponse) GoString() string

func (*DesiredLRPResponse) Marshal 

func (m *DesiredLRPResponse) Marshal() (data []byte, err error)

func (*DesiredLRPResponse) MarshalTo 

func (m *DesiredLRPResponse) MarshalTo(data []byte) (int, error)

func (*DesiredLRPResponse) ProtoMessage 

func (*DesiredLRPResponse) ProtoMessage()

func (*DesiredLRPResponse) Reset 

func (m *DesiredLRPResponse) Reset()

func (*DesiredLRPResponse) Size 

func (m *DesiredLRPResponse) Size() (n int)

func (*DesiredLRPResponse) String 

func (this *DesiredLRPResponse) String() string

func (*DesiredLRPResponse) Unmarshal 

func (m *DesiredLRPResponse) Unmarshal(data []byte) error

type DesiredLRPRunInfo 

type DesiredLRPRunInfo struct {
	DesiredLRPKey                 `protobuf:"bytes,1,opt,name=desired_lrp_key,embedded=desired_lrp_key" json:""`
	EnvironmentVariables          []EnvironmentVariable `protobuf:"bytes,2,rep,name=environment_variables" json:"env"`
	Setup                         *Action               `protobuf:"bytes,3,opt,name=setup" json:"setup,omitempty"`
	Action                        *Action               `protobuf:"bytes,4,opt,name=action" json:"action,omitempty"`
	Monitor                       *Action               `protobuf:"bytes,5,opt,name=monitor" json:"monitor,omitempty"`
	StartTimeout                  uint32                `protobuf:"varint,6,opt,name=start_timeout" json:"start_timeout"`
	Privileged                    bool                  `protobuf:"varint,7,opt,name=privileged" json:"privileged"`
	CpuWeight                     uint32                `protobuf:"varint,8,opt,name=cpu_weight" json:"cpu_weight"`
	Ports                         []uint32              `protobuf:"varint,9,rep,name=ports" json:"ports,omitempty"`
	EgressRules                   []SecurityGroupRule   `protobuf:"bytes,10,rep,name=egress_rules" json:"egress_rules"`
	LogSource                     string                `protobuf:"bytes,11,opt,name=log_source" json:"log_source"`
	MetricsGuid                   string                `protobuf:"bytes,12,opt,name=metrics_guid" json:"metrics_guid"`
	CreatedAt                     int64                 `protobuf:"varint,13,opt,name=created_at" json:"created_at"`
	CachedDependencies            []*CachedDependency   `protobuf:"bytes,14,rep,name=cached_dependencies" json:"cached_dependencies,omitempty"`
	LegacyDownloadUser            string                `protobuf:"bytes,15,opt,name=legacy_download_user" json:"legacy_download_user,omitempty"`
	TrustedSystemCertificatesPath string                `protobuf:"bytes,16,opt,name=trusted_system_certificates_path" json:"trusted_system_certificates_path,omitempty"`
}

func NewDesiredLRPRunInfo 

func NewDesiredLRPRunInfo(
	key DesiredLRPKey,
	createdAt time.Time,
	envVars []EnvironmentVariable,
	cacheDeps []*CachedDependency,
	setup,
	action,
	monitor *Action,
	startTimeout uint32,
	privileged bool,
	cpuWeight uint32,
	ports []uint32,
	egressRules []SecurityGroupRule,
	logSource,
	metricsGuid string,
	legacyDownloadUser string,
	trustedSystemCertificatesPath string,
) DesiredLRPRunInfo

func (*DesiredLRPRunInfo) Equal 

func (this *DesiredLRPRunInfo) Equal(that interface{}) bool

func (*DesiredLRPRunInfo) GetAction 

func (m *DesiredLRPRunInfo) GetAction() *Action

func (*DesiredLRPRunInfo) GetCachedDependencies 

func (m *DesiredLRPRunInfo) GetCachedDependencies() []*CachedDependency

func (*DesiredLRPRunInfo) GetCpuWeight 

func (m *DesiredLRPRunInfo) GetCpuWeight() uint32

func (*DesiredLRPRunInfo) GetCreatedAt 

func (m *DesiredLRPRunInfo) GetCreatedAt() int64

func (*DesiredLRPRunInfo) GetEgressRules 

func (m *DesiredLRPRunInfo) GetEgressRules() []SecurityGroupRule

func (*DesiredLRPRunInfo) GetEnvironmentVariables 

func (m *DesiredLRPRunInfo) GetEnvironmentVariables() []EnvironmentVariable

func (*DesiredLRPRunInfo) GetLegacyDownloadUser 

func (m *DesiredLRPRunInfo) GetLegacyDownloadUser() string

func (*DesiredLRPRunInfo) GetLogSource 

func (m *DesiredLRPRunInfo) GetLogSource() string

func (*DesiredLRPRunInfo) GetMetricsGuid 

func (m *DesiredLRPRunInfo) GetMetricsGuid() string

func (*DesiredLRPRunInfo) GetMonitor 

func (m *DesiredLRPRunInfo) GetMonitor() *Action

func (*DesiredLRPRunInfo) GetPorts 

func (m *DesiredLRPRunInfo) GetPorts() []uint32

func (*DesiredLRPRunInfo) GetPrivileged 

func (m *DesiredLRPRunInfo) GetPrivileged() bool

func (*DesiredLRPRunInfo) GetSetup 

func (m *DesiredLRPRunInfo) GetSetup() *Action

func (*DesiredLRPRunInfo) GetStartTimeout 

func (m *DesiredLRPRunInfo) GetStartTimeout() uint32

func (*DesiredLRPRunInfo) GetTrustedSystemCertificatesPath 

func (m *DesiredLRPRunInfo) GetTrustedSystemCertificatesPath() string

func (*DesiredLRPRunInfo) GoString 

func (this *DesiredLRPRunInfo) GoString() string

func (*DesiredLRPRunInfo) Marshal 

func (m *DesiredLRPRunInfo) Marshal() (data []byte, err error)

func (*DesiredLRPRunInfo) MarshalTo 

func (m *DesiredLRPRunInfo) MarshalTo(data []byte) (int, error)

func (*DesiredLRPRunInfo) MigrateFromVersion 

func (*DesiredLRPRunInfo) MigrateFromVersion(v format.Version) error

func (*DesiredLRPRunInfo) ProtoMessage 

func (*DesiredLRPRunInfo) ProtoMessage()

func (*DesiredLRPRunInfo) Reset 

func (m *DesiredLRPRunInfo) Reset()

func (*DesiredLRPRunInfo) Size 

func (m *DesiredLRPRunInfo) Size() (n int)

func (*DesiredLRPRunInfo) String 

func (this *DesiredLRPRunInfo) String() string

func (*DesiredLRPRunInfo) Unmarshal 

func (m *DesiredLRPRunInfo) Unmarshal(data []byte) error

func (DesiredLRPRunInfo) Validate 

func (runInfo DesiredLRPRunInfo) Validate() error

func (*DesiredLRPRunInfo) Version 

func (*DesiredLRPRunInfo) Version() format.Version

type DesiredLRPSchedulingInfo 

type DesiredLRPSchedulingInfo struct {
	DesiredLRPKey      `protobuf:"bytes,1,opt,name=desired_lrp_key,embedded=desired_lrp_key" json:""`
	Annotation         string `protobuf:"bytes,2,opt,name=annotation" json:"annotation"`
	Instances          int32  `protobuf:"varint,3,opt,name=instances" json:"instances"`
	DesiredLRPResource `protobuf:"bytes,4,opt,name=desired_lrp_resource,embedded=desired_lrp_resource" json:""`
	Routes             Routes `protobuf:"bytes,5,opt,name=routes,customtype=Routes" json:"routes"`
	ModificationTag    `protobuf:"bytes,6,opt,name=modification_tag,embedded=modification_tag" json:""`
}

func NewDesiredLRPSchedulingInfo 

func NewDesiredLRPSchedulingInfo(key DesiredLRPKey, annotation string, instances int32, resource DesiredLRPResource, routes Routes, modTag ModificationTag) DesiredLRPSchedulingInfo

func (*DesiredLRPSchedulingInfo) ApplyUpdate 

func (s *DesiredLRPSchedulingInfo) ApplyUpdate(update *DesiredLRPUpdate)

func (*DesiredLRPSchedulingInfo) Equal 

func (this *DesiredLRPSchedulingInfo) Equal(that interface{}) bool

func (*DesiredLRPSchedulingInfo) GetAnnotation 

func (m *DesiredLRPSchedulingInfo) GetAnnotation() string

func (*DesiredLRPSchedulingInfo) GetInstances 

func (m *DesiredLRPSchedulingInfo) GetInstances() int32

func (*DesiredLRPSchedulingInfo) GoString 

func (this *DesiredLRPSchedulingInfo) GoString() string

func (*DesiredLRPSchedulingInfo) Marshal 

func (m *DesiredLRPSchedulingInfo) Marshal() (data []byte, err error)

func (*DesiredLRPSchedulingInfo) MarshalTo 

func (m *DesiredLRPSchedulingInfo) MarshalTo(data []byte) (int, error)

func (*DesiredLRPSchedulingInfo) MigrateFromVersion 

func (*DesiredLRPSchedulingInfo) MigrateFromVersion(v format.Version) error

func (*DesiredLRPSchedulingInfo) ProtoMessage 

func (*DesiredLRPSchedulingInfo) ProtoMessage()

func (*DesiredLRPSchedulingInfo) Reset 

func (m *DesiredLRPSchedulingInfo) Reset()

func (*DesiredLRPSchedulingInfo) Size 

func (m *DesiredLRPSchedulingInfo) Size() (n int)

func (*DesiredLRPSchedulingInfo) String 

func (this *DesiredLRPSchedulingInfo) String() string

func (*DesiredLRPSchedulingInfo) Unmarshal 

func (m *DesiredLRPSchedulingInfo) Unmarshal(data []byte) error

func (DesiredLRPSchedulingInfo) Validate 

func (s DesiredLRPSchedulingInfo) Validate() error

func (*DesiredLRPSchedulingInfo) Version 

func (*DesiredLRPSchedulingInfo) Version() format.Version

type DesiredLRPSchedulingInfosResponse 

type DesiredLRPSchedulingInfosResponse struct {
	Error                     *Error                      `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	DesiredLrpSchedulingInfos []*DesiredLRPSchedulingInfo `protobuf:"bytes,2,rep,name=desired_lrp_scheduling_infos" json:"desired_lrp_scheduling_infos,omitempty"`
}

func (*DesiredLRPSchedulingInfosResponse) Equal 

func (this *DesiredLRPSchedulingInfosResponse) Equal(that interface{}) bool

func (*DesiredLRPSchedulingInfosResponse) GetDesiredLrpSchedulingInfos 

func (m *DesiredLRPSchedulingInfosResponse) GetDesiredLrpSchedulingInfos() []*DesiredLRPSchedulingInfo

func (*DesiredLRPSchedulingInfosResponse) GetError 

func (m *DesiredLRPSchedulingInfosResponse) GetError() *Error

func (*DesiredLRPSchedulingInfosResponse) GoString 

func (this *DesiredLRPSchedulingInfosResponse) GoString() string

func (*DesiredLRPSchedulingInfosResponse) Marshal 

func (m *DesiredLRPSchedulingInfosResponse) Marshal() (data []byte, err error)

func (*DesiredLRPSchedulingInfosResponse) MarshalTo 

func (m *DesiredLRPSchedulingInfosResponse) MarshalTo(data []byte) (int, error)

func (*DesiredLRPSchedulingInfosResponse) ProtoMessage 

func (*DesiredLRPSchedulingInfosResponse) ProtoMessage()

func (*DesiredLRPSchedulingInfosResponse) Reset 

func (m *DesiredLRPSchedulingInfosResponse) Reset()

func (*DesiredLRPSchedulingInfosResponse) Size 

func (m *DesiredLRPSchedulingInfosResponse) Size() (n int)

func (*DesiredLRPSchedulingInfosResponse) String 

func (this *DesiredLRPSchedulingInfosResponse) String() string

func (*DesiredLRPSchedulingInfosResponse) Unmarshal 

func (m *DesiredLRPSchedulingInfosResponse) Unmarshal(data []byte) error

type DesiredLRPUpdate 

type DesiredLRPUpdate struct {
	Instances  *int32  `protobuf:"varint,1,opt,name=instances" json:"instances,omitempty"`
	Routes     *Routes `protobuf:"bytes,2,opt,name=routes,customtype=Routes" json:"routes,omitempty"`
	Annotation *string `protobuf:"bytes,3,opt,name=annotation" json:"annotation,omitempty"`
}

func (*DesiredLRPUpdate) Equal 

func (this *DesiredLRPUpdate) Equal(that interface{}) bool

func (*DesiredLRPUpdate) GetAnnotation 

func (m *DesiredLRPUpdate) GetAnnotation() string

func (*DesiredLRPUpdate) GetInstances 

func (m *DesiredLRPUpdate) GetInstances() int32

func (*DesiredLRPUpdate) GoString 

func (this *DesiredLRPUpdate) GoString() string

func (*DesiredLRPUpdate) Marshal 

func (m *DesiredLRPUpdate) Marshal() (data []byte, err error)

func (*DesiredLRPUpdate) MarshalTo 

func (m *DesiredLRPUpdate) MarshalTo(data []byte) (int, error)

func (*DesiredLRPUpdate) ProtoMessage 

func (*DesiredLRPUpdate) ProtoMessage()

func (*DesiredLRPUpdate) Reset 

func (m *DesiredLRPUpdate) Reset()

func (*DesiredLRPUpdate) Size 

func (m *DesiredLRPUpdate) Size() (n int)

func (*DesiredLRPUpdate) String 

func (this *DesiredLRPUpdate) String() string

func (*DesiredLRPUpdate) Unmarshal 

func (m *DesiredLRPUpdate) Unmarshal(data []byte) error

func (*DesiredLRPUpdate) Validate 

func (desired *DesiredLRPUpdate) Validate() error

type DesiredLRPsRequest 

type DesiredLRPsRequest struct {
	Domain string `protobuf:"bytes,1,opt,name=domain" json:"domain"`
}

func (*DesiredLRPsRequest) Equal 

func (this *DesiredLRPsRequest) Equal(that interface{}) bool

func (*DesiredLRPsRequest) GetDomain 

func (m *DesiredLRPsRequest) GetDomain() string

func (*DesiredLRPsRequest) GoString 

func (this *DesiredLRPsRequest) GoString() string

func (*DesiredLRPsRequest) Marshal 

func (m *DesiredLRPsRequest) Marshal() (data []byte, err error)

func (*DesiredLRPsRequest) MarshalTo 

func (m *DesiredLRPsRequest) MarshalTo(data []byte) (int, error)

func (*DesiredLRPsRequest) ProtoMessage 

func (*DesiredLRPsRequest) ProtoMessage()

func (*DesiredLRPsRequest) Reset 

func (m *DesiredLRPsRequest) Reset()

func (*DesiredLRPsRequest) Size 

func (m *DesiredLRPsRequest) Size() (n int)

func (*DesiredLRPsRequest) String 

func (this *DesiredLRPsRequest) String() string

func (*DesiredLRPsRequest) Unmarshal 

func (m *DesiredLRPsRequest) Unmarshal(data []byte) error

func (*DesiredLRPsRequest) Validate 

func (request *DesiredLRPsRequest) Validate() error

type DesiredLRPsResponse 

type DesiredLRPsResponse struct {
	Error       *Error        `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	DesiredLrps []*DesiredLRP `protobuf:"bytes,2,rep,name=desired_lrps" json:"desired_lrps,omitempty"`
}

func (*DesiredLRPsResponse) Equal 

func (this *DesiredLRPsResponse) Equal(that interface{}) bool

func (*DesiredLRPsResponse) GetDesiredLrps 

func (m *DesiredLRPsResponse) GetDesiredLrps() []*DesiredLRP

func (*DesiredLRPsResponse) GetError 

func (m *DesiredLRPsResponse) GetError() *Error

func (*DesiredLRPsResponse) GoString 

func (this *DesiredLRPsResponse) GoString() string

func (*DesiredLRPsResponse) Marshal 

func (m *DesiredLRPsResponse) Marshal() (data []byte, err error)

func (*DesiredLRPsResponse) MarshalTo 

func (m *DesiredLRPsResponse) MarshalTo(data []byte) (int, error)

func (*DesiredLRPsResponse) ProtoMessage 

func (*DesiredLRPsResponse) ProtoMessage()

func (*DesiredLRPsResponse) Reset 

func (m *DesiredLRPsResponse) Reset()

func (*DesiredLRPsResponse) Size 

func (m *DesiredLRPsResponse) Size() (n int)

func (*DesiredLRPsResponse) String 

func (this *DesiredLRPsResponse) String() string

func (*DesiredLRPsResponse) Unmarshal 

func (m *DesiredLRPsResponse) Unmarshal(data []byte) error

type DomainSet 

type DomainSet map[string]struct{}

func NewDomainSet 

func NewDomainSet(domains []string) DomainSet

func (DomainSet) Add 

func (set DomainSet) Add(domain string)

func (DomainSet) Contains 

func (set DomainSet) Contains(domain string) bool

func (DomainSet) Each 

func (set DomainSet) Each(predicate func(domain string))

type DomainsResponse 

type DomainsResponse struct {
	Error   *Error   `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	Domains []string `protobuf:"bytes,2,rep,name=domains" json:"domains,omitempty"`
}

func (*DomainsResponse) GetDomains 

func (m *DomainsResponse) GetDomains() []string

func (*DomainsResponse) GetError 

func (m *DomainsResponse) GetError() *Error

func (*DomainsResponse) GoString 

func (this *DomainsResponse) GoString() string

func (*DomainsResponse) Marshal 

func (m *DomainsResponse) Marshal() (data []byte, err error)

func (*DomainsResponse) MarshalTo 

func (m *DomainsResponse) MarshalTo(data []byte) (int, error)

func (*DomainsResponse) ProtoMessage 

func (*DomainsResponse) ProtoMessage()

func (*DomainsResponse) Reset 

func (m *DomainsResponse) Reset()

func (*DomainsResponse) Size 

func (m *DomainsResponse) Size() (n int)

func (*DomainsResponse) String 

func (this *DomainsResponse) String() string

func (*DomainsResponse) Unmarshal 

func (m *DomainsResponse) Unmarshal(data []byte) error

type DownloadAction 

type DownloadAction struct {
	Artifact  string `protobuf:"bytes,1,opt,name=artifact" json:"artifact,omitempty"`
	From      string `protobuf:"bytes,2,opt,name=from" json:"from"`
	To        string `protobuf:"bytes,3,opt,name=to" json:"to"`
	CacheKey  string `protobuf:"bytes,4,opt,name=cache_key" json:"cache_key"`
	LogSource string `protobuf:"bytes,5,opt,name=log_source" json:"log_source,omitempty"`
	User      string `protobuf:"bytes,6,opt,name=user" json:"user"`
}

func (*DownloadAction) ActionType 

func (a *DownloadAction) ActionType() string

func (*DownloadAction) Equal 

func (this *DownloadAction) Equal(that interface{}) bool

func (*DownloadAction) GetArtifact 

func (m *DownloadAction) GetArtifact() string

func (*DownloadAction) GetCacheKey 

func (m *DownloadAction) GetCacheKey() string

func (*DownloadAction) GetFrom 

func (m *DownloadAction) GetFrom() string

func (*DownloadAction) GetLogSource 

func (m *DownloadAction) GetLogSource() string

func (*DownloadAction) GetTo 

func (m *DownloadAction) GetTo() string

func (*DownloadAction) GetUser 

func (m *DownloadAction) GetUser() string

func (*DownloadAction) GoString 

func (this *DownloadAction) GoString() string

func (*DownloadAction) Marshal 

func (m *DownloadAction) Marshal() (data []byte, err error)

func (*DownloadAction) MarshalTo 

func (m *DownloadAction) MarshalTo(data []byte) (int, error)

func (*DownloadAction) MigrateFromVersion 

func (*DownloadAction) MigrateFromVersion(v format.Version) error

func (*DownloadAction) ProtoMessage 

func (*DownloadAction) ProtoMessage()

func (*DownloadAction) Reset 

func (m *DownloadAction) Reset()

func (*DownloadAction) Size 

func (m *DownloadAction) Size() (n int)

func (*DownloadAction) String 

func (this *DownloadAction) String() string

func (*DownloadAction) Unmarshal 

func (m *DownloadAction) Unmarshal(data []byte) error

func (DownloadAction) Validate 

func (a DownloadAction) Validate() error

func (*DownloadAction) Version 

func (*DownloadAction) Version() format.Version

type EmitProgressAction 

type EmitProgressAction struct {
	Action               *Action `protobuf:"bytes,1,opt,name=action" json:"action,omitempty"`
	StartMessage         string  `protobuf:"bytes,2,opt,name=start_message" json:"start_message"`
	SuccessMessage       string  `protobuf:"bytes,3,opt,name=success_message" json:"success_message"`
	FailureMessagePrefix string  `protobuf:"bytes,4,opt,name=failure_message_prefix" json:"failure_message_prefix"`
	LogSource            string  `protobuf:"bytes,5,opt,name=log_source" json:"log_source,omitempty"`
}

func EmitProgressFor 

func EmitProgressFor(action ActionInterface, startMessage string, successMessage string, failureMessagePrefix string) *EmitProgressAction

func (*EmitProgressAction) ActionType 

func (a *EmitProgressAction) ActionType() string

func (*EmitProgressAction) Equal 

func (this *EmitProgressAction) Equal(that interface{}) bool

func (*EmitProgressAction) GetAction 

func (m *EmitProgressAction) GetAction() *Action

func (*EmitProgressAction) GetFailureMessagePrefix 

func (m *EmitProgressAction) GetFailureMessagePrefix() string

func (*EmitProgressAction) GetLogSource 

func (m *EmitProgressAction) GetLogSource() string

func (*EmitProgressAction) GetStartMessage 

func (m *EmitProgressAction) GetStartMessage() string

func (*EmitProgressAction) GetSuccessMessage 

func (m *EmitProgressAction) GetSuccessMessage() string

func (*EmitProgressAction) GoString 

func (this *EmitProgressAction) GoString() string

func (*EmitProgressAction) Marshal 

func (m *EmitProgressAction) Marshal() (data []byte, err error)

func (*EmitProgressAction) MarshalTo 

func (m *EmitProgressAction) MarshalTo(data []byte) (int, error)

func (*EmitProgressAction) MigrateFromVersion 

func (*EmitProgressAction) MigrateFromVersion(v format.Version) error

func (*EmitProgressAction) ProtoMessage 

func (*EmitProgressAction) ProtoMessage()

func (*EmitProgressAction) Reset 

func (m *EmitProgressAction) Reset()

func (*EmitProgressAction) Size 

func (m *EmitProgressAction) Size() (n int)

func (*EmitProgressAction) String 

func (this *EmitProgressAction) String() string

func (*EmitProgressAction) Unmarshal 

func (m *EmitProgressAction) Unmarshal(data []byte) error

func (EmitProgressAction) Validate 

func (a EmitProgressAction) Validate() error

func (*EmitProgressAction) Version 

func (*EmitProgressAction) Version() format.Version

type EnvironmentVariable 

type EnvironmentVariable struct {
	Name  string `protobuf:"bytes,1,opt,name=name" json:"name"`
	Value string `protobuf:"bytes,2,opt,name=value" json:"value"`
}

func (*EnvironmentVariable) Equal 

func (this *EnvironmentVariable) Equal(that interface{}) bool

func (*EnvironmentVariable) GetName 

func (m *EnvironmentVariable) GetName() string

func (*EnvironmentVariable) GetValue 

func (m *EnvironmentVariable) GetValue() string

func (*EnvironmentVariable) GoString 

func (this *EnvironmentVariable) GoString() string

func (*EnvironmentVariable) Marshal 

func (m *EnvironmentVariable) Marshal() (data []byte, err error)

func (*EnvironmentVariable) MarshalTo 

func (m *EnvironmentVariable) MarshalTo(data []byte) (int, error)

func (*EnvironmentVariable) ProtoMessage 

func (*EnvironmentVariable) ProtoMessage()

func (*EnvironmentVariable) Reset 

func (m *EnvironmentVariable) Reset()

func (*EnvironmentVariable) Size 

func (m *EnvironmentVariable) Size() (n int)

func (*EnvironmentVariable) String 

func (this *EnvironmentVariable) String() string

func (*EnvironmentVariable) Unmarshal 

func (m *EnvironmentVariable) Unmarshal(data []byte) error

func (EnvironmentVariable) Validate 

func (envVar EnvironmentVariable) Validate() error

type ErrInvalidField 

type ErrInvalidField struct {
	Field string
}

func (ErrInvalidField) Error 

func (err ErrInvalidField) Error() string

type ErrInvalidModification 

type ErrInvalidModification struct {
	InvalidField string
}

func (ErrInvalidModification) Error 

func (err ErrInvalidModification) Error() string

type Error 

type Error struct {
	Type    Error_Type `protobuf:"varint,1,opt,name=type,enum=models.Error_Type" json:"type"`
	Message string     `protobuf:"bytes,2,opt,name=message" json:"message"`
}

func ConvertError 

func ConvertError(err error) *Error

func NewError 

func NewError(errType Error_Type, msg string) *Error

func NewRunningOnDifferentCellError 

func NewRunningOnDifferentCellError(expectedCellId, actualCellId string) *Error

func NewTaskTransitionError 

func NewTaskTransitionError(from, to Task_State) *Error

func (*Error) Equal 

func (err *Error) Equal(other error) bool

func (*Error) Error 

func (err *Error) Error() string

func (*Error) GetMessage 

func (m *Error) GetMessage() string

func (*Error) GetType 

func (m *Error) GetType() Error_Type

func (*Error) GoString 

func (this *Error) GoString() string

func (*Error) Marshal 

func (m *Error) Marshal() (data []byte, err error)

func (*Error) MarshalTo 

func (m *Error) MarshalTo(data []byte) (int, error)

func (*Error) ProtoMessage 

func (*Error) ProtoMessage()

func (*Error) Reset 

func (m *Error) Reset()

func (*Error) Size 

func (m *Error) Size() (n int)

func (*Error) String 

func (this *Error) String() string

func (*Error) ToError 

func (err *Error) ToError() error

func (*Error) Unmarshal 

func (m *Error) Unmarshal(data []byte) error

type Error_Type 

type Error_Type int32
const (
	Error_UnknownError                            Error_Type = 0
	Error_InvalidDomain                           Error_Type = 1
	Error_UnkownVersion                           Error_Type = 2
	Error_InvalidRecord                           Error_Type = 3
	Error_InvalidRequest                          Error_Type = 4
	Error_InvalidResponse                         Error_Type = 5
	Error_InvalidProtobufMessage                  Error_Type = 6
	Error_InvalidJSON                             Error_Type = 7
	Error_FailedToOpenEnvelope                    Error_Type = 8
	Error_InvalidStateTransition                  Error_Type = 9
	Error_Unauthorized                            Error_Type = 10
	Error_ResourceConflict                        Error_Type = 11
	Error_ResourceExists                          Error_Type = 12
	Error_ResourceNotFound                        Error_Type = 13
	Error_RouterError                             Error_Type = 14
	Error_ActualLRPCannotBeClaimed                Error_Type = 15
	Error_ActualLRPCannotBeStarted                Error_Type = 16
	Error_ActualLRPCannotBeCrashed                Error_Type = 17
	Error_ActualLRPCannotBeFailed                 Error_Type = 18
	Error_ActualLRPCannotBeRemoved                Error_Type = 19
	Error_ActualLRPCannotBeStopped                Error_Type = 20
	Error_ActualLRPCannotBeUnclaimed              Error_Type = 21
	Error_ActualLRPCannotBeEvacuated              Error_Type = 22
	Error_DesiredLRPCannotBeUpdated               Error_Type = 23
	Error_RunningOnDifferentCell                  Error_Type = 24
	Error_DesiredLRPSchedulingInfoCannotBeUpdated Error_Type = 25
)

func (Error_Type) Enum 

func (x Error_Type) Enum() *Error_Type

func (Error_Type) MarshalJSON 

func (x Error_Type) MarshalJSON() ([]byte, error)

func (Error_Type) String 

func (x Error_Type) String() string

func (*Error_Type) UnmarshalJSON 

func (x *Error_Type) UnmarshalJSON(data []byte) error

type EvacuateClaimedActualLRPRequest 

type EvacuateClaimedActualLRPRequest struct {
	ActualLrpKey         *ActualLRPKey         `protobuf:"bytes,1,opt,name=actual_lrp_key" json:"actual_lrp_key,omitempty"`
	ActualLrpInstanceKey *ActualLRPInstanceKey `protobuf:"bytes,2,opt,name=actual_lrp_instance_key" json:"actual_lrp_instance_key,omitempty"`
}

func (*EvacuateClaimedActualLRPRequest) GetActualLrpInstanceKey 

func (m *EvacuateClaimedActualLRPRequest) GetActualLrpInstanceKey() *ActualLRPInstanceKey

func (*EvacuateClaimedActualLRPRequest) GetActualLrpKey 

func (m *EvacuateClaimedActualLRPRequest) GetActualLrpKey() *ActualLRPKey

func (*EvacuateClaimedActualLRPRequest) GoString 

func (this *EvacuateClaimedActualLRPRequest) GoString() string

func (*EvacuateClaimedActualLRPRequest) Marshal 

func (m *EvacuateClaimedActualLRPRequest) Marshal() (data []byte, err error)

func (*EvacuateClaimedActualLRPRequest) MarshalTo 

func (m *EvacuateClaimedActualLRPRequest) MarshalTo(data []byte) (int, error)

func (*EvacuateClaimedActualLRPRequest) ProtoMessage 

func (*EvacuateClaimedActualLRPRequest) ProtoMessage()

func (*EvacuateClaimedActualLRPRequest) Reset 

func (m *EvacuateClaimedActualLRPRequest) Reset()

func (*EvacuateClaimedActualLRPRequest) Size 

func (m *EvacuateClaimedActualLRPRequest) Size() (n int)

func (*EvacuateClaimedActualLRPRequest) String 

func (this *EvacuateClaimedActualLRPRequest) String() string

func (*EvacuateClaimedActualLRPRequest) Unmarshal 

func (m *EvacuateClaimedActualLRPRequest) Unmarshal(data []byte) error

func (*EvacuateClaimedActualLRPRequest) Validate 

func (request *EvacuateClaimedActualLRPRequest) Validate() error

type EvacuateCrashedActualLRPRequest 

type EvacuateCrashedActualLRPRequest struct {
	ActualLrpKey         *ActualLRPKey         `protobuf:"bytes,1,opt,name=actual_lrp_key" json:"actual_lrp_key,omitempty"`
	ActualLrpInstanceKey *ActualLRPInstanceKey `protobuf:"bytes,2,opt,name=actual_lrp_instance_key" json:"actual_lrp_instance_key,omitempty"`
	ErrorMessage         string                `protobuf:"bytes,3,opt,name=error_message" json:"error_message"`
}

func (*EvacuateCrashedActualLRPRequest) GetActualLrpInstanceKey 

func (m *EvacuateCrashedActualLRPRequest) GetActualLrpInstanceKey() *ActualLRPInstanceKey

func (*EvacuateCrashedActualLRPRequest) GetActualLrpKey 

func (m *EvacuateCrashedActualLRPRequest) GetActualLrpKey() *ActualLRPKey

func (*EvacuateCrashedActualLRPRequest) GetErrorMessage 

func (m *EvacuateCrashedActualLRPRequest) GetErrorMessage() string

func (*EvacuateCrashedActualLRPRequest) GoString 

func (this *EvacuateCrashedActualLRPRequest) GoString() string

func (*EvacuateCrashedActualLRPRequest) Marshal 

func (m *EvacuateCrashedActualLRPRequest) Marshal() (data []byte, err error)

func (*EvacuateCrashedActualLRPRequest) MarshalTo 

func (m *EvacuateCrashedActualLRPRequest) MarshalTo(data []byte) (int, error)

func (*EvacuateCrashedActualLRPRequest) ProtoMessage 

func (*EvacuateCrashedActualLRPRequest) ProtoMessage()

func (*EvacuateCrashedActualLRPRequest) Reset 

func (m *EvacuateCrashedActualLRPRequest) Reset()

func (*EvacuateCrashedActualLRPRequest) Size 

func (m *EvacuateCrashedActualLRPRequest) Size() (n int)

func (*EvacuateCrashedActualLRPRequest) String 

func (this *EvacuateCrashedActualLRPRequest) String() string

func (*EvacuateCrashedActualLRPRequest) Unmarshal 

func (m *EvacuateCrashedActualLRPRequest) Unmarshal(data []byte) error

func (*EvacuateCrashedActualLRPRequest) Validate 

func (request *EvacuateCrashedActualLRPRequest) Validate() error

type EvacuateRunningActualLRPRequest 

type EvacuateRunningActualLRPRequest struct {
	ActualLrpKey         *ActualLRPKey         `protobuf:"bytes,1,opt,name=actual_lrp_key" json:"actual_lrp_key,omitempty"`
	ActualLrpInstanceKey *ActualLRPInstanceKey `protobuf:"bytes,2,opt,name=actual_lrp_instance_key" json:"actual_lrp_instance_key,omitempty"`
	ActualLrpNetInfo     *ActualLRPNetInfo     `protobuf:"bytes,3,opt,name=actual_lrp_net_info" json:"actual_lrp_net_info,omitempty"`
	Ttl                  uint64                `protobuf:"varint,4,opt,name=ttl" json:"ttl"`
}

func (*EvacuateRunningActualLRPRequest) GetActualLrpInstanceKey 

func (m *EvacuateRunningActualLRPRequest) GetActualLrpInstanceKey() *ActualLRPInstanceKey

func (*EvacuateRunningActualLRPRequest) GetActualLrpKey 

func (m *EvacuateRunningActualLRPRequest) GetActualLrpKey() *ActualLRPKey

func (*EvacuateRunningActualLRPRequest) GetActualLrpNetInfo 

func (m *EvacuateRunningActualLRPRequest) GetActualLrpNetInfo() *ActualLRPNetInfo

func (*EvacuateRunningActualLRPRequest) GetTtl 

func (m *EvacuateRunningActualLRPRequest) GetTtl() uint64

func (*EvacuateRunningActualLRPRequest) GoString 

func (this *EvacuateRunningActualLRPRequest) GoString() string

func (*EvacuateRunningActualLRPRequest) Marshal 

func (m *EvacuateRunningActualLRPRequest) Marshal() (data []byte, err error)

func (*EvacuateRunningActualLRPRequest) MarshalTo 

func (m *EvacuateRunningActualLRPRequest) MarshalTo(data []byte) (int, error)

func (*EvacuateRunningActualLRPRequest) ProtoMessage 

func (*EvacuateRunningActualLRPRequest) ProtoMessage()

func (*EvacuateRunningActualLRPRequest) Reset 

func (m *EvacuateRunningActualLRPRequest) Reset()

func (*EvacuateRunningActualLRPRequest) Size 

func (m *EvacuateRunningActualLRPRequest) Size() (n int)

func (*EvacuateRunningActualLRPRequest) String 

func (this *EvacuateRunningActualLRPRequest) String() string

func (*EvacuateRunningActualLRPRequest) Unmarshal 

func (m *EvacuateRunningActualLRPRequest) Unmarshal(data []byte) error

func (*EvacuateRunningActualLRPRequest) Validate 

func (request *EvacuateRunningActualLRPRequest) Validate() error

type EvacuateStoppedActualLRPRequest 

type EvacuateStoppedActualLRPRequest struct {
	ActualLrpKey         *ActualLRPKey         `protobuf:"bytes,1,opt,name=actual_lrp_key" json:"actual_lrp_key,omitempty"`
	ActualLrpInstanceKey *ActualLRPInstanceKey `protobuf:"bytes,2,opt,name=actual_lrp_instance_key" json:"actual_lrp_instance_key,omitempty"`
}

func (*EvacuateStoppedActualLRPRequest) GetActualLrpInstanceKey 

func (m *EvacuateStoppedActualLRPRequest) GetActualLrpInstanceKey() *ActualLRPInstanceKey

func (*EvacuateStoppedActualLRPRequest) GetActualLrpKey 

func (m *EvacuateStoppedActualLRPRequest) GetActualLrpKey() *ActualLRPKey

func (*EvacuateStoppedActualLRPRequest) GoString 

func (this *EvacuateStoppedActualLRPRequest) GoString() string

func (*EvacuateStoppedActualLRPRequest) Marshal 

func (m *EvacuateStoppedActualLRPRequest) Marshal() (data []byte, err error)

func (*EvacuateStoppedActualLRPRequest) MarshalTo 

func (m *EvacuateStoppedActualLRPRequest) MarshalTo(data []byte) (int, error)

func (*EvacuateStoppedActualLRPRequest) ProtoMessage 

func (*EvacuateStoppedActualLRPRequest) ProtoMessage()

func (*EvacuateStoppedActualLRPRequest) Reset 

func (m *EvacuateStoppedActualLRPRequest) Reset()

func (*EvacuateStoppedActualLRPRequest) Size 

func (m *EvacuateStoppedActualLRPRequest) Size() (n int)

func (*EvacuateStoppedActualLRPRequest) String 

func (this *EvacuateStoppedActualLRPRequest) String() string

func (*EvacuateStoppedActualLRPRequest) Unmarshal 

func (m *EvacuateStoppedActualLRPRequest) Unmarshal(data []byte) error

func (*EvacuateStoppedActualLRPRequest) Validate 

func (request *EvacuateStoppedActualLRPRequest) Validate() error

type EvacuationResponse 

type EvacuationResponse struct {
	Error         *Error `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	KeepContainer bool   `protobuf:"varint,2,opt,name=keep_container" json:"keep_container"`
}

func (*EvacuationResponse) GetError 

func (m *EvacuationResponse) GetError() *Error

func (*EvacuationResponse) GetKeepContainer 

func (m *EvacuationResponse) GetKeepContainer() bool

func (*EvacuationResponse) GoString 

func (this *EvacuationResponse) GoString() string

func (*EvacuationResponse) Marshal 

func (m *EvacuationResponse) Marshal() (data []byte, err error)

func (*EvacuationResponse) MarshalTo 

func (m *EvacuationResponse) MarshalTo(data []byte) (int, error)

func (*EvacuationResponse) ProtoMessage 

func (*EvacuationResponse) ProtoMessage()

func (*EvacuationResponse) Reset 

func (m *EvacuationResponse) Reset()

func (*EvacuationResponse) Size 

func (m *EvacuationResponse) Size() (n int)

func (*EvacuationResponse) String 

func (this *EvacuationResponse) String() string

func (*EvacuationResponse) Unmarshal 

func (m *EvacuationResponse) Unmarshal(data []byte) error

type Event 

type Event interface {
	EventType() string
	Key() string
	proto.Message
}

func VersionDesiredLRPsToV0 

func VersionDesiredLRPsToV0(event Event) Event

type FailActualLRPRequest 

type FailActualLRPRequest struct {
	ActualLrpKey *ActualLRPKey `protobuf:"bytes,1,opt,name=actual_lrp_key" json:"actual_lrp_key,omitempty"`
	ErrorMessage string        `protobuf:"bytes,2,opt,name=error_message" json:"error_message"`
}

func (*FailActualLRPRequest) Equal 

func (this *FailActualLRPRequest) Equal(that interface{}) bool

func (*FailActualLRPRequest) GetActualLrpKey 

func (m *FailActualLRPRequest) GetActualLrpKey() *ActualLRPKey

func (*FailActualLRPRequest) GetErrorMessage 

func (m *FailActualLRPRequest) GetErrorMessage() string

func (*FailActualLRPRequest) GoString 

func (this *FailActualLRPRequest) GoString() string

func (*FailActualLRPRequest) Marshal 

func (m *FailActualLRPRequest) Marshal() (data []byte, err error)

func (*FailActualLRPRequest) MarshalTo 

func (m *FailActualLRPRequest) MarshalTo(data []byte) (int, error)

func (*FailActualLRPRequest) ProtoMessage 

func (*FailActualLRPRequest) ProtoMessage()

func (*FailActualLRPRequest) Reset 

func (m *FailActualLRPRequest) Reset()

func (*FailActualLRPRequest) Size 

func (m *FailActualLRPRequest) Size() (n int)

func (*FailActualLRPRequest) String 

func (this *FailActualLRPRequest) String() string

func (*FailActualLRPRequest) Unmarshal 

func (m *FailActualLRPRequest) Unmarshal(data []byte) error

func (*FailActualLRPRequest) Validate 

func (request *FailActualLRPRequest) Validate() error

type FailTaskRequest 

type FailTaskRequest struct {
	TaskGuid      string `protobuf:"bytes,1,opt,name=task_guid" json:"task_guid"`
	FailureReason string `protobuf:"bytes,2,opt,name=failure_reason" json:"failure_reason"`
}

func (*FailTaskRequest) Equal 

func (this *FailTaskRequest) Equal(that interface{}) bool

func (*FailTaskRequest) GetFailureReason 

func (m *FailTaskRequest) GetFailureReason() string

func (*FailTaskRequest) GetTaskGuid 

func (m *FailTaskRequest) GetTaskGuid() string

func (*FailTaskRequest) GoString 

func (this *FailTaskRequest) GoString() string

func (*FailTaskRequest) Marshal 

func (m *FailTaskRequest) Marshal() (data []byte, err error)

func (*FailTaskRequest) MarshalTo 

func (m *FailTaskRequest) MarshalTo(data []byte) (int, error)

func (*FailTaskRequest) ProtoMessage 

func (*FailTaskRequest) ProtoMessage()

func (*FailTaskRequest) Reset 

func (m *FailTaskRequest) Reset()

func (*FailTaskRequest) Size 

func (m *FailTaskRequest) Size() (n int)

func (*FailTaskRequest) String 

func (this *FailTaskRequest) String() string

func (*FailTaskRequest) Unmarshal 

func (m *FailTaskRequest) Unmarshal(data []byte) error

func (*FailTaskRequest) Validate 

func (req *FailTaskRequest) Validate() error

type ICMPInfo 

type ICMPInfo struct {
	Type int32 `protobuf:"varint,1,opt,name=type" json:"type"`
	Code int32 `protobuf:"varint,2,opt,name=code" json:"code"`
}

func (*ICMPInfo) Equal 

func (this *ICMPInfo) Equal(that interface{}) bool

func (*ICMPInfo) GetCode 

func (m *ICMPInfo) GetCode() int32

func (*ICMPInfo) GetType 

func (m *ICMPInfo) GetType() int32

func (*ICMPInfo) GoString 

func (this *ICMPInfo) GoString() string

func (*ICMPInfo) Marshal 

func (m *ICMPInfo) Marshal() (data []byte, err error)

func (*ICMPInfo) MarshalTo 

func (m *ICMPInfo) MarshalTo(data []byte) (int, error)

func (*ICMPInfo) ProtoMessage 

func (*ICMPInfo) ProtoMessage()

func (*ICMPInfo) Reset 

func (m *ICMPInfo) Reset()

func (*ICMPInfo) Size 

func (m *ICMPInfo) Size() (n int)

func (*ICMPInfo) String 

func (this *ICMPInfo) String() string

func (*ICMPInfo) Unmarshal 

func (m *ICMPInfo) Unmarshal(data []byte) error

type ModificationTag 

type ModificationTag struct {
	Epoch string `protobuf:"bytes,1,opt,name=epoch" json:"epoch"`
	Index uint32 `protobuf:"varint,2,opt,name=index" json:"index"`
}

func NewModificationTag 

func NewModificationTag(epoch string, index uint32) ModificationTag

func (*ModificationTag) Equal 

func (this *ModificationTag) Equal(that interface{}) bool

func (*ModificationTag) GetEpoch 

func (m *ModificationTag) GetEpoch() string

func (*ModificationTag) GetIndex 

func (m *ModificationTag) GetIndex() uint32

func (*ModificationTag) GoString 

func (this *ModificationTag) GoString() string

func (*ModificationTag) Increment 

func (t *ModificationTag) Increment()

func (*ModificationTag) Marshal 

func (m *ModificationTag) Marshal() (data []byte, err error)

func (*ModificationTag) MarshalTo 

func (m *ModificationTag) MarshalTo(data []byte) (int, error)

func (*ModificationTag) ProtoMessage 

func (*ModificationTag) ProtoMessage()

func (*ModificationTag) Reset 

func (m *ModificationTag) Reset()

func (*ModificationTag) Size 

func (m *ModificationTag) Size() (n int)

func (*ModificationTag) String 

func (this *ModificationTag) String() string

func (*ModificationTag) SucceededBy 

func (m *ModificationTag) SucceededBy(other *ModificationTag) bool

func (*ModificationTag) Unmarshal 

func (m *ModificationTag) Unmarshal(data []byte) error

type ParallelAction 

type ParallelAction struct {
	Actions   []*Action `protobuf:"bytes,1,rep,name=actions" json:"actions,omitempty"`
	LogSource string    `protobuf:"bytes,2,opt,name=log_source" json:"log_source,omitempty"`
}

func Parallel 

func Parallel(actions ...ActionInterface) *ParallelAction

func (*ParallelAction) ActionType 

func (a *ParallelAction) ActionType() string

func (*ParallelAction) Equal 

func (this *ParallelAction) Equal(that interface{}) bool

func (*ParallelAction) GetActions 

func (m *ParallelAction) GetActions() []*Action

func (*ParallelAction) GetLogSource 

func (m *ParallelAction) GetLogSource() string

func (*ParallelAction) GoString 

func (this *ParallelAction) GoString() string

func (*ParallelAction) Marshal 

func (m *ParallelAction) Marshal() (data []byte, err error)

func (*ParallelAction) MarshalTo 

func (m *ParallelAction) MarshalTo(data []byte) (int, error)

func (*ParallelAction) MigrateFromVersion 

func (*ParallelAction) MigrateFromVersion(v format.Version) error

func (*ParallelAction) ProtoMessage 

func (*ParallelAction) ProtoMessage()

func (*ParallelAction) Reset 

func (m *ParallelAction) Reset()

func (*ParallelAction) Size 

func (m *ParallelAction) Size() (n int)

func (*ParallelAction) String 

func (this *ParallelAction) String() string

func (*ParallelAction) Unmarshal 

func (m *ParallelAction) Unmarshal(data []byte) error

func (ParallelAction) Validate 

func (a ParallelAction) Validate() error

func (*ParallelAction) Version 

func (*ParallelAction) Version() format.Version

type PingResponse 

type PingResponse struct {
	Available bool `protobuf:"varint,1,opt,name=available" json:"available"`
}

func (*PingResponse) Equal 

func (this *PingResponse) Equal(that interface{}) bool

func (*PingResponse) GetAvailable 

func (m *PingResponse) GetAvailable() bool

func (*PingResponse) GoString 

func (this *PingResponse) GoString() string

func (*PingResponse) Marshal 

func (m *PingResponse) Marshal() (data []byte, err error)

func (*PingResponse) MarshalTo 

func (m *PingResponse) MarshalTo(data []byte) (int, error)

func (*PingResponse) ProtoMessage 

func (*PingResponse) ProtoMessage()

func (*PingResponse) Reset 

func (m *PingResponse) Reset()

func (*PingResponse) Size 

func (m *PingResponse) Size() (n int)

func (*PingResponse) String 

func (this *PingResponse) String() string

func (*PingResponse) Unmarshal 

func (m *PingResponse) Unmarshal(data []byte) error

type PortMapping 

type PortMapping struct {
	ContainerPort uint32 `protobuf:"varint,1,opt,name=container_port" json:"container_port"`
	HostPort      uint32 `protobuf:"varint,2,opt,name=host_port" json:"host_port"`
}

func NewPortMapping 

func NewPortMapping(hostPort, containerPort uint32) *PortMapping

func (*PortMapping) Equal 

func (this *PortMapping) Equal(that interface{}) bool

func (*PortMapping) GetContainerPort 

func (m *PortMapping) GetContainerPort() uint32

func (*PortMapping) GetHostPort 

func (m *PortMapping) GetHostPort() uint32

func (*PortMapping) GoString 

func (this *PortMapping) GoString() string

func (*PortMapping) Marshal 

func (m *PortMapping) Marshal() (data []byte, err error)

func (*PortMapping) MarshalTo 

func (m *PortMapping) MarshalTo(data []byte) (int, error)

func (*PortMapping) ProtoMessage 

func (*PortMapping) ProtoMessage()

func (*PortMapping) Reset 

func (m *PortMapping) Reset()

func (*PortMapping) Size 

func (m *PortMapping) Size() (n int)

func (*PortMapping) String 

func (this *PortMapping) String() string

func (*PortMapping) Unmarshal 

func (m *PortMapping) Unmarshal(data []byte) error

type PortRange 

type PortRange struct {
	Start uint32 `protobuf:"varint,1,opt,name=start" json:"start"`
	End   uint32 `protobuf:"varint,2,opt,name=end" json:"end"`
}

func (*PortRange) Equal 

func (this *PortRange) Equal(that interface{}) bool

func (*PortRange) GetEnd 

func (m *PortRange) GetEnd() uint32

func (*PortRange) GetStart 

func (m *PortRange) GetStart() uint32

func (*PortRange) GoString 

func (this *PortRange) GoString() string

func (*PortRange) Marshal 

func (m *PortRange) Marshal() (data []byte, err error)

func (*PortRange) MarshalTo 

func (m *PortRange) MarshalTo(data []byte) (int, error)

func (*PortRange) ProtoMessage 

func (*PortRange) ProtoMessage()

func (*PortRange) Reset 

func (m *PortRange) Reset()

func (*PortRange) Size 

func (m *PortRange) Size() (n int)

func (*PortRange) String 

func (this *PortRange) String() string

func (*PortRange) Unmarshal 

func (m *PortRange) Unmarshal(data []byte) error

type ProtoRoutes 

type ProtoRoutes struct {
	Routes map[string][]byte `` /* 132-byte string literal not displayed */
}

helper message for marshalling routes

func (*ProtoRoutes) Equal 

func (this *ProtoRoutes) Equal(that interface{}) bool

func (*ProtoRoutes) GetRoutes 

func (m *ProtoRoutes) GetRoutes() map[string][]byte

func (*ProtoRoutes) GoString 

func (this *ProtoRoutes) GoString() string

func (*ProtoRoutes) Marshal 

func (m *ProtoRoutes) Marshal() (data []byte, err error)

func (*ProtoRoutes) MarshalTo 

func (m *ProtoRoutes) MarshalTo(data []byte) (int, error)

func (*ProtoRoutes) ProtoMessage 

func (*ProtoRoutes) ProtoMessage()

func (*ProtoRoutes) Reset 

func (m *ProtoRoutes) Reset()

func (*ProtoRoutes) Size 

func (m *ProtoRoutes) Size() (n int)

func (*ProtoRoutes) String 

func (this *ProtoRoutes) String() string

func (*ProtoRoutes) Unmarshal 

func (m *ProtoRoutes) Unmarshal(data []byte) error

type RemoveActualLRPRequest 

type RemoveActualLRPRequest struct {
	ProcessGuid string `protobuf:"bytes,1,opt,name=process_guid" json:"process_guid"`
	Index       int32  `protobuf:"varint,2,opt,name=index" json:"index"`
}

func (*RemoveActualLRPRequest) Equal 

func (this *RemoveActualLRPRequest) Equal(that interface{}) bool

func (*RemoveActualLRPRequest) GetIndex 

func (m *RemoveActualLRPRequest) GetIndex() int32

func (*RemoveActualLRPRequest) GetProcessGuid 

func (m *RemoveActualLRPRequest) GetProcessGuid() string

func (*RemoveActualLRPRequest) GoString 

func (this *RemoveActualLRPRequest) GoString() string

func (*RemoveActualLRPRequest) Marshal 

func (m *RemoveActualLRPRequest) Marshal() (data []byte, err error)

func (*RemoveActualLRPRequest) MarshalTo 

func (m *RemoveActualLRPRequest) MarshalTo(data []byte) (int, error)

func (*RemoveActualLRPRequest) ProtoMessage 

func (*RemoveActualLRPRequest) ProtoMessage()

func (*RemoveActualLRPRequest) Reset 

func (m *RemoveActualLRPRequest) Reset()

func (*RemoveActualLRPRequest) Size 

func (m *RemoveActualLRPRequest) Size() (n int)

func (*RemoveActualLRPRequest) String 

func (this *RemoveActualLRPRequest) String() string

func (*RemoveActualLRPRequest) Unmarshal 

func (m *RemoveActualLRPRequest) Unmarshal(data []byte) error

func (*RemoveActualLRPRequest) Validate 

func (request *RemoveActualLRPRequest) Validate() error

type RemoveDesiredLRPRequest 

type RemoveDesiredLRPRequest struct {
	ProcessGuid string `protobuf:"bytes,1,opt,name=process_guid" json:"process_guid"`
}

func (*RemoveDesiredLRPRequest) Equal 

func (this *RemoveDesiredLRPRequest) Equal(that interface{}) bool

func (*RemoveDesiredLRPRequest) GetProcessGuid 

func (m *RemoveDesiredLRPRequest) GetProcessGuid() string

func (*RemoveDesiredLRPRequest) GoString 

func (this *RemoveDesiredLRPRequest) GoString() string

func (*RemoveDesiredLRPRequest) Marshal 

func (m *RemoveDesiredLRPRequest) Marshal() (data []byte, err error)

func (*RemoveDesiredLRPRequest) MarshalTo 

func (m *RemoveDesiredLRPRequest) MarshalTo(data []byte) (int, error)

func (*RemoveDesiredLRPRequest) ProtoMessage 

func (*RemoveDesiredLRPRequest) ProtoMessage()

func (*RemoveDesiredLRPRequest) Reset 

func (m *RemoveDesiredLRPRequest) Reset()

func (*RemoveDesiredLRPRequest) Size 

func (m *RemoveDesiredLRPRequest) Size() (n int)

func (*RemoveDesiredLRPRequest) String 

func (this *RemoveDesiredLRPRequest) String() string

func (*RemoveDesiredLRPRequest) Unmarshal 

func (m *RemoveDesiredLRPRequest) Unmarshal(data []byte) error

func (*RemoveDesiredLRPRequest) Validate 

func (request *RemoveDesiredLRPRequest) Validate() error

type RemoveEvacuatingActualLRPRequest 

type RemoveEvacuatingActualLRPRequest struct {
	ActualLrpKey         *ActualLRPKey         `protobuf:"bytes,1,opt,name=actual_lrp_key" json:"actual_lrp_key,omitempty"`
	ActualLrpInstanceKey *ActualLRPInstanceKey `protobuf:"bytes,2,opt,name=actual_lrp_instance_key" json:"actual_lrp_instance_key,omitempty"`
}

func (*RemoveEvacuatingActualLRPRequest) GetActualLrpInstanceKey 

func (m *RemoveEvacuatingActualLRPRequest) GetActualLrpInstanceKey() *ActualLRPInstanceKey

func (*RemoveEvacuatingActualLRPRequest) GetActualLrpKey 

func (m *RemoveEvacuatingActualLRPRequest) GetActualLrpKey() *ActualLRPKey

func (*RemoveEvacuatingActualLRPRequest) GoString 

func (this *RemoveEvacuatingActualLRPRequest) GoString() string

func (*RemoveEvacuatingActualLRPRequest) Marshal 

func (m *RemoveEvacuatingActualLRPRequest) Marshal() (data []byte, err error)

func (*RemoveEvacuatingActualLRPRequest) MarshalTo 

func (m *RemoveEvacuatingActualLRPRequest) MarshalTo(data []byte) (int, error)

func (*RemoveEvacuatingActualLRPRequest) ProtoMessage 

func (*RemoveEvacuatingActualLRPRequest) ProtoMessage()

func (*RemoveEvacuatingActualLRPRequest) Reset 

func (m *RemoveEvacuatingActualLRPRequest) Reset()

func (*RemoveEvacuatingActualLRPRequest) Size 

func (m *RemoveEvacuatingActualLRPRequest) Size() (n int)

func (*RemoveEvacuatingActualLRPRequest) String 

func (this *RemoveEvacuatingActualLRPRequest) String() string

func (*RemoveEvacuatingActualLRPRequest) Unmarshal 

func (m *RemoveEvacuatingActualLRPRequest) Unmarshal(data []byte) error

func (*RemoveEvacuatingActualLRPRequest) Validate 

func (request *RemoveEvacuatingActualLRPRequest) Validate() error

type RemoveEvacuatingActualLRPResponse 

type RemoveEvacuatingActualLRPResponse struct {
	Error *Error `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
}

func (*RemoveEvacuatingActualLRPResponse) GetError 

func (m *RemoveEvacuatingActualLRPResponse) GetError() *Error

func (*RemoveEvacuatingActualLRPResponse) GoString 

func (this *RemoveEvacuatingActualLRPResponse) GoString() string

func (*RemoveEvacuatingActualLRPResponse) Marshal 

func (m *RemoveEvacuatingActualLRPResponse) Marshal() (data []byte, err error)

func (*RemoveEvacuatingActualLRPResponse) MarshalTo 

func (m *RemoveEvacuatingActualLRPResponse) MarshalTo(data []byte) (int, error)

func (*RemoveEvacuatingActualLRPResponse) ProtoMessage 

func (*RemoveEvacuatingActualLRPResponse) ProtoMessage()

func (*RemoveEvacuatingActualLRPResponse) Reset 

func (m *RemoveEvacuatingActualLRPResponse) Reset()

func (*RemoveEvacuatingActualLRPResponse) Size 

func (m *RemoveEvacuatingActualLRPResponse) Size() (n int)

func (*RemoveEvacuatingActualLRPResponse) String 

func (this *RemoveEvacuatingActualLRPResponse) String() string

func (*RemoveEvacuatingActualLRPResponse) Unmarshal 

func (m *RemoveEvacuatingActualLRPResponse) Unmarshal(data []byte) error

type ResourceLimits 

type ResourceLimits struct {
	Nofile *uint64 `protobuf:"varint,1,opt,name=nofile" json:"nofile,omitempty"`
}

func (*ResourceLimits) Equal 

func (this *ResourceLimits) Equal(that interface{}) bool

func (*ResourceLimits) GetNofile 

func (m *ResourceLimits) GetNofile() uint64

func (*ResourceLimits) GoString 

func (this *ResourceLimits) GoString() string

func (*ResourceLimits) Marshal 

func (m *ResourceLimits) Marshal() (data []byte, err error)

func (*ResourceLimits) MarshalTo 

func (m *ResourceLimits) MarshalTo(data []byte) (int, error)

func (*ResourceLimits) ProtoMessage 

func (*ResourceLimits) ProtoMessage()

func (*ResourceLimits) Reset 

func (m *ResourceLimits) Reset()

func (*ResourceLimits) Size 

func (m *ResourceLimits) Size() (n int)

func (*ResourceLimits) String 

func (this *ResourceLimits) String() string

func (*ResourceLimits) Unmarshal 

func (m *ResourceLimits) Unmarshal(data []byte) error

type RestartCalculator 

type RestartCalculator struct {
	ImmediateRestarts  int32         `json:"immediate_restarts"`
	MaxBackoffCount    int32         `json:"max_backoff_count"`
	MaxBackoffDuration time.Duration `json:"max_backoff_duration"`
	MaxRestartAttempts int32         `json:"max_restart_attempts"`
}

func NewDefaultRestartCalculator 

func NewDefaultRestartCalculator() RestartCalculator

func NewRestartCalculator 

func NewRestartCalculator(immediateRestarts int32, maxBackoffDuration time.Duration, maxRestarts int32) RestartCalculator

func (RestartCalculator) ShouldRestart 

func (r RestartCalculator) ShouldRestart(now, crashedAt int64, crashCount int32) bool

func (RestartCalculator) Validate 

func (r RestartCalculator) Validate() error

type RetireActualLRPRequest 

type RetireActualLRPRequest struct {
	ActualLrpKey *ActualLRPKey `protobuf:"bytes,1,opt,name=actual_lrp_key" json:"actual_lrp_key,omitempty"`
}

func (*RetireActualLRPRequest) Equal 

func (this *RetireActualLRPRequest) Equal(that interface{}) bool

func (*RetireActualLRPRequest) GetActualLrpKey 

func (m *RetireActualLRPRequest) GetActualLrpKey() *ActualLRPKey

func (*RetireActualLRPRequest) GoString 

func (this *RetireActualLRPRequest) GoString() string

func (*RetireActualLRPRequest) Marshal 

func (m *RetireActualLRPRequest) Marshal() (data []byte, err error)

func (*RetireActualLRPRequest) MarshalTo 

func (m *RetireActualLRPRequest) MarshalTo(data []byte) (int, error)

func (*RetireActualLRPRequest) ProtoMessage 

func (*RetireActualLRPRequest) ProtoMessage()

func (*RetireActualLRPRequest) Reset 

func (m *RetireActualLRPRequest) Reset()

func (*RetireActualLRPRequest) Size 

func (m *RetireActualLRPRequest) Size() (n int)

func (*RetireActualLRPRequest) String 

func (this *RetireActualLRPRequest) String() string

func (*RetireActualLRPRequest) Unmarshal 

func (m *RetireActualLRPRequest) Unmarshal(data []byte) error

func (*RetireActualLRPRequest) Validate 

func (request *RetireActualLRPRequest) Validate() error

type Routes 

type Routes map[string]*json.RawMessage

func (*Routes) Equal 

func (r *Routes) Equal(other Routes) bool

func (*Routes) Marshal 

func (r *Routes) Marshal() ([]byte, error)

func (*Routes) MarshalTo 

func (r *Routes) MarshalTo(data []byte) (n int, err error)

func (*Routes) Size 

func (r *Routes) Size() int

func (*Routes) Unmarshal 

func (r *Routes) Unmarshal(data []byte) error

func (Routes) Validate 

func (r Routes) Validate() error

type RunAction 

type RunAction struct {
	Path              string                 `protobuf:"bytes,1,opt,name=path" json:"path"`
	Args              []string               `protobuf:"bytes,2,rep,name=args" json:"args,omitempty"`
	Dir               string                 `protobuf:"bytes,3,opt,name=dir" json:"dir,omitempty"`
	Env               []*EnvironmentVariable `protobuf:"bytes,4,rep,name=env" json:"env,omitempty"`
	ResourceLimits    *ResourceLimits        `protobuf:"bytes,5,opt,name=resource_limits" json:"resource_limits,omitempty"`
	User              string                 `protobuf:"bytes,6,opt,name=user" json:"user"`
	LogSource         string                 `protobuf:"bytes,7,opt,name=log_source" json:"log_source,omitempty"`
	SuppressLogOutput bool                   `protobuf:"varint,8,opt,name=suppress_log_output" json:"suppress_log_output"`
}

func (*RunAction) ActionType 

func (a *RunAction) ActionType() string

func (*RunAction) Equal 

func (this *RunAction) Equal(that interface{}) bool

func (*RunAction) GetArgs 

func (m *RunAction) GetArgs() []string

func (*RunAction) GetDir 

func (m *RunAction) GetDir() string

func (*RunAction) GetEnv 

func (m *RunAction) GetEnv() []*EnvironmentVariable

func (*RunAction) GetLogSource 

func (m *RunAction) GetLogSource() string

func (*RunAction) GetPath 

func (m *RunAction) GetPath() string

func (*RunAction) GetResourceLimits 

func (m *RunAction) GetResourceLimits() *ResourceLimits

func (*RunAction) GetSuppressLogOutput 

func (m *RunAction) GetSuppressLogOutput() bool

func (*RunAction) GetUser 

func (m *RunAction) GetUser() string

func (*RunAction) GoString 

func (this *RunAction) GoString() string

func (*RunAction) Marshal 

func (m *RunAction) Marshal() (data []byte, err error)

func (*RunAction) MarshalTo 

func (m *RunAction) MarshalTo(data []byte) (int, error)

func (*RunAction) MigrateFromVersion 

func (*RunAction) MigrateFromVersion(v format.Version) error

func (*RunAction) ProtoMessage 

func (*RunAction) ProtoMessage()

func (*RunAction) Reset 

func (m *RunAction) Reset()

func (*RunAction) Size 

func (m *RunAction) Size() (n int)

func (*RunAction) String 

func (this *RunAction) String() string

func (*RunAction) Unmarshal 

func (m *RunAction) Unmarshal(data []byte) error

func (RunAction) Validate 

func (a RunAction) Validate() error

func (*RunAction) Version 

func (*RunAction) Version() format.Version

type SecurityGroupRule 

type SecurityGroupRule struct {
	Protocol     string     `protobuf:"bytes,1,opt,name=protocol" json:"protocol,omitempty"`
	Destinations []string   `protobuf:"bytes,2,rep,name=destinations" json:"destinations,omitempty"`
	Ports        []uint32   `protobuf:"varint,3,rep,name=ports" json:"ports,omitempty"`
	PortRange    *PortRange `protobuf:"bytes,4,opt,name=port_range" json:"port_range,omitempty"`
	IcmpInfo     *ICMPInfo  `protobuf:"bytes,5,opt,name=icmp_info" json:"icmp_info,omitempty"`
	Log          bool       `protobuf:"varint,6,opt,name=log" json:"log"`
}

func (*SecurityGroupRule) Equal 

func (this *SecurityGroupRule) Equal(that interface{}) bool

func (*SecurityGroupRule) GetDestinations 

func (m *SecurityGroupRule) GetDestinations() []string

func (*SecurityGroupRule) GetIcmpInfo 

func (m *SecurityGroupRule) GetIcmpInfo() *ICMPInfo

func (*SecurityGroupRule) GetLog 

func (m *SecurityGroupRule) GetLog() bool

func (*SecurityGroupRule) GetPortRange 

func (m *SecurityGroupRule) GetPortRange() *PortRange

func (*SecurityGroupRule) GetPorts 

func (m *SecurityGroupRule) GetPorts() []uint32

func (*SecurityGroupRule) GetProtocol 

func (m *SecurityGroupRule) GetProtocol() string

func (*SecurityGroupRule) GoString 

func (this *SecurityGroupRule) GoString() string

func (*SecurityGroupRule) Marshal 

func (m *SecurityGroupRule) Marshal() (data []byte, err error)

func (*SecurityGroupRule) MarshalTo 

func (m *SecurityGroupRule) MarshalTo(data []byte) (int, error)

func (*SecurityGroupRule) ProtoMessage 

func (*SecurityGroupRule) ProtoMessage()

func (*SecurityGroupRule) Reset 

func (m *SecurityGroupRule) Reset()

func (*SecurityGroupRule) Size 

func (m *SecurityGroupRule) Size() (n int)

func (*SecurityGroupRule) String 

func (this *SecurityGroupRule) String() string

func (*SecurityGroupRule) Unmarshal 

func (m *SecurityGroupRule) Unmarshal(data []byte) error

func (SecurityGroupRule) Validate 

func (rule SecurityGroupRule) Validate() error

type SerialAction 

type SerialAction struct {
	Actions   []*Action `protobuf:"bytes,1,rep,name=actions" json:"actions,omitempty"`
	LogSource string    `protobuf:"bytes,2,opt,name=log_source" json:"log_source,omitempty"`
}

func Serial 

func Serial(actions ...ActionInterface) *SerialAction

func (*SerialAction) ActionType 

func (a *SerialAction) ActionType() string

func (*SerialAction) Equal 

func (this *SerialAction) Equal(that interface{}) bool

func (*SerialAction) GetActions 

func (m *SerialAction) GetActions() []*Action

func (*SerialAction) GetLogSource 

func (m *SerialAction) GetLogSource() string

func (*SerialAction) GoString 

func (this *SerialAction) GoString() string

func (*SerialAction) Marshal 

func (m *SerialAction) Marshal() (data []byte, err error)

func (*SerialAction) MarshalTo 

func (m *SerialAction) MarshalTo(data []byte) (int, error)

func (*SerialAction) MigrateFromVersion 

func (*SerialAction) MigrateFromVersion(v format.Version) error

func (*SerialAction) ProtoMessage 

func (*SerialAction) ProtoMessage()

func (*SerialAction) Reset 

func (m *SerialAction) Reset()

func (*SerialAction) Size 

func (m *SerialAction) Size() (n int)

func (*SerialAction) String 

func (this *SerialAction) String() string

func (*SerialAction) Unmarshal 

func (m *SerialAction) Unmarshal(data []byte) error

func (SerialAction) Validate 

func (a SerialAction) Validate() error

func (*SerialAction) Version 

func (*SerialAction) Version() format.Version

type StartActualLRPRequest 

type StartActualLRPRequest struct {
	ActualLrpKey         *ActualLRPKey         `protobuf:"bytes,1,opt,name=actual_lrp_key" json:"actual_lrp_key,omitempty"`
	ActualLrpInstanceKey *ActualLRPInstanceKey `protobuf:"bytes,2,opt,name=actual_lrp_instance_key" json:"actual_lrp_instance_key,omitempty"`
	ActualLrpNetInfo     *ActualLRPNetInfo     `protobuf:"bytes,3,opt,name=actual_lrp_net_info" json:"actual_lrp_net_info,omitempty"`
}

func (*StartActualLRPRequest) Equal 

func (this *StartActualLRPRequest) Equal(that interface{}) bool

func (*StartActualLRPRequest) GetActualLrpInstanceKey 

func (m *StartActualLRPRequest) GetActualLrpInstanceKey() *ActualLRPInstanceKey

func (*StartActualLRPRequest) GetActualLrpKey 

func (m *StartActualLRPRequest) GetActualLrpKey() *ActualLRPKey

func (*StartActualLRPRequest) GetActualLrpNetInfo 

func (m *StartActualLRPRequest) GetActualLrpNetInfo() *ActualLRPNetInfo

func (*StartActualLRPRequest) GoString 

func (this *StartActualLRPRequest) GoString() string

func (*StartActualLRPRequest) Marshal 

func (m *StartActualLRPRequest) Marshal() (data []byte, err error)

func (*StartActualLRPRequest) MarshalTo 

func (m *StartActualLRPRequest) MarshalTo(data []byte) (int, error)

func (*StartActualLRPRequest) ProtoMessage 

func (*StartActualLRPRequest) ProtoMessage()

func (*StartActualLRPRequest) Reset 

func (m *StartActualLRPRequest) Reset()

func (*StartActualLRPRequest) Size 

func (m *StartActualLRPRequest) Size() (n int)

func (*StartActualLRPRequest) String 

func (this *StartActualLRPRequest) String() string

func (*StartActualLRPRequest) Unmarshal 

func (m *StartActualLRPRequest) Unmarshal(data []byte) error

func (*StartActualLRPRequest) Validate 

func (request *StartActualLRPRequest) Validate() error

type StartTaskRequest 

type StartTaskRequest struct {
	TaskGuid string `protobuf:"bytes,1,opt,name=task_guid" json:"task_guid"`
	CellId   string `protobuf:"bytes,2,opt,name=cell_id" json:"cell_id"`
}

func (*StartTaskRequest) Equal 

func (this *StartTaskRequest) Equal(that interface{}) bool

func (*StartTaskRequest) GetCellId 

func (m *StartTaskRequest) GetCellId() string

func (*StartTaskRequest) GetTaskGuid 

func (m *StartTaskRequest) GetTaskGuid() string

func (*StartTaskRequest) GoString 

func (this *StartTaskRequest) GoString() string

func (*StartTaskRequest) Marshal 

func (m *StartTaskRequest) Marshal() (data []byte, err error)

func (*StartTaskRequest) MarshalTo 

func (m *StartTaskRequest) MarshalTo(data []byte) (int, error)

func (*StartTaskRequest) ProtoMessage 

func (*StartTaskRequest) ProtoMessage()

func (*StartTaskRequest) Reset 

func (m *StartTaskRequest) Reset()

func (*StartTaskRequest) Size 

func (m *StartTaskRequest) Size() (n int)

func (*StartTaskRequest) String 

func (this *StartTaskRequest) String() string

func (*StartTaskRequest) Unmarshal 

func (m *StartTaskRequest) Unmarshal(data []byte) error

func (*StartTaskRequest) Validate 

func (req *StartTaskRequest) Validate() error

type StartTaskResponse 

type StartTaskResponse struct {
	Error       *Error `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	ShouldStart bool   `protobuf:"varint,2,opt,name=should_start" json:"should_start"`
}

func (*StartTaskResponse) Equal 

func (this *StartTaskResponse) Equal(that interface{}) bool

func (*StartTaskResponse) GetError 

func (m *StartTaskResponse) GetError() *Error

func (*StartTaskResponse) GetShouldStart 

func (m *StartTaskResponse) GetShouldStart() bool

func (*StartTaskResponse) GoString 

func (this *StartTaskResponse) GoString() string

func (*StartTaskResponse) Marshal 

func (m *StartTaskResponse) Marshal() (data []byte, err error)

func (*StartTaskResponse) MarshalTo 

func (m *StartTaskResponse) MarshalTo(data []byte) (int, error)

func (*StartTaskResponse) ProtoMessage 

func (*StartTaskResponse) ProtoMessage()

func (*StartTaskResponse) Reset 

func (m *StartTaskResponse) Reset()

func (*StartTaskResponse) Size 

func (m *StartTaskResponse) Size() (n int)

func (*StartTaskResponse) String 

func (this *StartTaskResponse) String() string

func (*StartTaskResponse) Unmarshal 

func (m *StartTaskResponse) Unmarshal(data []byte) error

type Task 

type Task struct {
	*TaskDefinition  `protobuf:"bytes,1,opt,name=task_definition,embedded=task_definition" json:""`
	TaskGuid         string     `protobuf:"bytes,2,opt,name=task_guid" json:"task_guid"`
	Domain           string     `protobuf:"bytes,3,opt,name=domain" json:"domain"`
	CreatedAt        int64      `protobuf:"varint,4,opt,name=created_at" json:"created_at"`
	UpdatedAt        int64      `protobuf:"varint,5,opt,name=updated_at" json:"updated_at"`
	FirstCompletedAt int64      `protobuf:"varint,6,opt,name=first_completed_at" json:"first_completed_at"`
	State            Task_State `protobuf:"varint,7,opt,name=state,enum=models.Task_State" json:"state"`
	CellId           string     `protobuf:"bytes,8,opt,name=cell_id" json:"cell_id"`
	Result           string     `protobuf:"bytes,9,opt,name=result" json:"result"`
	Failed           bool       `protobuf:"varint,10,opt,name=failed" json:"failed"`
	FailureReason    string     `protobuf:"bytes,11,opt,name=failure_reason" json:"failure_reason"`
}

func (*Task) Copy 

func (t *Task) Copy() *Task

func (*Task) Equal 

func (this *Task) Equal(that interface{}) bool

func (*Task) GetCellId 

func (m *Task) GetCellId() string

func (*Task) GetCreatedAt 

func (m *Task) GetCreatedAt() int64

func (*Task) GetDomain 

func (m *Task) GetDomain() string

func (*Task) GetFailed 

func (m *Task) GetFailed() bool

func (*Task) GetFailureReason 

func (m *Task) GetFailureReason() string

func (*Task) GetFirstCompletedAt 

func (m *Task) GetFirstCompletedAt() int64

func (*Task) GetResult 

func (m *Task) GetResult() string

func (*Task) GetState 

func (m *Task) GetState() Task_State

func (*Task) GetTaskGuid 

func (m *Task) GetTaskGuid() string

func (*Task) GetUpdatedAt 

func (m *Task) GetUpdatedAt() int64

func (*Task) GoString 

func (this *Task) GoString() string

func (*Task) LagerData 

func (t *Task) LagerData() lager.Data

func (*Task) Marshal 

func (m *Task) Marshal() (data []byte, err error)

func (*Task) MarshalTo 

func (m *Task) MarshalTo(data []byte) (int, error)

func (*Task) MigrateFromVersion 

func (t *Task) MigrateFromVersion(v format.Version) error

func (*Task) ProtoMessage 

func (*Task) ProtoMessage()

func (*Task) Reset 

func (m *Task) Reset()

func (*Task) Size 

func (m *Task) Size() (n int)

func (*Task) String 

func (this *Task) String() string

func (*Task) Unmarshal 

func (m *Task) Unmarshal(data []byte) error

func (*Task) Validate 

func (task *Task) Validate() error

func (*Task) Version 

func (t *Task) Version() format.Version

func (*Task) VersionDownTo 

func (t *Task) VersionDownTo(v format.Version) *Task

type TaskByGuidRequest 

type TaskByGuidRequest struct {
	TaskGuid string `protobuf:"bytes,1,opt,name=task_guid" json:"task_guid"`
}

func (*TaskByGuidRequest) Equal 

func (this *TaskByGuidRequest) Equal(that interface{}) bool

func (*TaskByGuidRequest) GetTaskGuid 

func (m *TaskByGuidRequest) GetTaskGuid() string

func (*TaskByGuidRequest) GoString 

func (this *TaskByGuidRequest) GoString() string

func (*TaskByGuidRequest) Marshal 

func (m *TaskByGuidRequest) Marshal() (data []byte, err error)

func (*TaskByGuidRequest) MarshalTo 

func (m *TaskByGuidRequest) MarshalTo(data []byte) (int, error)

func (*TaskByGuidRequest) ProtoMessage 

func (*TaskByGuidRequest) ProtoMessage()

func (*TaskByGuidRequest) Reset 

func (m *TaskByGuidRequest) Reset()

func (*TaskByGuidRequest) Size 

func (m *TaskByGuidRequest) Size() (n int)

func (*TaskByGuidRequest) String 

func (this *TaskByGuidRequest) String() string

func (*TaskByGuidRequest) Unmarshal 

func (m *TaskByGuidRequest) Unmarshal(data []byte) error

func (*TaskByGuidRequest) Validate 

func (request *TaskByGuidRequest) Validate() error

type TaskCallbackResponse 

type TaskCallbackResponse struct {
	TaskGuid      string `protobuf:"bytes,1,opt,name=task_guid" json:"task_guid"`
	Failed        bool   `protobuf:"varint,2,opt,name=failed" json:"failed"`
	FailureReason string `protobuf:"bytes,3,opt,name=failure_reason" json:"failure_reason"`
	Result        string `protobuf:"bytes,4,opt,name=result" json:"result"`
	Annotation    string `protobuf:"bytes,5,opt,name=annotation" json:"annotation,omitempty"`
	CreatedAt     int64  `protobuf:"varint,6,opt,name=created_at" json:"created_at"`
}

func (*TaskCallbackResponse) Equal 

func (this *TaskCallbackResponse) Equal(that interface{}) bool

func (*TaskCallbackResponse) GetAnnotation 

func (m *TaskCallbackResponse) GetAnnotation() string

func (*TaskCallbackResponse) GetCreatedAt 

func (m *TaskCallbackResponse) GetCreatedAt() int64

func (*TaskCallbackResponse) GetFailed 

func (m *TaskCallbackResponse) GetFailed() bool

func (*TaskCallbackResponse) GetFailureReason 

func (m *TaskCallbackResponse) GetFailureReason() string

func (*TaskCallbackResponse) GetResult 

func (m *TaskCallbackResponse) GetResult() string

func (*TaskCallbackResponse) GetTaskGuid 

func (m *TaskCallbackResponse) GetTaskGuid() string

func (*TaskCallbackResponse) GoString 

func (this *TaskCallbackResponse) GoString() string

func (*TaskCallbackResponse) Marshal 

func (m *TaskCallbackResponse) Marshal() (data []byte, err error)

func (*TaskCallbackResponse) MarshalTo 

func (m *TaskCallbackResponse) MarshalTo(data []byte) (int, error)

func (*TaskCallbackResponse) ProtoMessage 

func (*TaskCallbackResponse) ProtoMessage()

func (*TaskCallbackResponse) Reset 

func (m *TaskCallbackResponse) Reset()

func (*TaskCallbackResponse) Size 

func (m *TaskCallbackResponse) Size() (n int)

func (*TaskCallbackResponse) String 

func (this *TaskCallbackResponse) String() string

func (*TaskCallbackResponse) Unmarshal 

func (m *TaskCallbackResponse) Unmarshal(data []byte) error

type TaskChange 

type TaskChange struct {
	Before *Task
	After  *Task
}

type TaskChangedEvent 

type TaskChangedEvent struct {
	Before *Task `protobuf:"bytes,1,opt,name=before" json:"before,omitempty"`
	After  *Task `protobuf:"bytes,2,opt,name=after" json:"after,omitempty"`
}

func NewTaskChangedEvent 

func NewTaskChangedEvent(before, after *Task) *TaskChangedEvent

func (*TaskChangedEvent) Equal 

func (this *TaskChangedEvent) Equal(that interface{}) bool

func (*TaskChangedEvent) EventType 

func (event *TaskChangedEvent) EventType() string

func (*TaskChangedEvent) GetAfter 

func (m *TaskChangedEvent) GetAfter() *Task

func (*TaskChangedEvent) GetBefore 

func (m *TaskChangedEvent) GetBefore() *Task

func (*TaskChangedEvent) GoString 

func (this *TaskChangedEvent) GoString() string

func (*TaskChangedEvent) Key 

func (event *TaskChangedEvent) Key() string

func (*TaskChangedEvent) Marshal 

func (m *TaskChangedEvent) Marshal() (data []byte, err error)

func (*TaskChangedEvent) MarshalTo 

func (m *TaskChangedEvent) MarshalTo(data []byte) (int, error)

func (*TaskChangedEvent) ProtoMessage 

func (*TaskChangedEvent) ProtoMessage()

func (*TaskChangedEvent) Reset 

func (m *TaskChangedEvent) Reset()

func (*TaskChangedEvent) Size 

func (m *TaskChangedEvent) Size() (n int)

func (*TaskChangedEvent) String 

func (this *TaskChangedEvent) String() string

func (*TaskChangedEvent) Unmarshal 

func (m *TaskChangedEvent) Unmarshal(data []byte) error

type TaskCreatedEvent 

type TaskCreatedEvent struct {
	Task *Task `protobuf:"bytes,1,opt,name=task" json:"task,omitempty"`
}

func NewTaskCreatedEvent 

func NewTaskCreatedEvent(task *Task) *TaskCreatedEvent

func (*TaskCreatedEvent) Equal 

func (this *TaskCreatedEvent) Equal(that interface{}) bool

func (*TaskCreatedEvent) EventType 

func (event *TaskCreatedEvent) EventType() string

func (*TaskCreatedEvent) GetTask 

func (m *TaskCreatedEvent) GetTask() *Task

func (*TaskCreatedEvent) GoString 

func (this *TaskCreatedEvent) GoString() string

func (*TaskCreatedEvent) Key 

func (event *TaskCreatedEvent) Key() string

func (*TaskCreatedEvent) Marshal 

func (m *TaskCreatedEvent) Marshal() (data []byte, err error)

func (*TaskCreatedEvent) MarshalTo 

func (m *TaskCreatedEvent) MarshalTo(data []byte) (int, error)

func (*TaskCreatedEvent) ProtoMessage 

func (*TaskCreatedEvent) ProtoMessage()

func (*TaskCreatedEvent) Reset 

func (m *TaskCreatedEvent) Reset()

func (*TaskCreatedEvent) Size 

func (m *TaskCreatedEvent) Size() (n int)

func (*TaskCreatedEvent) String 

func (this *TaskCreatedEvent) String() string

func (*TaskCreatedEvent) Unmarshal 

func (m *TaskCreatedEvent) Unmarshal(data []byte) error

type TaskDefinition 

type TaskDefinition struct {
	RootFs                        string                 `protobuf:"bytes,1,opt,name=root_fs" json:"rootfs"`
	EnvironmentVariables          []*EnvironmentVariable `protobuf:"bytes,2,rep,name=environment_variables" json:"env,omitempty"`
	Action                        *Action                `protobuf:"bytes,3,opt,name=action" json:"action,omitempty"`
	DiskMb                        int32                  `protobuf:"varint,4,opt,name=disk_mb" json:"disk_mb"`
	MemoryMb                      int32                  `protobuf:"varint,5,opt,name=memory_mb" json:"memory_mb"`
	CpuWeight                     uint32                 `protobuf:"varint,6,opt,name=cpu_weight" json:"cpu_weight"`
	Privileged                    bool                   `protobuf:"varint,7,opt,name=privileged" json:"privileged"`
	LogSource                     string                 `protobuf:"bytes,8,opt,name=log_source" json:"log_source"`
	LogGuid                       string                 `protobuf:"bytes,9,opt,name=log_guid" json:"log_guid"`
	MetricsGuid                   string                 `protobuf:"bytes,10,opt,name=metrics_guid" json:"metrics_guid"`
	ResultFile                    string                 `protobuf:"bytes,11,opt,name=result_file" json:"result_file"`
	CompletionCallbackUrl         string                 `protobuf:"bytes,12,opt,name=completion_callback_url" json:"completion_callback_url,omitempty"`
	Annotation                    string                 `protobuf:"bytes,13,opt,name=annotation" json:"annotation,omitempty"`
	EgressRules                   []*SecurityGroupRule   `protobuf:"bytes,14,rep,name=egress_rules" json:"egress_rules,omitempty"`
	CachedDependencies            []*CachedDependency    `protobuf:"bytes,15,rep,name=cached_dependencies" json:"cached_dependencies,omitempty"`
	LegacyDownloadUser            string                 `protobuf:"bytes,16,opt,name=legacy_download_user" json:"legacy_download_user,omitempty"`
	TrustedSystemCertificatesPath string                 `protobuf:"bytes,17,opt,name=trusted_system_certificates_path" json:"trusted_system_certificates_path,omitempty"`
}

func (*TaskDefinition) Copy 

func (t *TaskDefinition) Copy() *TaskDefinition

func (*TaskDefinition) Equal 

func (this *TaskDefinition) Equal(that interface{}) bool

func (*TaskDefinition) GetAction 

func (m *TaskDefinition) GetAction() *Action

func (*TaskDefinition) GetAnnotation 

func (m *TaskDefinition) GetAnnotation() string

func (*TaskDefinition) GetCachedDependencies 

func (m *TaskDefinition) GetCachedDependencies() []*CachedDependency

func (*TaskDefinition) GetCompletionCallbackUrl 

func (m *TaskDefinition) GetCompletionCallbackUrl() string

func (*TaskDefinition) GetCpuWeight 

func (m *TaskDefinition) GetCpuWeight() uint32

func (*TaskDefinition) GetDiskMb 

func (m *TaskDefinition) GetDiskMb() int32

func (*TaskDefinition) GetEgressRules 

func (m *TaskDefinition) GetEgressRules() []*SecurityGroupRule

func (*TaskDefinition) GetEnvironmentVariables 

func (m *TaskDefinition) GetEnvironmentVariables() []*EnvironmentVariable

func (*TaskDefinition) GetLegacyDownloadUser 

func (m *TaskDefinition) GetLegacyDownloadUser() string

func (*TaskDefinition) GetLogGuid 

func (m *TaskDefinition) GetLogGuid() string

func (*TaskDefinition) GetLogSource 

func (m *TaskDefinition) GetLogSource() string

func (*TaskDefinition) GetMemoryMb 

func (m *TaskDefinition) GetMemoryMb() int32

func (*TaskDefinition) GetMetricsGuid 

func (m *TaskDefinition) GetMetricsGuid() string

func (*TaskDefinition) GetPrivileged 

func (m *TaskDefinition) GetPrivileged() bool

func (*TaskDefinition) GetResultFile 

func (m *TaskDefinition) GetResultFile() string

func (*TaskDefinition) GetRootFs 

func (m *TaskDefinition) GetRootFs() string

func (*TaskDefinition) GetTrustedSystemCertificatesPath 

func (m *TaskDefinition) GetTrustedSystemCertificatesPath() string

func (*TaskDefinition) GoString 

func (this *TaskDefinition) GoString() string

func (*TaskDefinition) Marshal 

func (m *TaskDefinition) Marshal() (data []byte, err error)

func (*TaskDefinition) MarshalTo 

func (m *TaskDefinition) MarshalTo(data []byte) (int, error)

func (*TaskDefinition) ProtoMessage 

func (*TaskDefinition) ProtoMessage()

func (*TaskDefinition) Reset 

func (m *TaskDefinition) Reset()

func (*TaskDefinition) Size 

func (m *TaskDefinition) Size() (n int)

func (*TaskDefinition) String 

func (this *TaskDefinition) String() string

func (*TaskDefinition) Unmarshal 

func (m *TaskDefinition) Unmarshal(data []byte) error

func (*TaskDefinition) Validate 

func (def *TaskDefinition) Validate() error

type TaskFilter 

type TaskFilter struct {
	Domain string
	CellID string
}

type TaskGuidRequest 

type TaskGuidRequest struct {
	TaskGuid string `protobuf:"bytes,1,opt,name=task_guid" json:"task_guid"`
}

func (*TaskGuidRequest) Equal 

func (this *TaskGuidRequest) Equal(that interface{}) bool

func (*TaskGuidRequest) GetTaskGuid 

func (m *TaskGuidRequest) GetTaskGuid() string

func (*TaskGuidRequest) GoString 

func (this *TaskGuidRequest) GoString() string

func (*TaskGuidRequest) Marshal 

func (m *TaskGuidRequest) Marshal() (data []byte, err error)

func (*TaskGuidRequest) MarshalTo 

func (m *TaskGuidRequest) MarshalTo(data []byte) (int, error)

func (*TaskGuidRequest) ProtoMessage 

func (*TaskGuidRequest) ProtoMessage()

func (*TaskGuidRequest) Reset 

func (m *TaskGuidRequest) Reset()

func (*TaskGuidRequest) Size 

func (m *TaskGuidRequest) Size() (n int)

func (*TaskGuidRequest) String 

func (this *TaskGuidRequest) String() string

func (*TaskGuidRequest) Unmarshal 

func (m *TaskGuidRequest) Unmarshal(data []byte) error

func (*TaskGuidRequest) Validate 

func (request *TaskGuidRequest) Validate() error

type TaskLifecycleResponse 

type TaskLifecycleResponse struct {
	Error *Error `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
}

func (*TaskLifecycleResponse) Equal 

func (this *TaskLifecycleResponse) Equal(that interface{}) bool

func (*TaskLifecycleResponse) GetError 

func (m *TaskLifecycleResponse) GetError() *Error

func (*TaskLifecycleResponse) GoString 

func (this *TaskLifecycleResponse) GoString() string

func (*TaskLifecycleResponse) Marshal 

func (m *TaskLifecycleResponse) Marshal() (data []byte, err error)

func (*TaskLifecycleResponse) MarshalTo 

func (m *TaskLifecycleResponse) MarshalTo(data []byte) (int, error)

func (*TaskLifecycleResponse) ProtoMessage 

func (*TaskLifecycleResponse) ProtoMessage()

func (*TaskLifecycleResponse) Reset 

func (m *TaskLifecycleResponse) Reset()

func (*TaskLifecycleResponse) Size 

func (m *TaskLifecycleResponse) Size() (n int)

func (*TaskLifecycleResponse) String 

func (this *TaskLifecycleResponse) String() string

func (*TaskLifecycleResponse) Unmarshal 

func (m *TaskLifecycleResponse) Unmarshal(data []byte) error

type TaskRemovedEvent 

type TaskRemovedEvent struct {
	Task *Task `protobuf:"bytes,1,opt,name=task" json:"task,omitempty"`
}

func NewTaskRemovedEvent 

func NewTaskRemovedEvent(task *Task) *TaskRemovedEvent

func (*TaskRemovedEvent) Equal 

func (this *TaskRemovedEvent) Equal(that interface{}) bool

func (*TaskRemovedEvent) EventType 

func (event *TaskRemovedEvent) EventType() string

func (*TaskRemovedEvent) GetTask 

func (m *TaskRemovedEvent) GetTask() *Task

func (*TaskRemovedEvent) GoString 

func (this *TaskRemovedEvent) GoString() string

func (*TaskRemovedEvent) Key 

func (event *TaskRemovedEvent) Key() string

func (*TaskRemovedEvent) Marshal 

func (m *TaskRemovedEvent) Marshal() (data []byte, err error)

func (*TaskRemovedEvent) MarshalTo 

func (m *TaskRemovedEvent) MarshalTo(data []byte) (int, error)

func (*TaskRemovedEvent) ProtoMessage 

func (*TaskRemovedEvent) ProtoMessage()

func (*TaskRemovedEvent) Reset 

func (m *TaskRemovedEvent) Reset()

func (*TaskRemovedEvent) Size 

func (m *TaskRemovedEvent) Size() (n int)

func (*TaskRemovedEvent) String 

func (this *TaskRemovedEvent) String() string

func (*TaskRemovedEvent) Unmarshal 

func (m *TaskRemovedEvent) Unmarshal(data []byte) error

type TaskResponse 

type TaskResponse struct {
	Error *Error `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	Task  *Task  `protobuf:"bytes,2,opt,name=task" json:"task,omitempty"`
}

func (*TaskResponse) Equal 

func (this *TaskResponse) Equal(that interface{}) bool

func (*TaskResponse) GetError 

func (m *TaskResponse) GetError() *Error

func (*TaskResponse) GetTask 

func (m *TaskResponse) GetTask() *Task

func (*TaskResponse) GoString 

func (this *TaskResponse) GoString() string

func (*TaskResponse) Marshal 

func (m *TaskResponse) Marshal() (data []byte, err error)

func (*TaskResponse) MarshalTo 

func (m *TaskResponse) MarshalTo(data []byte) (int, error)

func (*TaskResponse) ProtoMessage 

func (*TaskResponse) ProtoMessage()

func (*TaskResponse) Reset 

func (m *TaskResponse) Reset()

func (*TaskResponse) Size 

func (m *TaskResponse) Size() (n int)

func (*TaskResponse) String 

func (this *TaskResponse) String() string

func (*TaskResponse) Unmarshal 

func (m *TaskResponse) Unmarshal(data []byte) error

type Task_State 

type Task_State int32
const (
	Task_Invalid   Task_State = 0
	Task_Pending   Task_State = 1
	Task_Running   Task_State = 2
	Task_Completed Task_State = 3
	Task_Resolving Task_State = 4
)

func (Task_State) Enum 

func (x Task_State) Enum() *Task_State

func (Task_State) MarshalJSON 

func (x Task_State) MarshalJSON() ([]byte, error)

func (Task_State) String 

func (x Task_State) String() string

func (*Task_State) UnmarshalJSON 

func (x *Task_State) UnmarshalJSON(data []byte) error

type TasksRequest 

type TasksRequest struct {
	Domain string `protobuf:"bytes,1,opt,name=domain" json:"domain"`
	CellId string `protobuf:"bytes,2,opt,name=cell_id" json:"cell_id"`
}

func (*TasksRequest) Equal 

func (this *TasksRequest) Equal(that interface{}) bool

func (*TasksRequest) GetCellId 

func (m *TasksRequest) GetCellId() string

func (*TasksRequest) GetDomain 

func (m *TasksRequest) GetDomain() string

func (*TasksRequest) GoString 

func (this *TasksRequest) GoString() string

func (*TasksRequest) Marshal 

func (m *TasksRequest) Marshal() (data []byte, err error)

func (*TasksRequest) MarshalTo 

func (m *TasksRequest) MarshalTo(data []byte) (int, error)

func (*TasksRequest) ProtoMessage 

func (*TasksRequest) ProtoMessage()

func (*TasksRequest) Reset 

func (m *TasksRequest) Reset()

func (*TasksRequest) Size 

func (m *TasksRequest) Size() (n int)

func (*TasksRequest) String 

func (this *TasksRequest) String() string

func (*TasksRequest) Unmarshal 

func (m *TasksRequest) Unmarshal(data []byte) error

func (*TasksRequest) Validate 

func (req *TasksRequest) Validate() error

type TasksResponse 

type TasksResponse struct {
	Error *Error  `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	Tasks []*Task `protobuf:"bytes,2,rep,name=tasks" json:"tasks,omitempty"`
}

func (*TasksResponse) Equal 

func (this *TasksResponse) Equal(that interface{}) bool

func (*TasksResponse) GetError 

func (m *TasksResponse) GetError() *Error

func (*TasksResponse) GetTasks 

func (m *TasksResponse) GetTasks() []*Task

func (*TasksResponse) GoString 

func (this *TasksResponse) GoString() string

func (*TasksResponse) Marshal 

func (m *TasksResponse) Marshal() (data []byte, err error)

func (*TasksResponse) MarshalTo 

func (m *TasksResponse) MarshalTo(data []byte) (int, error)

func (*TasksResponse) ProtoMessage 

func (*TasksResponse) ProtoMessage()

func (*TasksResponse) Reset 

func (m *TasksResponse) Reset()

func (*TasksResponse) Size 

func (m *TasksResponse) Size() (n int)

func (*TasksResponse) String 

func (this *TasksResponse) String() string

func (*TasksResponse) Unmarshal 

func (m *TasksResponse) Unmarshal(data []byte) error

type TimeoutAction 

type TimeoutAction struct {
	Action    *Action `protobuf:"bytes,1,opt,name=action" json:"action,omitempty"`
	Timeout   int64   `protobuf:"varint,2,opt,name=timeout" json:"timeout"`
	LogSource string  `protobuf:"bytes,3,opt,name=log_source" json:"log_source,omitempty"`
}

func Timeout 

func Timeout(action ActionInterface, timeout time.Duration) *TimeoutAction

func (*TimeoutAction) ActionType 

func (a *TimeoutAction) ActionType() string

func (*TimeoutAction) Equal 

func (this *TimeoutAction) Equal(that interface{}) bool

func (*TimeoutAction) GetAction 

func (m *TimeoutAction) GetAction() *Action

func (*TimeoutAction) GetLogSource 

func (m *TimeoutAction) GetLogSource() string

func (*TimeoutAction) GetTimeout 

func (m *TimeoutAction) GetTimeout() int64

func (*TimeoutAction) GoString 

func (this *TimeoutAction) GoString() string

func (*TimeoutAction) Marshal 

func (m *TimeoutAction) Marshal() (data []byte, err error)

func (*TimeoutAction) MarshalTo 

func (m *TimeoutAction) MarshalTo(data []byte) (int, error)

func (*TimeoutAction) MigrateFromVersion 

func (*TimeoutAction) MigrateFromVersion(v format.Version) error

func (*TimeoutAction) ProtoMessage 

func (*TimeoutAction) ProtoMessage()

func (*TimeoutAction) Reset 

func (m *TimeoutAction) Reset()

func (*TimeoutAction) Size 

func (m *TimeoutAction) Size() (n int)

func (*TimeoutAction) String 

func (this *TimeoutAction) String() string

func (*TimeoutAction) Unmarshal 

func (m *TimeoutAction) Unmarshal(data []byte) error

func (TimeoutAction) Validate 

func (a TimeoutAction) Validate() error

func (*TimeoutAction) Version 

func (*TimeoutAction) Version() format.Version

type TryAction 

type TryAction struct {
	Action    *Action `protobuf:"bytes,1,opt,name=action" json:"action,omitempty"`
	LogSource string  `protobuf:"bytes,2,opt,name=log_source" json:"log_source,omitempty"`
}

func Try 

func Try(action ActionInterface) *TryAction

func (*TryAction) ActionType 

func (a *TryAction) ActionType() string

func (*TryAction) Equal 

func (this *TryAction) Equal(that interface{}) bool

func (*TryAction) GetAction 

func (m *TryAction) GetAction() *Action

func (*TryAction) GetLogSource 

func (m *TryAction) GetLogSource() string

func (*TryAction) GoString 

func (this *TryAction) GoString() string

func (*TryAction) Marshal 

func (m *TryAction) Marshal() (data []byte, err error)

func (*TryAction) MarshalTo 

func (m *TryAction) MarshalTo(data []byte) (int, error)

func (*TryAction) MigrateFromVersion 

func (*TryAction) MigrateFromVersion(v format.Version) error

func (*TryAction) ProtoMessage 

func (*TryAction) ProtoMessage()

func (*TryAction) Reset 

func (m *TryAction) Reset()

func (*TryAction) Size 

func (m *TryAction) Size() (n int)

func (*TryAction) String 

func (this *TryAction) String() string

func (*TryAction) Unmarshal 

func (m *TryAction) Unmarshal(data []byte) error

func (TryAction) Validate 

func (a TryAction) Validate() error

func (*TryAction) Version 

func (*TryAction) Version() format.Version

type UpdateDesiredLRPRequest 

type UpdateDesiredLRPRequest struct {
	ProcessGuid string            `protobuf:"bytes,1,opt,name=process_guid" json:"process_guid"`
	Update      *DesiredLRPUpdate `protobuf:"bytes,2,opt,name=update" json:"update,omitempty"`
}

func (*UpdateDesiredLRPRequest) Equal 

func (this *UpdateDesiredLRPRequest) Equal(that interface{}) bool

func (*UpdateDesiredLRPRequest) GetProcessGuid 

func (m *UpdateDesiredLRPRequest) GetProcessGuid() string

func (*UpdateDesiredLRPRequest) GetUpdate 

func (m *UpdateDesiredLRPRequest) GetUpdate() *DesiredLRPUpdate

func (*UpdateDesiredLRPRequest) GoString 

func (this *UpdateDesiredLRPRequest) GoString() string

func (*UpdateDesiredLRPRequest) Marshal 

func (m *UpdateDesiredLRPRequest) Marshal() (data []byte, err error)

func (*UpdateDesiredLRPRequest) MarshalTo 

func (m *UpdateDesiredLRPRequest) MarshalTo(data []byte) (int, error)

func (*UpdateDesiredLRPRequest) ProtoMessage 

func (*UpdateDesiredLRPRequest) ProtoMessage()

func (*UpdateDesiredLRPRequest) Reset 

func (m *UpdateDesiredLRPRequest) Reset()

func (*UpdateDesiredLRPRequest) Size 

func (m *UpdateDesiredLRPRequest) Size() (n int)

func (*UpdateDesiredLRPRequest) String 

func (this *UpdateDesiredLRPRequest) String() string

func (*UpdateDesiredLRPRequest) Unmarshal 

func (m *UpdateDesiredLRPRequest) Unmarshal(data []byte) error

func (*UpdateDesiredLRPRequest) Validate 

func (request *UpdateDesiredLRPRequest) Validate() error

type UploadAction 

type UploadAction struct {
	Artifact  string `protobuf:"bytes,1,opt,name=artifact" json:"artifact,omitempty"`
	From      string `protobuf:"bytes,2,opt,name=from" json:"from"`
	To        string `protobuf:"bytes,3,opt,name=to" json:"to"`
	LogSource string `protobuf:"bytes,4,opt,name=log_source" json:"log_source,omitempty"`
	User      string `protobuf:"bytes,5,opt,name=user" json:"user"`
}

func (*UploadAction) ActionType 

func (a *UploadAction) ActionType() string

func (*UploadAction) Equal 

func (this *UploadAction) Equal(that interface{}) bool

func (*UploadAction) GetArtifact 

func (m *UploadAction) GetArtifact() string

func (*UploadAction) GetFrom 

func (m *UploadAction) GetFrom() string

func (*UploadAction) GetLogSource 

func (m *UploadAction) GetLogSource() string

func (*UploadAction) GetTo 

func (m *UploadAction) GetTo() string

func (*UploadAction) GetUser 

func (m *UploadAction) GetUser() string

func (*UploadAction) GoString 

func (this *UploadAction) GoString() string

func (*UploadAction) Marshal 

func (m *UploadAction) Marshal() (data []byte, err error)

func (*UploadAction) MarshalTo 

func (m *UploadAction) MarshalTo(data []byte) (int, error)

func (*UploadAction) MigrateFromVersion 

func (*UploadAction) MigrateFromVersion(v format.Version) error

func (*UploadAction) ProtoMessage 

func (*UploadAction) ProtoMessage()

func (*UploadAction) Reset 

func (m *UploadAction) Reset()

func (*UploadAction) Size 

func (m *UploadAction) Size() (n int)

func (*UploadAction) String 

func (this *UploadAction) String() string

func (*UploadAction) Unmarshal 

func (m *UploadAction) Unmarshal(data []byte) error

func (UploadAction) Validate 

func (a UploadAction) Validate() error

func (*UploadAction) Version 

func (*UploadAction) Version() format.Version

type UpsertDomainRequest 

type UpsertDomainRequest struct {
	Domain string `protobuf:"bytes,1,opt,name=domain" json:"domain"`
	Ttl    uint32 `protobuf:"varint,2,opt,name=ttl" json:"ttl"`
}

func (*UpsertDomainRequest) GetDomain 

func (m *UpsertDomainRequest) GetDomain() string

func (*UpsertDomainRequest) GetTtl 

func (m *UpsertDomainRequest) GetTtl() uint32

func (*UpsertDomainRequest) GoString 

func (this *UpsertDomainRequest) GoString() string

func (*UpsertDomainRequest) Marshal 

func (m *UpsertDomainRequest) Marshal() (data []byte, err error)

func (*UpsertDomainRequest) MarshalTo 

func (m *UpsertDomainRequest) MarshalTo(data []byte) (int, error)

func (*UpsertDomainRequest) ProtoMessage 

func (*UpsertDomainRequest) ProtoMessage()

func (*UpsertDomainRequest) Reset 

func (m *UpsertDomainRequest) Reset()

func (*UpsertDomainRequest) Size 

func (m *UpsertDomainRequest) Size() (n int)

func (*UpsertDomainRequest) String 

func (this *UpsertDomainRequest) String() string

func (*UpsertDomainRequest) Unmarshal 

func (m *UpsertDomainRequest) Unmarshal(data []byte) error

func (*UpsertDomainRequest) Validate 

func (request *UpsertDomainRequest) Validate() error

type UpsertDomainResponse 

type UpsertDomainResponse struct {
	Error *Error `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
}

func (*UpsertDomainResponse) GetError 

func (m *UpsertDomainResponse) GetError() *Error

func (*UpsertDomainResponse) GoString 

func (this *UpsertDomainResponse) GoString() string

func (*UpsertDomainResponse) Marshal 

func (m *UpsertDomainResponse) Marshal() (data []byte, err error)

func (*UpsertDomainResponse) MarshalTo 

func (m *UpsertDomainResponse) MarshalTo(data []byte) (int, error)

func (*UpsertDomainResponse) ProtoMessage 

func (*UpsertDomainResponse) ProtoMessage()

func (*UpsertDomainResponse) Reset 

func (m *UpsertDomainResponse) Reset()

func (*UpsertDomainResponse) Size 

func (m *UpsertDomainResponse) Size() (n int)

func (*UpsertDomainResponse) String 

func (this *UpsertDomainResponse) String() string

func (*UpsertDomainResponse) Unmarshal 

func (m *UpsertDomainResponse) Unmarshal(data []byte) error

type ValidationError 

type ValidationError []error

func (ValidationError) Append 

func (ve ValidationError) Append(err error) ValidationError

func (ValidationError) Check 

func (ve ValidationError) Check(validators ...Validator) ValidationError

func (ValidationError) Empty 

func (ve ValidationError) Empty() bool

func (ValidationError) Error 

func (ve ValidationError) Error() string

func (ValidationError) ToError 

func (ve ValidationError) ToError() error

type Validator 

type Validator interface {
	Validate() error
}

type Version 

type Version struct {
	CurrentVersion int64
	TargetVersion  int64
}

Source Files

View all Source files

Directories

Path Synopsis
This file was generated by counterfeiter This file was generated by counterfeiter
 This file was generated by counterfeiter This file was generated by counterfeiter
test
model_helpers

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.