Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
- API
  
  Reference documentation for the pkg.go.dev API
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

models

package module

Go to main page

Versions in this module

v1

v1.7.0

Jun 23, 2026

v1.6.0

Jun 22, 2026

v1.5.0

Jun 22, 2026

v1.4.0

Jun 22, 2026

v1.3.0

Jun 19, 2026

Changes in this version

+ const ActionTypeCodependent

+ const ActionTypeDownload

+ const ActionTypeEmitProgress

+ const ActionTypeParallel

+ const ActionTypeRun

+ const ActionTypeSerial

+ const ActionTypeTimeout

+ const ActionTypeTry

+ const ActionTypeUpload

+ const ActualLRPStateClaimed

+ const ActualLRPStateCrashed

+ const ActualLRPStateRunning

+ const ActualLRPStateUnclaimed

+ const AllProtocol

+ const CrashBackoffMinDuration

+ const CrashResetTimeout

+ const DefaultImmediateRestarts

+ const DefaultMaxBackoffDuration

+ const DefaultMaxRestarts

+ const EventTypeActualLRPChanged

+ const EventTypeActualLRPCrashed

+ const EventTypeActualLRPCreated

+ const EventTypeActualLRPInstanceChanged

+ const EventTypeActualLRPInstanceCreated

+ const EventTypeActualLRPInstanceRemoved

+ const EventTypeActualLRPRemoved

+ const EventTypeCellDisappeared

+ const EventTypeDesiredLRPChanged

+ const EventTypeDesiredLRPCreated

+ const EventTypeDesiredLRPRemoved

+ const EventTypeInvalid

+ const EventTypeTaskChanged

+ const EventTypeTaskCreated

+ const EventTypeTaskRemoved

+ const ExtraRootFSScheme

+ const ICMPProtocol

+ const ICMPv6Protocol

+ const InternalRouter

+ const PreloadedOCIRootFSScheme

+ const PreloadedRootFSScheme

+ const RetireActualLRPRetryAttempts

+ const StackVersionFile

+ const StaleUnclaimedActualLRPDuration

+ const TCPProtocol

+ const UDPProtocol

+ var ActualLRPNetInfo_PreferredAddress_name = map[int32]string

+ var ActualLRPNetInfo_PreferredAddress_value = map[string]int32

+ var ActualLRPStates = []string

+ var ActualLRP_Presence_name = map[int32]string

+ var ActualLRP_Presence_value = map[string]int32

+ var DesiredLRP_UpdateStrategy_name = map[int32]string

+ var DesiredLRP_UpdateStrategy_value = map[string]int32

+ var ErrActualLRPCannotBeClaimed = &Error

+ var ErrActualLRPCannotBeCrashed = &Error

+ var ErrActualLRPCannotBeFailed = &Error

+ var ErrActualLRPCannotBeRemoved = &Error

+ var ErrActualLRPCannotBeStarted = &Error

+ var ErrActualLRPCannotBeUnclaimed = &Error

+ var ErrActualLRPGroupInvalid = errors.New("ActualLRPGroup invalid")

+ var ErrBadRequest = &Error

+ var ErrDeadlock = &Error

+ var ErrDeserialize = &Error

+ var ErrFailedToOpenEnvelope = &Error

+ var ErrGUIDGeneration = &Error

+ var ErrIntOverflowActions = fmt.Errorf("proto: integer overflow")

+ var ErrIntOverflowActualLrp = fmt.Errorf("proto: integer overflow")

+ var ErrIntOverflowActualLrpRequests = fmt.Errorf("proto: integer overflow")

+ var ErrIntOverflowCachedDependency = fmt.Errorf("proto: integer overflow")

+ var ErrIntOverflowCells = fmt.Errorf("proto: integer overflow")

+ var ErrIntOverflowCertificateProperties = fmt.Errorf("proto: integer overflow")

+ var ErrIntOverflowCheckDefinition = fmt.Errorf("proto: integer overflow")

+ var ErrIntOverflowDesiredLrp = fmt.Errorf("proto: integer overflow")

+ var ErrIntOverflowDesiredLrpRequests = fmt.Errorf("proto: integer overflow")

+ var ErrIntOverflowDomain = fmt.Errorf("proto: integer overflow")

+ var ErrIntOverflowEnvironmentVariables = fmt.Errorf("proto: integer overflow")

+ var ErrIntOverflowError = fmt.Errorf("proto: integer overflow")

+ var ErrIntOverflowEvacuation = fmt.Errorf("proto: integer overflow")

+ var ErrIntOverflowEvents = fmt.Errorf("proto: integer overflow")

+ var ErrIntOverflowFile = fmt.Errorf("proto: integer overflow")

+ var ErrIntOverflowImageLayer = fmt.Errorf("proto: integer overflow")

+ var ErrIntOverflowLogRateLimit = fmt.Errorf("proto: integer overflow")

+ var ErrIntOverflowMetricTags = fmt.Errorf("proto: integer overflow")

+ var ErrIntOverflowModificationTag = fmt.Errorf("proto: integer overflow")

+ var ErrIntOverflowNetwork = fmt.Errorf("proto: integer overflow")

+ var ErrIntOverflowPing = fmt.Errorf("proto: integer overflow")

+ var ErrIntOverflowSecurityGroup = fmt.Errorf("proto: integer overflow")

+ var ErrIntOverflowSidecar = fmt.Errorf("proto: integer overflow")

+ var ErrIntOverflowTask = fmt.Errorf("proto: integer overflow")

+ var ErrIntOverflowTaskRequests = fmt.Errorf("proto: integer overflow")

+ var ErrIntOverflowVolumeMount = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidActionType = errors.New("invalid action type")

+ var ErrInvalidLengthActions = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrInvalidLengthActualLrp = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrInvalidLengthActualLrpRequests = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrInvalidLengthCachedDependency = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrInvalidLengthCells = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrInvalidLengthCertificateProperties = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrInvalidLengthCheckDefinition = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrInvalidLengthDesiredLrp = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrInvalidLengthDesiredLrpRequests = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrInvalidLengthDomain = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrInvalidLengthEnvironmentVariables = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrInvalidLengthError = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrInvalidLengthEvacuation = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrInvalidLengthEvents = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrInvalidLengthFile = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrInvalidLengthImageLayer = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrInvalidLengthLogRateLimit = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrInvalidLengthMetricTags = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrInvalidLengthModificationTag = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrInvalidLengthNetwork = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrInvalidLengthPing = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrInvalidLengthSecurityGroup = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrInvalidLengthSidecar = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrInvalidLengthTask = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrInvalidLengthTaskRequests = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrInvalidLengthVolumeMount = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrLockCollision = &Error

+ var ErrResourceConflict = &Error

+ var ErrResourceExists = &Error

+ var ErrResourceNotFound = &Error

+ var ErrUnexpectedEndOfGroupActions = fmt.Errorf("proto: unexpected end of group")

+ var ErrUnexpectedEndOfGroupActualLrp = fmt.Errorf("proto: unexpected end of group")

+ var ErrUnexpectedEndOfGroupActualLrpRequests = fmt.Errorf("proto: unexpected end of group")

+ var ErrUnexpectedEndOfGroupCachedDependency = fmt.Errorf("proto: unexpected end of group")

+ var ErrUnexpectedEndOfGroupCells = fmt.Errorf("proto: unexpected end of group")

+ var ErrUnexpectedEndOfGroupCertificateProperties = fmt.Errorf("proto: unexpected end of group")

+ var ErrUnexpectedEndOfGroupCheckDefinition = fmt.Errorf("proto: unexpected end of group")

+ var ErrUnexpectedEndOfGroupDesiredLrp = fmt.Errorf("proto: unexpected end of group")

+ var ErrUnexpectedEndOfGroupDesiredLrpRequests = fmt.Errorf("proto: unexpected end of group")

+ var ErrUnexpectedEndOfGroupDomain = fmt.Errorf("proto: unexpected end of group")

+ var ErrUnexpectedEndOfGroupEnvironmentVariables = fmt.Errorf("proto: unexpected end of group")

+ var ErrUnexpectedEndOfGroupError = fmt.Errorf("proto: unexpected end of group")

+ var ErrUnexpectedEndOfGroupEvacuation = fmt.Errorf("proto: unexpected end of group")

+ var ErrUnexpectedEndOfGroupEvents = fmt.Errorf("proto: unexpected end of group")

+ var ErrUnexpectedEndOfGroupFile = fmt.Errorf("proto: unexpected end of group")

+ var ErrUnexpectedEndOfGroupImageLayer = fmt.Errorf("proto: unexpected end of group")

+ var ErrUnexpectedEndOfGroupLogRateLimit = fmt.Errorf("proto: unexpected end of group")

+ var ErrUnexpectedEndOfGroupMetricTags = fmt.Errorf("proto: unexpected end of group")

+ var ErrUnexpectedEndOfGroupModificationTag = fmt.Errorf("proto: unexpected end of group")

+ var ErrUnexpectedEndOfGroupNetwork = fmt.Errorf("proto: unexpected end of group")

+ var ErrUnexpectedEndOfGroupPing = fmt.Errorf("proto: unexpected end of group")

+ var ErrUnexpectedEndOfGroupSecurityGroup = fmt.Errorf("proto: unexpected end of group")

+ var ErrUnexpectedEndOfGroupSidecar = fmt.Errorf("proto: unexpected end of group")

+ var ErrUnexpectedEndOfGroupTask = fmt.Errorf("proto: unexpected end of group")

+ var ErrUnexpectedEndOfGroupTaskRequests = fmt.Errorf("proto: unexpected end of group")

+ var ErrUnexpectedEndOfGroupVolumeMount = fmt.Errorf("proto: unexpected end of group")

+ var ErrUnknownError = &Error

+ var ErrorIncompatibleRootfs = errors.New("rootfs not found")

+ var Error_Type_name = map[int32]string

+ var Error_Type_value = map[string]int32

+ var ImageLayer_DigestAlgorithm_name = map[int32]string

+ var ImageLayer_DigestAlgorithm_value = map[string]int32

+ var ImageLayer_MediaType_name = map[int32]string

+ var ImageLayer_MediaType_value = map[string]int32

+ var ImageLayer_Type_name = map[int32]string

+ var ImageLayer_Type_value = map[string]int32

+ var MetricTagValue_DynamicValue_name = map[int32]string

+ var MetricTagValue_DynamicValue_value = map[string]int32

+ var Task_State_name = map[int32]string

+ var Task_State_value = map[string]int32

+ func ConvertMetricTags(metricTags map[string]*MetricTagValue, ...) (map[string]string, error)

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

+ func PreloadedRootFS(stack string) string

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

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

+ type Action struct

+ CodependentAction *CodependentAction

+ DownloadAction *DownloadAction

+ EmitProgressAction *EmitProgressAction

+ ParallelAction *ParallelAction

+ RunAction *RunAction

+ SerialAction *SerialAction

+ TimeoutAction *TimeoutAction

+ TryAction *TryAction

+ UploadAction *UploadAction

+ func WrapAction(action ActionInterface) *Action

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

+ func (*Action) Descriptor() ([]byte, []int)

+ func (*Action) ProtoMessage()

+ func (a *Action) GetValue() interface{}

+ func (a *Action) SetValue(value interface{}) bool

+ func (a *Action) Validate() error

+ func (action *Action) SetDeprecatedTimeoutNs() *Action

+ func (action *Action) SetTimeoutMsFromDeprecatedTimeoutNs()

+ func (m *Action) GetCodependentAction() *CodependentAction

+ func (m *Action) GetDownloadAction() *DownloadAction

+ func (m *Action) GetEmitProgressAction() *EmitProgressAction

+ func (m *Action) GetParallelAction() *ParallelAction

+ func (m *Action) GetRunAction() *RunAction

+ func (m *Action) GetSerialAction() *SerialAction

+ func (m *Action) GetTimeoutAction() *TimeoutAction

+ func (m *Action) GetTryAction() *TryAction

+ func (m *Action) GetUploadAction() *UploadAction

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

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

+ func (m *Action) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Action) Reset()

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

+ func (m *Action) Unmarshal(dAtA []byte) error

+ func (m *Action) XXX_DiscardUnknown()

+ func (m *Action) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Action) XXX_Merge(src proto.Message)

+ func (m *Action) XXX_Size() int

+ func (m *Action) XXX_Unmarshal(b []byte) error

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

+ func (this *Action) GoString() string

+ func (this *Action) String() string

+ type ActionInterface interface

+ ActionType func() string

+ Validate func() error

+ func UnwrapAction(action *Action) ActionInterface

+ type ActualLRP struct

+ ActualLrpInternalRoutes []*ActualLRPInternalRoute

+ AvailabilityZone string

+ CrashCount int32

+ CrashReason string

+ MetricTags map[string]string

+ ModificationTag ModificationTag

+ OptionalRoutable isActualLRP_OptionalRoutable

+ PlacementError string

+ Presence ActualLRP_Presence

+ Since int64

+ State string

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

+ func NewRunningActualLRP(lrpKey ActualLRPKey, instanceKey ActualLRPInstanceKey, ...) *ActualLRP

+ func NewUnclaimedActualLRP(lrpKey ActualLRPKey, since int64) *ActualLRP

+ func (*ActualLRP) Descriptor() ([]byte, []int)

+ func (*ActualLRP) ProtoMessage()

+ func (*ActualLRP) Version() format.Version

+ func (*ActualLRP) XXX_OneofWrappers() []interface{}

+ func (a *ActualLRP) Copy() *ActualLRP

+ func (actual *ActualLRP) RoutableExists() bool

+ func (actual *ActualLRP) SetRoutable(routable bool)

+ func (actual *ActualLRP) ToActualLRPGroup() *ActualLRPGroup

+ func (actual *ActualLRP) ToActualLRPInfo() *ActualLRPInfo

+ func (actual ActualLRP) CellIsMissing(cellSet CellSet) bool

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

+ func (actual ActualLRP) ShouldRestartImmediately(calc RestartCalculator) bool

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

+ func (actual ActualLRP) Validate() error

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

+ func (m *ActualLRP) GetActualLrpInternalRoutes() []*ActualLRPInternalRoute

+ func (m *ActualLRP) GetAvailabilityZone() string

+ func (m *ActualLRP) GetCrashCount() int32

+ func (m *ActualLRP) GetCrashReason() string

+ func (m *ActualLRP) GetMetricTags() map[string]string

+ func (m *ActualLRP) GetModificationTag() ModificationTag

+ func (m *ActualLRP) GetOptionalRoutable() isActualLRP_OptionalRoutable

+ func (m *ActualLRP) GetPlacementError() string

+ func (m *ActualLRP) GetPresence() ActualLRP_Presence

+ func (m *ActualLRP) GetRoutable() bool

+ func (m *ActualLRP) GetSince() int64

+ func (m *ActualLRP) GetState() string

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

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

+ func (m *ActualLRP) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ActualLRP) Reset()

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

+ func (m *ActualLRP) Unmarshal(dAtA []byte) error

+ func (m *ActualLRP) XXX_DiscardUnknown()

+ func (m *ActualLRP) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ActualLRP) XXX_Merge(src proto.Message)

+ func (m *ActualLRP) XXX_Size() int

+ func (m *ActualLRP) XXX_Unmarshal(b []byte) error

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

+ func (this *ActualLRP) GoString() string

+ func (this *ActualLRP) String() string

+ type ActualLRPChange struct

+ After *ActualLRPGroup

+ Before *ActualLRPGroup

+ type ActualLRPChangedEvent struct

+ After *ActualLRPGroup

+ Before *ActualLRPGroup

+ func NewActualLRPChangedEvent(before, after *ActualLRPGroup) *ActualLRPChangedEvent

+ func (*ActualLRPChangedEvent) Descriptor() ([]byte, []int)

+ func (*ActualLRPChangedEvent) ProtoMessage()

+ func (event *ActualLRPChangedEvent) EventType() string

+ func (event *ActualLRPChangedEvent) Key() string

+ func (m *ActualLRPChangedEvent) GetAfter() *ActualLRPGroup

+ func (m *ActualLRPChangedEvent) GetBefore() *ActualLRPGroup

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

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

+ func (m *ActualLRPChangedEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ActualLRPChangedEvent) Reset()

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

+ func (m *ActualLRPChangedEvent) Unmarshal(dAtA []byte) error

+ func (m *ActualLRPChangedEvent) XXX_DiscardUnknown()

+ func (m *ActualLRPChangedEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ActualLRPChangedEvent) XXX_Merge(src proto.Message)

+ func (m *ActualLRPChangedEvent) XXX_Size() int

+ func (m *ActualLRPChangedEvent) XXX_Unmarshal(b []byte) error

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

+ func (this *ActualLRPChangedEvent) GoString() string

+ func (this *ActualLRPChangedEvent) String() string

+ type ActualLRPCrashedEvent struct

+ CrashCount int32

+ CrashReason string

+ Since int64

+ func NewActualLRPCrashedEvent(before, after *ActualLRP) *ActualLRPCrashedEvent

+ func (*ActualLRPCrashedEvent) Descriptor() ([]byte, []int)

+ func (*ActualLRPCrashedEvent) ProtoMessage()

+ func (event *ActualLRPCrashedEvent) EventType() string

+ func (event *ActualLRPCrashedEvent) Key() string

+ func (m *ActualLRPCrashedEvent) GetCrashCount() int32

+ func (m *ActualLRPCrashedEvent) GetCrashReason() string

+ func (m *ActualLRPCrashedEvent) GetSince() int64

+ func (m *ActualLRPCrashedEvent) Marshal() (dAtA []byte, err error)

+ func (m *ActualLRPCrashedEvent) MarshalTo(dAtA []byte) (int, error)

+ func (m *ActualLRPCrashedEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ActualLRPCrashedEvent) Reset()

+ func (m *ActualLRPCrashedEvent) Size() (n int)

+ func (m *ActualLRPCrashedEvent) Unmarshal(dAtA []byte) error

+ func (m *ActualLRPCrashedEvent) XXX_DiscardUnknown()

+ func (m *ActualLRPCrashedEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ActualLRPCrashedEvent) XXX_Merge(src proto.Message)

+ func (m *ActualLRPCrashedEvent) XXX_Size() int

+ func (m *ActualLRPCrashedEvent) XXX_Unmarshal(b []byte) error

+ func (this *ActualLRPCrashedEvent) Equal(that interface{}) bool

+ func (this *ActualLRPCrashedEvent) GoString() string

+ func (this *ActualLRPCrashedEvent) String() string

+ type ActualLRPCreatedEvent struct

+ ActualLrpGroup *ActualLRPGroup

+ func NewActualLRPCreatedEvent(actualLRPGroup *ActualLRPGroup) *ActualLRPCreatedEvent

+ func (*ActualLRPCreatedEvent) Descriptor() ([]byte, []int)

+ func (*ActualLRPCreatedEvent) ProtoMessage()

+ func (event *ActualLRPCreatedEvent) EventType() string

+ func (event *ActualLRPCreatedEvent) Key() string

+ func (m *ActualLRPCreatedEvent) GetActualLrpGroup() *ActualLRPGroup

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

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

+ func (m *ActualLRPCreatedEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ActualLRPCreatedEvent) Reset()

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

+ func (m *ActualLRPCreatedEvent) Unmarshal(dAtA []byte) error

+ func (m *ActualLRPCreatedEvent) XXX_DiscardUnknown()

+ func (m *ActualLRPCreatedEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ActualLRPCreatedEvent) XXX_Merge(src proto.Message)

+ func (m *ActualLRPCreatedEvent) XXX_Size() int

+ func (m *ActualLRPCreatedEvent) XXX_Unmarshal(b []byte) error

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

+ func (this *ActualLRPCreatedEvent) GoString() string

+ func (this *ActualLRPCreatedEvent) String() string

+ type ActualLRPFilter struct

+ CellID string

+ Domain string

+ Index *int32

+ ProcessGuid string

+ type ActualLRPGroup struct

+ Evacuating *ActualLRP

+ Instance *ActualLRP

+ func NewEvacuatingActualLRPGroup(actualLRP *ActualLRP) *ActualLRPGroup

+ func NewRunningActualLRPGroup(actualLRP *ActualLRP) *ActualLRPGroup

+ func ResolveActualLRPGroup(lrps []*ActualLRP) *ActualLRPGroup

+ func ResolveActualLRPGroups(lrps []*ActualLRP) []*ActualLRPGroup

+ func (*ActualLRPGroup) Descriptor() ([]byte, []int)

+ func (*ActualLRPGroup) ProtoMessage()

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

+ func (m *ActualLRPGroup) GetEvacuating() *ActualLRP

+ func (m *ActualLRPGroup) GetInstance() *ActualLRP

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

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

+ func (m *ActualLRPGroup) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ActualLRPGroup) Reset()

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

+ func (m *ActualLRPGroup) Unmarshal(dAtA []byte) error

+ func (m *ActualLRPGroup) XXX_DiscardUnknown()

+ func (m *ActualLRPGroup) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ActualLRPGroup) XXX_Merge(src proto.Message)

+ func (m *ActualLRPGroup) XXX_Size() int

+ func (m *ActualLRPGroup) XXX_Unmarshal(b []byte) error

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

+ func (this *ActualLRPGroup) GoString() string

+ func (this *ActualLRPGroup) String() string

+ type ActualLRPGroupByProcessGuidAndIndexRequest struct

+ Index int32

+ ProcessGuid string

+ func (*ActualLRPGroupByProcessGuidAndIndexRequest) Descriptor() ([]byte, []int)

+ func (*ActualLRPGroupByProcessGuidAndIndexRequest) ProtoMessage()

+ func (m *ActualLRPGroupByProcessGuidAndIndexRequest) GetIndex() int32

+ func (m *ActualLRPGroupByProcessGuidAndIndexRequest) GetProcessGuid() string

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

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

+ func (m *ActualLRPGroupByProcessGuidAndIndexRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ActualLRPGroupByProcessGuidAndIndexRequest) Reset()

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

+ func (m *ActualLRPGroupByProcessGuidAndIndexRequest) Unmarshal(dAtA []byte) error

+ func (m *ActualLRPGroupByProcessGuidAndIndexRequest) XXX_DiscardUnknown()

+ func (m *ActualLRPGroupByProcessGuidAndIndexRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ActualLRPGroupByProcessGuidAndIndexRequest) XXX_Merge(src proto.Message)

+ func (m *ActualLRPGroupByProcessGuidAndIndexRequest) XXX_Size() int

+ func (m *ActualLRPGroupByProcessGuidAndIndexRequest) XXX_Unmarshal(b []byte) error

+ func (request *ActualLRPGroupByProcessGuidAndIndexRequest) Validate() error

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

+ func (this *ActualLRPGroupByProcessGuidAndIndexRequest) GoString() string

+ func (this *ActualLRPGroupByProcessGuidAndIndexRequest) String() string

+ type ActualLRPGroupResponse struct

+ ActualLrpGroup *ActualLRPGroup

+ Error *Error

+ func (*ActualLRPGroupResponse) Descriptor() ([]byte, []int)

+ func (*ActualLRPGroupResponse) ProtoMessage()

+ func (m *ActualLRPGroupResponse) GetActualLrpGroup() *ActualLRPGroup

+ func (m *ActualLRPGroupResponse) GetError() *Error

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

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

+ func (m *ActualLRPGroupResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ActualLRPGroupResponse) Reset()

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

+ func (m *ActualLRPGroupResponse) Unmarshal(dAtA []byte) error

+ func (m *ActualLRPGroupResponse) XXX_DiscardUnknown()

+ func (m *ActualLRPGroupResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ActualLRPGroupResponse) XXX_Merge(src proto.Message)

+ func (m *ActualLRPGroupResponse) XXX_Size() int

+ func (m *ActualLRPGroupResponse) XXX_Unmarshal(b []byte) error

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

+ func (this *ActualLRPGroupResponse) GoString() string

+ func (this *ActualLRPGroupResponse) String() string

+ type ActualLRPGroupsByProcessGuidRequest struct

+ ProcessGuid string

+ func (*ActualLRPGroupsByProcessGuidRequest) Descriptor() ([]byte, []int)

+ func (*ActualLRPGroupsByProcessGuidRequest) ProtoMessage()

+ func (m *ActualLRPGroupsByProcessGuidRequest) GetProcessGuid() string

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

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

+ func (m *ActualLRPGroupsByProcessGuidRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ActualLRPGroupsByProcessGuidRequest) Reset()

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

+ func (m *ActualLRPGroupsByProcessGuidRequest) Unmarshal(dAtA []byte) error

+ func (m *ActualLRPGroupsByProcessGuidRequest) XXX_DiscardUnknown()

+ func (m *ActualLRPGroupsByProcessGuidRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ActualLRPGroupsByProcessGuidRequest) XXX_Merge(src proto.Message)

+ func (m *ActualLRPGroupsByProcessGuidRequest) XXX_Size() int

+ func (m *ActualLRPGroupsByProcessGuidRequest) XXX_Unmarshal(b []byte) error

+ func (request *ActualLRPGroupsByProcessGuidRequest) Validate() error

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

+ func (this *ActualLRPGroupsByProcessGuidRequest) GoString() string

+ func (this *ActualLRPGroupsByProcessGuidRequest) String() string

+ type ActualLRPGroupsRequest struct

+ CellId string

+ Domain string

+ func (*ActualLRPGroupsRequest) Descriptor() ([]byte, []int)

+ func (*ActualLRPGroupsRequest) ProtoMessage()

+ func (m *ActualLRPGroupsRequest) GetCellId() string

+ func (m *ActualLRPGroupsRequest) GetDomain() string

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

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

+ func (m *ActualLRPGroupsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ActualLRPGroupsRequest) Reset()

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

+ func (m *ActualLRPGroupsRequest) Unmarshal(dAtA []byte) error

+ func (m *ActualLRPGroupsRequest) XXX_DiscardUnknown()

+ func (m *ActualLRPGroupsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ActualLRPGroupsRequest) XXX_Merge(src proto.Message)

+ func (m *ActualLRPGroupsRequest) XXX_Size() int

+ func (m *ActualLRPGroupsRequest) XXX_Unmarshal(b []byte) error

+ func (request *ActualLRPGroupsRequest) Validate() error

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

+ func (this *ActualLRPGroupsRequest) GoString() string

+ func (this *ActualLRPGroupsRequest) String() string

+ type ActualLRPGroupsResponse struct

+ ActualLrpGroups []*ActualLRPGroup

+ Error *Error

+ func (*ActualLRPGroupsResponse) Descriptor() ([]byte, []int)

+ func (*ActualLRPGroupsResponse) ProtoMessage()

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

+ func (m *ActualLRPGroupsResponse) GetError() *Error

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

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

+ func (m *ActualLRPGroupsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ActualLRPGroupsResponse) Reset()

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

+ func (m *ActualLRPGroupsResponse) Unmarshal(dAtA []byte) error

+ func (m *ActualLRPGroupsResponse) XXX_DiscardUnknown()

+ func (m *ActualLRPGroupsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ActualLRPGroupsResponse) XXX_Merge(src proto.Message)

+ func (m *ActualLRPGroupsResponse) XXX_Size() int

+ func (m *ActualLRPGroupsResponse) XXX_Unmarshal(b []byte) error

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

+ func (this *ActualLRPGroupsResponse) GoString() string

+ func (this *ActualLRPGroupsResponse) String() string

+ type ActualLRPInfo struct

+ AvailabilityZone string

+ CrashCount int32

+ CrashReason string

+ ModificationTag ModificationTag

+ OptionalRoutable isActualLRPInfo_OptionalRoutable

+ PlacementError string

+ Presence ActualLRP_Presence

+ Since int64

+ State string

+ func (*ActualLRPInfo) Descriptor() ([]byte, []int)

+ func (*ActualLRPInfo) ProtoMessage()

+ func (*ActualLRPInfo) XXX_OneofWrappers() []interface{}

+ func (actualLRPInfo *ActualLRPInfo) ToActualLRP(lrpKey ActualLRPKey, lrpInstanceKey ActualLRPInstanceKey) *ActualLRP

+ func (info *ActualLRPInfo) RoutableExists() bool

+ func (info *ActualLRPInfo) SetRoutable(routable bool)

+ func (m *ActualLRPInfo) GetAvailabilityZone() string

+ func (m *ActualLRPInfo) GetCrashCount() int32

+ func (m *ActualLRPInfo) GetCrashReason() string

+ func (m *ActualLRPInfo) GetModificationTag() ModificationTag

+ func (m *ActualLRPInfo) GetOptionalRoutable() isActualLRPInfo_OptionalRoutable

+ func (m *ActualLRPInfo) GetPlacementError() string

+ func (m *ActualLRPInfo) GetPresence() ActualLRP_Presence

+ func (m *ActualLRPInfo) GetRoutable() bool

+ func (m *ActualLRPInfo) GetSince() int64

+ func (m *ActualLRPInfo) GetState() string

+ func (m *ActualLRPInfo) Marshal() (dAtA []byte, err error)

+ func (m *ActualLRPInfo) MarshalTo(dAtA []byte) (int, error)

+ func (m *ActualLRPInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ActualLRPInfo) Reset()

+ func (m *ActualLRPInfo) Size() (n int)

+ func (m *ActualLRPInfo) Unmarshal(dAtA []byte) error

+ func (m *ActualLRPInfo) XXX_DiscardUnknown()

+ func (m *ActualLRPInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ActualLRPInfo) XXX_Merge(src proto.Message)

+ func (m *ActualLRPInfo) XXX_Size() int

+ func (m *ActualLRPInfo) XXX_Unmarshal(b []byte) error

+ func (this *ActualLRPInfo) Equal(that interface{}) bool

+ func (this *ActualLRPInfo) GoString() string

+ func (this *ActualLRPInfo) String() string

+ type ActualLRPInfo_Routable struct

+ Routable bool

+ func (m *ActualLRPInfo_Routable) MarshalTo(dAtA []byte) (int, error)

+ func (m *ActualLRPInfo_Routable) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ActualLRPInfo_Routable) Size() (n int)

+ func (this *ActualLRPInfo_Routable) Equal(that interface{}) bool

+ func (this *ActualLRPInfo_Routable) GoString() string

+ func (this *ActualLRPInfo_Routable) String() string

+ type ActualLRPInstanceChangedEvent struct

+ After *ActualLRPInfo

+ Before *ActualLRPInfo

+ TraceId string

+ func NewActualLRPInstanceChangedEvent(before, after *ActualLRP, traceId string) *ActualLRPInstanceChangedEvent

+ func (*ActualLRPInstanceChangedEvent) Descriptor() ([]byte, []int)

+ func (*ActualLRPInstanceChangedEvent) ProtoMessage()

+ func (event *ActualLRPInstanceChangedEvent) EventType() string

+ func (event *ActualLRPInstanceChangedEvent) Key() string

+ func (m *ActualLRPInstanceChangedEvent) GetAfter() *ActualLRPInfo

+ func (m *ActualLRPInstanceChangedEvent) GetBefore() *ActualLRPInfo

+ func (m *ActualLRPInstanceChangedEvent) GetTraceId() string

+ func (m *ActualLRPInstanceChangedEvent) Marshal() (dAtA []byte, err error)

+ func (m *ActualLRPInstanceChangedEvent) MarshalTo(dAtA []byte) (int, error)

+ func (m *ActualLRPInstanceChangedEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ActualLRPInstanceChangedEvent) Reset()

+ func (m *ActualLRPInstanceChangedEvent) Size() (n int)

+ func (m *ActualLRPInstanceChangedEvent) Unmarshal(dAtA []byte) error

+ func (m *ActualLRPInstanceChangedEvent) XXX_DiscardUnknown()

+ func (m *ActualLRPInstanceChangedEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ActualLRPInstanceChangedEvent) XXX_Merge(src proto.Message)

+ func (m *ActualLRPInstanceChangedEvent) XXX_Size() int

+ func (m *ActualLRPInstanceChangedEvent) XXX_Unmarshal(b []byte) error

+ func (this *ActualLRPInstanceChangedEvent) Equal(that interface{}) bool

+ func (this *ActualLRPInstanceChangedEvent) GoString() string

+ func (this *ActualLRPInstanceChangedEvent) String() string

+ type ActualLRPInstanceCreatedEvent struct

+ ActualLrp *ActualLRP

+ TraceId string

+ func NewActualLRPInstanceCreatedEvent(actualLrp *ActualLRP, traceId string) *ActualLRPInstanceCreatedEvent

+ func (*ActualLRPInstanceCreatedEvent) Descriptor() ([]byte, []int)

+ func (*ActualLRPInstanceCreatedEvent) ProtoMessage()

+ func (event *ActualLRPInstanceCreatedEvent) EventType() string

+ func (event *ActualLRPInstanceCreatedEvent) Key() string

+ func (m *ActualLRPInstanceCreatedEvent) GetActualLrp() *ActualLRP

+ func (m *ActualLRPInstanceCreatedEvent) GetTraceId() string

+ func (m *ActualLRPInstanceCreatedEvent) Marshal() (dAtA []byte, err error)

+ func (m *ActualLRPInstanceCreatedEvent) MarshalTo(dAtA []byte) (int, error)

+ func (m *ActualLRPInstanceCreatedEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ActualLRPInstanceCreatedEvent) Reset()

+ func (m *ActualLRPInstanceCreatedEvent) Size() (n int)

+ func (m *ActualLRPInstanceCreatedEvent) Unmarshal(dAtA []byte) error

+ func (m *ActualLRPInstanceCreatedEvent) XXX_DiscardUnknown()

+ func (m *ActualLRPInstanceCreatedEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ActualLRPInstanceCreatedEvent) XXX_Merge(src proto.Message)

+ func (m *ActualLRPInstanceCreatedEvent) XXX_Size() int

+ func (m *ActualLRPInstanceCreatedEvent) XXX_Unmarshal(b []byte) error

+ func (this *ActualLRPInstanceCreatedEvent) Equal(that interface{}) bool

+ func (this *ActualLRPInstanceCreatedEvent) GoString() string

+ func (this *ActualLRPInstanceCreatedEvent) String() string

+ type ActualLRPInstanceKey struct

+ CellId string

+ InstanceGuid string

+ func NewActualLRPInstanceKey(instanceGuid string, cellId string) ActualLRPInstanceKey

+ func (*ActualLRPInstanceKey) Descriptor() ([]byte, []int)

+ func (*ActualLRPInstanceKey) ProtoMessage()

+ func (key *ActualLRPInstanceKey) Validate() error

+ func (key ActualLRPInstanceKey) Empty() bool

+ func (m *ActualLRPInstanceKey) GetCellId() string

+ func (m *ActualLRPInstanceKey) GetInstanceGuid() string

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

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

+ func (m *ActualLRPInstanceKey) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ActualLRPInstanceKey) Reset()

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

+ func (m *ActualLRPInstanceKey) Unmarshal(dAtA []byte) error

+ func (m *ActualLRPInstanceKey) XXX_DiscardUnknown()

+ func (m *ActualLRPInstanceKey) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ActualLRPInstanceKey) XXX_Merge(src proto.Message)

+ func (m *ActualLRPInstanceKey) XXX_Size() int

+ func (m *ActualLRPInstanceKey) XXX_Unmarshal(b []byte) error

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

+ func (this *ActualLRPInstanceKey) GoString() string

+ func (this *ActualLRPInstanceKey) String() string

+ type ActualLRPInstanceRemovedEvent struct

+ ActualLrp *ActualLRP

+ TraceId string

+ func NewActualLRPInstanceRemovedEvent(actualLrp *ActualLRP, traceId string) *ActualLRPInstanceRemovedEvent

+ func (*ActualLRPInstanceRemovedEvent) Descriptor() ([]byte, []int)

+ func (*ActualLRPInstanceRemovedEvent) ProtoMessage()

+ func (event *ActualLRPInstanceRemovedEvent) EventType() string

+ func (event *ActualLRPInstanceRemovedEvent) Key() string

+ func (m *ActualLRPInstanceRemovedEvent) GetActualLrp() *ActualLRP

+ func (m *ActualLRPInstanceRemovedEvent) GetTraceId() string

+ func (m *ActualLRPInstanceRemovedEvent) Marshal() (dAtA []byte, err error)

+ func (m *ActualLRPInstanceRemovedEvent) MarshalTo(dAtA []byte) (int, error)

+ func (m *ActualLRPInstanceRemovedEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ActualLRPInstanceRemovedEvent) Reset()

+ func (m *ActualLRPInstanceRemovedEvent) Size() (n int)

+ func (m *ActualLRPInstanceRemovedEvent) Unmarshal(dAtA []byte) error

+ func (m *ActualLRPInstanceRemovedEvent) XXX_DiscardUnknown()

+ func (m *ActualLRPInstanceRemovedEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ActualLRPInstanceRemovedEvent) XXX_Merge(src proto.Message)

+ func (m *ActualLRPInstanceRemovedEvent) XXX_Size() int

+ func (m *ActualLRPInstanceRemovedEvent) XXX_Unmarshal(b []byte) error

+ func (this *ActualLRPInstanceRemovedEvent) Equal(that interface{}) bool

+ func (this *ActualLRPInstanceRemovedEvent) GoString() string

+ func (this *ActualLRPInstanceRemovedEvent) String() string

+ type ActualLRPInternalRoute struct

+ Hostname string

+ func (*ActualLRPInternalRoute) Descriptor() ([]byte, []int)

+ func (*ActualLRPInternalRoute) ProtoMessage()

+ func (m *ActualLRPInternalRoute) GetHostname() string

+ func (m *ActualLRPInternalRoute) Marshal() (dAtA []byte, err error)

+ func (m *ActualLRPInternalRoute) MarshalTo(dAtA []byte) (int, error)

+ func (m *ActualLRPInternalRoute) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ActualLRPInternalRoute) Reset()

+ func (m *ActualLRPInternalRoute) Size() (n int)

+ func (m *ActualLRPInternalRoute) Unmarshal(dAtA []byte) error

+ func (m *ActualLRPInternalRoute) XXX_DiscardUnknown()

+ func (m *ActualLRPInternalRoute) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ActualLRPInternalRoute) XXX_Merge(src proto.Message)

+ func (m *ActualLRPInternalRoute) XXX_Size() int

+ func (m *ActualLRPInternalRoute) XXX_Unmarshal(b []byte) error

+ func (this *ActualLRPInternalRoute) Equal(that interface{}) bool

+ func (this *ActualLRPInternalRoute) GoString() string

+ func (this *ActualLRPInternalRoute) String() string

+ type ActualLRPKey struct

+ Domain string

+ Index int32

+ ProcessGuid string

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

+ func (*ActualLRPKey) Descriptor() ([]byte, []int)

+ func (*ActualLRPKey) ProtoMessage()

+ func (key *ActualLRPKey) Validate() error

+ func (m *ActualLRPKey) GetDomain() string

+ func (m *ActualLRPKey) GetIndex() int32

+ func (m *ActualLRPKey) GetProcessGuid() string

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

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

+ func (m *ActualLRPKey) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ActualLRPKey) Reset()

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

+ func (m *ActualLRPKey) Unmarshal(dAtA []byte) error

+ func (m *ActualLRPKey) XXX_DiscardUnknown()

+ func (m *ActualLRPKey) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ActualLRPKey) XXX_Merge(src proto.Message)

+ func (m *ActualLRPKey) XXX_Size() int

+ func (m *ActualLRPKey) XXX_Unmarshal(b []byte) error

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

+ func (this *ActualLRPKey) GoString() string

+ func (this *ActualLRPKey) String() string

+ type ActualLRPKeyWithSchedulingInfo struct

+ Key *ActualLRPKey

+ SchedulingInfo *DesiredLRPSchedulingInfo

+ type ActualLRPLifecycleResponse struct

+ Error *Error

+ func (*ActualLRPLifecycleResponse) Descriptor() ([]byte, []int)

+ func (*ActualLRPLifecycleResponse) ProtoMessage()

+ func (m *ActualLRPLifecycleResponse) GetError() *Error

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

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

+ func (m *ActualLRPLifecycleResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ActualLRPLifecycleResponse) Reset()

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

+ func (m *ActualLRPLifecycleResponse) Unmarshal(dAtA []byte) error

+ func (m *ActualLRPLifecycleResponse) XXX_DiscardUnknown()

+ func (m *ActualLRPLifecycleResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ActualLRPLifecycleResponse) XXX_Merge(src proto.Message)

+ func (m *ActualLRPLifecycleResponse) XXX_Size() int

+ func (m *ActualLRPLifecycleResponse) XXX_Unmarshal(b []byte) error

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

+ func (this *ActualLRPLifecycleResponse) GoString() string

+ func (this *ActualLRPLifecycleResponse) String() string

+ type ActualLRPNetInfo struct

+ Address string

+ InstanceAddress string

+ InstanceIpv6Address string

+ Ports []*PortMapping

+ PreferredAddress ActualLRPNetInfo_PreferredAddress

+ func EmptyActualLRPNetInfo() ActualLRPNetInfo

+ func NewActualLRPNetInfo(address string, instanceAddress string, ...) ActualLRPNetInfo

+ func NewActualLRPNetInfoWithIPv6(address, instanceAddress, instanceIPv6Address string, ...) ActualLRPNetInfo

+ func (*ActualLRPNetInfo) Descriptor() ([]byte, []int)

+ func (*ActualLRPNetInfo) ProtoMessage()

+ func (*ActualLRPNetInfo) Version() format.Version

+ func (info ActualLRPNetInfo) Empty() bool

+ func (key *ActualLRPNetInfo) Validate() error

+ func (m *ActualLRPNetInfo) GetAddress() string

+ func (m *ActualLRPNetInfo) GetInstanceAddress() string

+ func (m *ActualLRPNetInfo) GetInstanceIpv6Address() string

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

+ func (m *ActualLRPNetInfo) GetPreferredAddress() ActualLRPNetInfo_PreferredAddress

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

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

+ func (m *ActualLRPNetInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ActualLRPNetInfo) Reset()

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

+ func (m *ActualLRPNetInfo) Unmarshal(dAtA []byte) error

+ func (m *ActualLRPNetInfo) XXX_DiscardUnknown()

+ func (m *ActualLRPNetInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ActualLRPNetInfo) XXX_Merge(src proto.Message)

+ func (m *ActualLRPNetInfo) XXX_Size() int

+ func (m *ActualLRPNetInfo) XXX_Unmarshal(b []byte) error

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

+ func (this *ActualLRPNetInfo) GoString() string

+ func (this *ActualLRPNetInfo) String() string

+ type ActualLRPNetInfo_PreferredAddress int32

+ const ActualLRPNetInfo_PreferredAddressHost

+ const ActualLRPNetInfo_PreferredAddressInstance

+ const ActualLRPNetInfo_PreferredAddressUnknown

+ func (ActualLRPNetInfo_PreferredAddress) EnumDescriptor() ([]byte, []int)

+ func (d *ActualLRPNetInfo_PreferredAddress) UnmarshalJSON(data []byte) error

+ func (d ActualLRPNetInfo_PreferredAddress) MarshalJSON() ([]byte, error)

+ func (x ActualLRPNetInfo_PreferredAddress) String() string

+ type ActualLRPRemovedEvent struct

+ ActualLrpGroup *ActualLRPGroup

+ func NewActualLRPRemovedEvent(actualLRPGroup *ActualLRPGroup) *ActualLRPRemovedEvent

+ func (*ActualLRPRemovedEvent) Descriptor() ([]byte, []int)

+ func (*ActualLRPRemovedEvent) ProtoMessage()

+ func (event *ActualLRPRemovedEvent) EventType() string

+ func (event *ActualLRPRemovedEvent) Key() string

+ func (m *ActualLRPRemovedEvent) GetActualLrpGroup() *ActualLRPGroup

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

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

+ func (m *ActualLRPRemovedEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ActualLRPRemovedEvent) Reset()

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

+ func (m *ActualLRPRemovedEvent) Unmarshal(dAtA []byte) error

+ func (m *ActualLRPRemovedEvent) XXX_DiscardUnknown()

+ func (m *ActualLRPRemovedEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ActualLRPRemovedEvent) XXX_Merge(src proto.Message)

+ func (m *ActualLRPRemovedEvent) XXX_Size() int

+ func (m *ActualLRPRemovedEvent) XXX_Unmarshal(b []byte) error

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

+ func (this *ActualLRPRemovedEvent) GoString() string

+ func (this *ActualLRPRemovedEvent) String() string

+ type ActualLRP_Presence int32

+ const ActualLRP_Evacuating

+ const ActualLRP_Ordinary

+ const ActualLRP_Suspect

+ func (ActualLRP_Presence) EnumDescriptor() ([]byte, []int)

+ func (d *ActualLRP_Presence) UnmarshalJSON(data []byte) error

+ func (d ActualLRP_Presence) MarshalJSON() ([]byte, error)

+ func (x ActualLRP_Presence) String() string

+ type ActualLRP_Routable struct

+ Routable bool

+ func (m *ActualLRP_Routable) MarshalTo(dAtA []byte) (int, error)

+ func (m *ActualLRP_Routable) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ActualLRP_Routable) Size() (n int)

+ func (this *ActualLRP_Routable) Equal(that interface{}) bool

+ func (this *ActualLRP_Routable) GoString() string

+ func (this *ActualLRP_Routable) String() string

+ type ActualLRPsByProcessGuidsFilter struct

+ ProcessGuids []string

+ type ActualLRPsByProcessGuidsRequest struct

+ ProcessGuids []string

+ func (*ActualLRPsByProcessGuidsRequest) Descriptor() ([]byte, []int)

+ func (*ActualLRPsByProcessGuidsRequest) ProtoMessage()

+ func (m *ActualLRPsByProcessGuidsRequest) GetProcessGuids() []string

+ func (m *ActualLRPsByProcessGuidsRequest) Marshal() (dAtA []byte, err error)

+ func (m *ActualLRPsByProcessGuidsRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *ActualLRPsByProcessGuidsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ActualLRPsByProcessGuidsRequest) Reset()

+ func (m *ActualLRPsByProcessGuidsRequest) Size() (n int)

+ func (m *ActualLRPsByProcessGuidsRequest) Unmarshal(dAtA []byte) error

+ func (m *ActualLRPsByProcessGuidsRequest) XXX_DiscardUnknown()

+ func (m *ActualLRPsByProcessGuidsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ActualLRPsByProcessGuidsRequest) XXX_Merge(src proto.Message)

+ func (m *ActualLRPsByProcessGuidsRequest) XXX_Size() int

+ func (m *ActualLRPsByProcessGuidsRequest) XXX_Unmarshal(b []byte) error

+ func (request *ActualLRPsByProcessGuidsRequest) Validate() error

+ func (this *ActualLRPsByProcessGuidsRequest) Equal(that interface{}) bool

+ func (this *ActualLRPsByProcessGuidsRequest) GoString() string

+ func (this *ActualLRPsByProcessGuidsRequest) String() string

+ type ActualLRPsByProcessGuidsResponse struct

+ ActualLrps []*ActualLRP

+ Error *Error

+ func (*ActualLRPsByProcessGuidsResponse) Descriptor() ([]byte, []int)

+ func (*ActualLRPsByProcessGuidsResponse) ProtoMessage()

+ func (m *ActualLRPsByProcessGuidsResponse) GetActualLrps() []*ActualLRP

+ func (m *ActualLRPsByProcessGuidsResponse) GetError() *Error

+ func (m *ActualLRPsByProcessGuidsResponse) Marshal() (dAtA []byte, err error)

+ func (m *ActualLRPsByProcessGuidsResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *ActualLRPsByProcessGuidsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ActualLRPsByProcessGuidsResponse) Reset()

+ func (m *ActualLRPsByProcessGuidsResponse) Size() (n int)

+ func (m *ActualLRPsByProcessGuidsResponse) Unmarshal(dAtA []byte) error

+ func (m *ActualLRPsByProcessGuidsResponse) XXX_DiscardUnknown()

+ func (m *ActualLRPsByProcessGuidsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ActualLRPsByProcessGuidsResponse) XXX_Merge(src proto.Message)

+ func (m *ActualLRPsByProcessGuidsResponse) XXX_Size() int

+ func (m *ActualLRPsByProcessGuidsResponse) XXX_Unmarshal(b []byte) error

+ func (this *ActualLRPsByProcessGuidsResponse) Equal(that interface{}) bool

+ func (this *ActualLRPsByProcessGuidsResponse) GoString() string

+ func (this *ActualLRPsByProcessGuidsResponse) String() string

+ type ActualLRPsRequest struct

+ CellId string

+ Domain string

+ OptionalIndex isActualLRPsRequest_OptionalIndex

+ ProcessGuid string

+ func (*ActualLRPsRequest) Descriptor() ([]byte, []int)

+ func (*ActualLRPsRequest) ProtoMessage()

+ func (*ActualLRPsRequest) XXX_OneofWrappers() []interface{}

+ func (m *ActualLRPsRequest) GetCellId() string

+ func (m *ActualLRPsRequest) GetDomain() string

+ func (m *ActualLRPsRequest) GetIndex() int32

+ func (m *ActualLRPsRequest) GetOptionalIndex() isActualLRPsRequest_OptionalIndex

+ func (m *ActualLRPsRequest) GetProcessGuid() string

+ func (m *ActualLRPsRequest) Marshal() (dAtA []byte, err error)

+ func (m *ActualLRPsRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *ActualLRPsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ActualLRPsRequest) Reset()

+ func (m *ActualLRPsRequest) Size() (n int)

+ func (m *ActualLRPsRequest) Unmarshal(dAtA []byte) error

+ func (m *ActualLRPsRequest) XXX_DiscardUnknown()

+ func (m *ActualLRPsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ActualLRPsRequest) XXX_Merge(src proto.Message)

+ func (m *ActualLRPsRequest) XXX_Size() int

+ func (m *ActualLRPsRequest) XXX_Unmarshal(b []byte) error

+ func (request *ActualLRPsRequest) SetIndex(index int32)

+ func (request *ActualLRPsRequest) UnmarshalJSON(data []byte) error

+ func (request *ActualLRPsRequest) Validate() error

+ func (request ActualLRPsRequest) IndexExists() bool

+ func (request ActualLRPsRequest) MarshalJSON() ([]byte, error)

+ func (this *ActualLRPsRequest) Equal(that interface{}) bool

+ func (this *ActualLRPsRequest) GoString() string

+ func (this *ActualLRPsRequest) String() string

+ type ActualLRPsRequest_Index struct

+ Index int32

+ func (m *ActualLRPsRequest_Index) MarshalTo(dAtA []byte) (int, error)

+ func (m *ActualLRPsRequest_Index) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ActualLRPsRequest_Index) Size() (n int)

+ func (this *ActualLRPsRequest_Index) Equal(that interface{}) bool

+ func (this *ActualLRPsRequest_Index) GoString() string

+ func (this *ActualLRPsRequest_Index) String() string

+ type ActualLRPsResponse struct

+ ActualLrps []*ActualLRP

+ Error *Error

+ func (*ActualLRPsResponse) Descriptor() ([]byte, []int)

+ func (*ActualLRPsResponse) ProtoMessage()

+ func (m *ActualLRPsResponse) GetActualLrps() []*ActualLRP

+ func (m *ActualLRPsResponse) GetError() *Error

+ func (m *ActualLRPsResponse) Marshal() (dAtA []byte, err error)

+ func (m *ActualLRPsResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *ActualLRPsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ActualLRPsResponse) Reset()

+ func (m *ActualLRPsResponse) Size() (n int)

+ func (m *ActualLRPsResponse) Unmarshal(dAtA []byte) error

+ func (m *ActualLRPsResponse) XXX_DiscardUnknown()

+ func (m *ActualLRPsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ActualLRPsResponse) XXX_Merge(src proto.Message)

+ func (m *ActualLRPsResponse) XXX_Size() int

+ func (m *ActualLRPsResponse) XXX_Unmarshal(b []byte) error

+ func (this *ActualLRPsResponse) Equal(that interface{}) bool

+ func (this *ActualLRPsResponse) GoString() string

+ func (this *ActualLRPsResponse) String() string

+ type ArbitraryRootFSProvider struct

+ func (ArbitraryRootFSProvider) Match(url.URL) bool

+ func (ArbitraryRootFSProvider) Type() RootFSProviderType

+ func (provider ArbitraryRootFSProvider) MarshalJSON() ([]byte, error)

+ type AuctioneerClient interface

+ RequestLRPAuctions func(logger lager.Logger, traceID string, lrpStart []*LRPStartRequest) error

+ RequestTaskAuctions func(logger lager.Logger, traceID string, tasks []*TaskStartRequest) error

+ type BBSPresence struct

+ ID string

+ URL string

+ func NewBBSPresence(id, url string) BBSPresence

+ func (p BBSPresence) Validate() error

+ type CachedDependency struct

+ CacheKey string

+ ChecksumAlgorithm string

+ ChecksumValue string

+ From string

+ LogSource string

+ Name string

+ To string

+ func (*CachedDependency) Descriptor() ([]byte, []int)

+ func (*CachedDependency) ProtoMessage()

+ func (c *CachedDependency) Validate() error

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

+ func (m *CachedDependency) GetCacheKey() string

+ func (m *CachedDependency) GetChecksumAlgorithm() string

+ func (m *CachedDependency) GetChecksumValue() string

+ func (m *CachedDependency) GetFrom() string

+ func (m *CachedDependency) GetLogSource() string

+ func (m *CachedDependency) GetName() string

+ func (m *CachedDependency) GetTo() string

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

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

+ func (m *CachedDependency) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *CachedDependency) Reset()

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

+ func (m *CachedDependency) Unmarshal(dAtA []byte) error

+ func (m *CachedDependency) XXX_DiscardUnknown()

+ func (m *CachedDependency) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *CachedDependency) XXX_Merge(src proto.Message)

+ func (m *CachedDependency) XXX_Size() int

+ func (m *CachedDependency) XXX_Unmarshal(b []byte) error

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

+ func (this *CachedDependency) GoString() string

+ func (this *CachedDependency) String() string

+ type CellCapacity struct

+ Containers int32

+ DiskMb int32

+ MemoryMb int32

+ func NewCellCapacity(memoryMB, diskMB, containers int32) CellCapacity

+ func (*CellCapacity) Descriptor() ([]byte, []int)

+ func (*CellCapacity) ProtoMessage()

+ func (cap CellCapacity) Validate() error

+ func (m *CellCapacity) GetContainers() int32

+ func (m *CellCapacity) GetDiskMb() int32

+ func (m *CellCapacity) GetMemoryMb() int32

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

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

+ func (m *CellCapacity) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *CellCapacity) Reset()

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

+ func (m *CellCapacity) Unmarshal(dAtA []byte) error

+ func (m *CellCapacity) XXX_DiscardUnknown()

+ func (m *CellCapacity) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *CellCapacity) XXX_Merge(src proto.Message)

+ func (m *CellCapacity) XXX_Size() int

+ func (m *CellCapacity) XXX_Unmarshal(b []byte) error

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

+ func (this *CellCapacity) GoString() string

+ func (this *CellCapacity) String() string

+ type CellDisappearedEvent struct

+ IDs []string

+ func NewCellDisappearedEvent(ids []string) CellDisappearedEvent

+ func (CellDisappearedEvent) EventType() string

+ func (e CellDisappearedEvent) CellIDs() []string

+ type CellEvent interface

+ CellIDs func() []string

+ EventType func() string

+ type CellPresence struct

+ Annotations map[string]string

+ Capacity *CellCapacity

+ CellId string

+ OptionalPlacementTags []string

+ PlacementTags []string

+ RepAddress string

+ RepUrl string

+ RootfsProviders []*Provider

+ Zone string

+ func NewCellPresence(cellID, repAddress, repUrl, zone string, capacity CellCapacity, ...) CellPresence

+ func (*CellPresence) Descriptor() ([]byte, []int)

+ func (*CellPresence) ProtoMessage()

+ func (c *CellPresence) Copy() *CellPresence

+ func (c CellPresence) MarshalJSON() ([]byte, error)

+ func (c CellPresence) Validate() error

+ func (m *CellPresence) GetAnnotations() map[string]string

+ func (m *CellPresence) GetCapacity() *CellCapacity

+ func (m *CellPresence) GetCellId() string

+ func (m *CellPresence) GetOptionalPlacementTags() []string

+ func (m *CellPresence) GetPlacementTags() []string

+ func (m *CellPresence) GetRepAddress() string

+ func (m *CellPresence) GetRepUrl() string

+ func (m *CellPresence) GetRootfsProviders() []*Provider

+ func (m *CellPresence) GetZone() string

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

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

+ func (m *CellPresence) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *CellPresence) Reset()

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

+ func (m *CellPresence) Unmarshal(dAtA []byte) error

+ func (m *CellPresence) XXX_DiscardUnknown()

+ func (m *CellPresence) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *CellPresence) XXX_Merge(src proto.Message)

+ func (m *CellPresence) XXX_Size() int

+ func (m *CellPresence) XXX_Unmarshal(b []byte) error

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

+ func (this *CellPresence) GoString() string

+ func (this *CellPresence) String() string

+ type CellSet map[string]*CellPresence

+ func NewCellSet() CellSet

+ func NewCellSetFromList(cells []*CellPresence) CellSet

+ func (set CellSet) Add(cell *CellPresence)

+ func (set CellSet) CellIDs() []string

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

+ func (set CellSet) HasCellID(cellID string) bool

+ type CellState struct

+ AvailableResources Resources

+ CellID string

+ CellIndex int

+ Evacuating bool

+ LRPs []SchedulingLRP

+ OptionalPlacementTags []string

+ PlacementTags []string

+ ProxyMemoryAllocationMB int

+ RepURL string

+ RootFSProviders RootFSProviders

+ StartingContainerCount int

+ Tasks []SchedulingTask

+ TotalResources Resources

+ VolumeDrivers []string

+ Zone string

+ func NewCellState(cellID string, cellIndex int, repURL string, root RootFSProviders, ...) CellState

+ func (c *CellState) AddLRP(lrp *SchedulingLRP)

+ func (c *CellState) AddTask(task *SchedulingTask)

+ func (c *CellState) MatchPlacementTags(desiredPlacementTags []string) bool

+ func (c *CellState) MatchRootFS(rootfs string) bool

+ func (c *CellState) MatchVolumeDrivers(volumeDrivers []string) bool

+ func (c *CellState) ResourceMatch(res *Resource) error

+ func (c CellState) ComputeScore(res *Resource, startingContainerWeight float64) float64

+ type CellsResponse struct

+ Cells []*CellPresence

+ Error *Error

+ func (*CellsResponse) Descriptor() ([]byte, []int)

+ func (*CellsResponse) ProtoMessage()

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

+ func (m *CellsResponse) GetError() *Error

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

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

+ func (m *CellsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *CellsResponse) Reset()

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

+ func (m *CellsResponse) Unmarshal(dAtA []byte) error

+ func (m *CellsResponse) XXX_DiscardUnknown()

+ func (m *CellsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *CellsResponse) XXX_Merge(src proto.Message)

+ func (m *CellsResponse) XXX_Size() int

+ func (m *CellsResponse) XXX_Unmarshal(b []byte) error

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

+ func (this *CellsResponse) GoString() string

+ func (this *CellsResponse) String() string

+ type CertificateProperties struct

+ OrganizationalUnit []string

+ func (*CertificateProperties) Descriptor() ([]byte, []int)

+ func (*CertificateProperties) ProtoMessage()

+ func (*CertificateProperties) Version() format.Version

+ func (CertificateProperties) Validate() error

+ func (m *CertificateProperties) GetOrganizationalUnit() []string

+ func (m *CertificateProperties) Marshal() (dAtA []byte, err error)

+ func (m *CertificateProperties) MarshalTo(dAtA []byte) (int, error)

+ func (m *CertificateProperties) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *CertificateProperties) Reset()

+ func (m *CertificateProperties) Size() (n int)

+ func (m *CertificateProperties) Unmarshal(dAtA []byte) error

+ func (m *CertificateProperties) XXX_DiscardUnknown()

+ func (m *CertificateProperties) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *CertificateProperties) XXX_Merge(src proto.Message)

+ func (m *CertificateProperties) XXX_Size() int

+ func (m *CertificateProperties) XXX_Unmarshal(b []byte) error

+ func (this *CertificateProperties) Equal(that interface{}) bool

+ func (this *CertificateProperties) GoString() string

+ func (this *CertificateProperties) String() string

+ type Check struct

+ HttpCheck *HTTPCheck

+ TcpCheck *TCPCheck

+ func (*Check) Descriptor() ([]byte, []int)

+ func (*Check) ProtoMessage()

+ func (check Check) GetPortChecker() PortChecker

+ func (check Check) Validate() error

+ func (m *Check) GetHttpCheck() *HTTPCheck

+ func (m *Check) GetTcpCheck() *TCPCheck

+ func (m *Check) Marshal() (dAtA []byte, err error)

+ func (m *Check) MarshalTo(dAtA []byte) (int, error)

+ func (m *Check) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Check) Reset()

+ func (m *Check) Size() (n int)

+ func (m *Check) Unmarshal(dAtA []byte) error

+ func (m *Check) XXX_DiscardUnknown()

+ func (m *Check) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Check) XXX_Merge(src proto.Message)

+ func (m *Check) XXX_Size() int

+ func (m *Check) XXX_Unmarshal(b []byte) error

+ func (this *Check) Equal(that interface{}) bool

+ func (this *Check) GoString() string

+ func (this *Check) String() string

+ type CheckDefinition struct

+ Checks []*Check

+ LogSource string

+ ReadinessChecks []*Check

+ func (*CheckDefinition) Descriptor() ([]byte, []int)

+ func (*CheckDefinition) ProtoMessage()

+ func (check CheckDefinition) Validate() error

+ func (m *CheckDefinition) GetChecks() []*Check

+ func (m *CheckDefinition) GetLogSource() string

+ func (m *CheckDefinition) GetReadinessChecks() []*Check

+ func (m *CheckDefinition) Marshal() (dAtA []byte, err error)

+ func (m *CheckDefinition) MarshalTo(dAtA []byte) (int, error)

+ func (m *CheckDefinition) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *CheckDefinition) Reset()

+ func (m *CheckDefinition) Size() (n int)

+ func (m *CheckDefinition) Unmarshal(dAtA []byte) error

+ func (m *CheckDefinition) XXX_DiscardUnknown()

+ func (m *CheckDefinition) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *CheckDefinition) XXX_Merge(src proto.Message)

+ func (m *CheckDefinition) XXX_Size() int

+ func (m *CheckDefinition) XXX_Unmarshal(b []byte) error

+ func (this *CheckDefinition) Equal(that interface{}) bool

+ func (this *CheckDefinition) GoString() string

+ func (this *CheckDefinition) String() string

+ type ClaimActualLRPRequest struct

+ ActualLrpInstanceKey *ActualLRPInstanceKey

+ Index int32

+ ProcessGuid string

+ func (*ClaimActualLRPRequest) Descriptor() ([]byte, []int)

+ func (*ClaimActualLRPRequest) ProtoMessage()

+ func (m *ClaimActualLRPRequest) GetActualLrpInstanceKey() *ActualLRPInstanceKey

+ func (m *ClaimActualLRPRequest) GetIndex() int32

+ func (m *ClaimActualLRPRequest) GetProcessGuid() string

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

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

+ func (m *ClaimActualLRPRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ClaimActualLRPRequest) Reset()

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

+ func (m *ClaimActualLRPRequest) Unmarshal(dAtA []byte) error

+ func (m *ClaimActualLRPRequest) XXX_DiscardUnknown()

+ func (m *ClaimActualLRPRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ClaimActualLRPRequest) XXX_Merge(src proto.Message)

+ func (m *ClaimActualLRPRequest) XXX_Size() int

+ func (m *ClaimActualLRPRequest) XXX_Unmarshal(b []byte) error

+ func (request *ClaimActualLRPRequest) Validate() error

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

+ func (this *ClaimActualLRPRequest) GoString() string

+ func (this *ClaimActualLRPRequest) String() string

+ type CodependentAction struct

+ Actions []*Action

+ LogSource string

+ func Codependent(actions ...ActionInterface) *CodependentAction

+ func (*CodependentAction) Descriptor() ([]byte, []int)

+ func (*CodependentAction) ProtoMessage()

+ func (a *CodependentAction) ActionType() string

+ func (a CodependentAction) Validate() error

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

+ func (m *CodependentAction) GetLogSource() string

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

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

+ func (m *CodependentAction) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *CodependentAction) Reset()

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

+ func (m *CodependentAction) Unmarshal(dAtA []byte) error

+ func (m *CodependentAction) XXX_DiscardUnknown()

+ func (m *CodependentAction) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *CodependentAction) XXX_Merge(src proto.Message)

+ func (m *CodependentAction) XXX_Size() int

+ func (m *CodependentAction) XXX_Unmarshal(b []byte) error

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

+ func (this *CodependentAction) GoString() string

+ func (this *CodependentAction) String() string

+ type CompleteTaskRequest struct

+ CellId string

+ Failed bool

+ FailureReason string

+ Result string

+ TaskGuid string

+ func (*CompleteTaskRequest) Descriptor() ([]byte, []int)

+ func (*CompleteTaskRequest) ProtoMessage()

+ func (m *CompleteTaskRequest) GetCellId() string

+ func (m *CompleteTaskRequest) GetFailed() bool

+ func (m *CompleteTaskRequest) GetFailureReason() string

+ func (m *CompleteTaskRequest) GetResult() string

+ func (m *CompleteTaskRequest) GetTaskGuid() string

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

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

+ func (m *CompleteTaskRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *CompleteTaskRequest) Reset()

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

+ func (m *CompleteTaskRequest) Unmarshal(dAtA []byte) error

+ func (m *CompleteTaskRequest) XXX_DiscardUnknown()

+ func (m *CompleteTaskRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *CompleteTaskRequest) XXX_Merge(src proto.Message)

+ func (m *CompleteTaskRequest) XXX_Size() int

+ func (m *CompleteTaskRequest) XXX_Unmarshal(b []byte) error

+ func (req *CompleteTaskRequest) Validate() error

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

+ func (this *CompleteTaskRequest) GoString() string

+ func (this *CompleteTaskRequest) String() string

+ type CrashActualLRPRequest struct

+ ActualLrpInstanceKey *ActualLRPInstanceKey

+ ActualLrpKey *ActualLRPKey

+ ErrorMessage string

+ func (*CrashActualLRPRequest) Descriptor() ([]byte, []int)

+ func (*CrashActualLRPRequest) ProtoMessage()

+ func (m *CrashActualLRPRequest) GetActualLrpInstanceKey() *ActualLRPInstanceKey

+ func (m *CrashActualLRPRequest) GetActualLrpKey() *ActualLRPKey

+ func (m *CrashActualLRPRequest) GetErrorMessage() string

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

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

+ func (m *CrashActualLRPRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *CrashActualLRPRequest) Reset()

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

+ func (m *CrashActualLRPRequest) Unmarshal(dAtA []byte) error

+ func (m *CrashActualLRPRequest) XXX_DiscardUnknown()

+ func (m *CrashActualLRPRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *CrashActualLRPRequest) XXX_Merge(src proto.Message)

+ func (m *CrashActualLRPRequest) XXX_Size() int

+ func (m *CrashActualLRPRequest) XXX_Unmarshal(b []byte) error

+ func (request *CrashActualLRPRequest) Validate() error

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

+ func (this *CrashActualLRPRequest) GoString() string

+ func (this *CrashActualLRPRequest) String() string

+ type DedicatedDevice struct

+ DeviceConfig string

+ MountConfig string

+ MounterId string

+ func (*DedicatedDevice) Descriptor() ([]byte, []int)

+ func (*DedicatedDevice) ProtoMessage()

+ func (m *DedicatedDevice) GetDeviceConfig() string

+ func (m *DedicatedDevice) GetMountConfig() string

+ func (m *DedicatedDevice) GetMounterId() string

+ func (m *DedicatedDevice) Marshal() (dAtA []byte, err error)

+ func (m *DedicatedDevice) MarshalTo(dAtA []byte) (int, error)

+ func (m *DedicatedDevice) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DedicatedDevice) Reset()

+ func (m *DedicatedDevice) Size() (n int)

+ func (m *DedicatedDevice) Unmarshal(dAtA []byte) error

+ func (m *DedicatedDevice) XXX_DiscardUnknown()

+ func (m *DedicatedDevice) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *DedicatedDevice) XXX_Merge(src proto.Message)

+ func (m *DedicatedDevice) XXX_Size() int

+ func (m *DedicatedDevice) XXX_Unmarshal(b []byte) error

+ func (this *DedicatedDevice) Equal(that interface{}) bool

+ func (this *DedicatedDevice) GoString() string

+ func (this *DedicatedDevice) String() string

+ type DesireLRPRequest struct

+ DesiredLrp *DesiredLRP

+ func (*DesireLRPRequest) Descriptor() ([]byte, []int)

+ func (*DesireLRPRequest) ProtoMessage()

+ func (m *DesireLRPRequest) GetDesiredLrp() *DesiredLRP

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

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

+ func (m *DesireLRPRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DesireLRPRequest) Reset()

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

+ func (m *DesireLRPRequest) Unmarshal(dAtA []byte) error

+ func (m *DesireLRPRequest) XXX_DiscardUnknown()

+ func (m *DesireLRPRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *DesireLRPRequest) XXX_Merge(src proto.Message)

+ func (m *DesireLRPRequest) XXX_Size() int

+ func (m *DesireLRPRequest) XXX_Unmarshal(b []byte) error

+ func (request *DesireLRPRequest) Validate() error

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

+ func (this *DesireLRPRequest) GoString() string

+ func (this *DesireLRPRequest) String() string

+ type DesireTaskRequest struct

+ Domain string

+ TaskDefinition *TaskDefinition

+ TaskGuid string

+ func (*DesireTaskRequest) Descriptor() ([]byte, []int)

+ func (*DesireTaskRequest) ProtoMessage()

+ func (m *DesireTaskRequest) GetDomain() string

+ func (m *DesireTaskRequest) GetTaskDefinition() *TaskDefinition

+ func (m *DesireTaskRequest) GetTaskGuid() string

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

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

+ func (m *DesireTaskRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DesireTaskRequest) Reset()

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

+ func (m *DesireTaskRequest) Unmarshal(dAtA []byte) error

+ func (m *DesireTaskRequest) XXX_DiscardUnknown()

+ func (m *DesireTaskRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *DesireTaskRequest) XXX_Merge(src proto.Message)

+ func (m *DesireTaskRequest) XXX_Size() int

+ func (m *DesireTaskRequest) XXX_Unmarshal(b []byte) error

+ func (req *DesireTaskRequest) Validate() error

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

+ func (this *DesireTaskRequest) GoString() string

+ func (this *DesireTaskRequest) String() string

+ type DesiredLRP struct

+ Action *Action

+ Annotation string

+ CachedDependencies []*CachedDependency

+ CertificateProperties *CertificateProperties

+ CheckDefinition *CheckDefinition

+ CpuWeight uint32

+ DeprecatedStartTimeoutS uint32

+ DiskMb int32

+ Domain string

+ EgressRules []*SecurityGroupRule

+ EnvironmentVariables []*EnvironmentVariable

+ ImageLayers []*ImageLayer

+ ImagePassword string

+ ImageUsername string

+ Instances int32

+ LegacyDownloadUser string

+ LogGuid string

+ LogRateLimit *LogRateLimit

+ LogSource string

+ MaxPids int32

+ MemoryMb int32

+ MetricTags map[string]*MetricTagValue

+ MetricsGuid string

+ ModificationTag *ModificationTag

+ Monitor *Action

+ Network *Network

+ PlacementTags []string

+ Ports []uint32

+ Privileged bool

+ ProcessGuid string

+ RootFs string

+ Routes *Routes

+ Setup *Action

+ Sidecars []*Sidecar

+ StartTimeoutMs int64

+ TrustedSystemCertificatesPath string

+ UpdateStrategy DesiredLRP_UpdateStrategy

+ VolumeMountedFiles []*File

+ VolumeMounts []*VolumeMount

+ func NewDesiredLRP(schedInfo DesiredLRPSchedulingInfo, runInfo DesiredLRPRunInfo, ...) DesiredLRP

+ func NewDesiredLRPRoutingInfo(key DesiredLRPKey, instances int32, routes *Routes, modTag *ModificationTag, ...) DesiredLRP

+ func (*DesiredLRP) Descriptor() ([]byte, []int)

+ func (*DesiredLRP) ProtoMessage()

+ func (*DesiredLRP) Version() format.Version

+ func (d *DesiredLRP) Copy() *DesiredLRP

+ func (d *DesiredLRP) DesiredLRPKey() DesiredLRPKey

+ func (d *DesiredLRP) DesiredLRPResource() DesiredLRPResource

+ func (d *DesiredLRP) DesiredLRPRoutingInfo() DesiredLRP

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

+ func (d *DesiredLRP) DesiredLRPSchedulingInfo() DesiredLRPSchedulingInfo

+ func (d *DesiredLRP) PopulateMetricsGuid() *DesiredLRP

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

+ func (desired DesiredLRP) Validate() error

+ func (desiredLRP *DesiredLRP) AddRunInfo(runInfo DesiredLRPRunInfo)

+ func (m *DesiredLRP) GetAction() *Action

+ func (m *DesiredLRP) GetAnnotation() string

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

+ func (m *DesiredLRP) GetCertificateProperties() *CertificateProperties

+ func (m *DesiredLRP) GetCheckDefinition() *CheckDefinition

+ func (m *DesiredLRP) GetCpuWeight() uint32

+ func (m *DesiredLRP) GetDeprecatedStartTimeoutS() uint32

+ func (m *DesiredLRP) GetDiskMb() int32

+ func (m *DesiredLRP) GetDomain() string

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

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

+ func (m *DesiredLRP) GetImageLayers() []*ImageLayer

+ func (m *DesiredLRP) GetImagePassword() string

+ func (m *DesiredLRP) GetImageUsername() string

+ func (m *DesiredLRP) GetInstances() int32

+ func (m *DesiredLRP) GetLegacyDownloadUser() string

+ func (m *DesiredLRP) GetLogGuid() string

+ func (m *DesiredLRP) GetLogRateLimit() *LogRateLimit

+ func (m *DesiredLRP) GetLogSource() string

+ func (m *DesiredLRP) GetMaxPids() int32

+ func (m *DesiredLRP) GetMemoryMb() int32

+ func (m *DesiredLRP) GetMetricTags() map[string]*MetricTagValue

+ func (m *DesiredLRP) GetMetricsGuid() string

+ func (m *DesiredLRP) GetModificationTag() *ModificationTag

+ func (m *DesiredLRP) GetMonitor() *Action

+ func (m *DesiredLRP) GetNetwork() *Network

+ func (m *DesiredLRP) GetPlacementTags() []string

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

+ func (m *DesiredLRP) GetPrivileged() bool

+ func (m *DesiredLRP) GetProcessGuid() string

+ func (m *DesiredLRP) GetRootFs() string

+ func (m *DesiredLRP) GetSetup() *Action

+ func (m *DesiredLRP) GetSidecars() []*Sidecar

+ func (m *DesiredLRP) GetStartTimeoutMs() int64

+ func (m *DesiredLRP) GetTrustedSystemCertificatesPath() string

+ func (m *DesiredLRP) GetUpdateStrategy() DesiredLRP_UpdateStrategy

+ func (m *DesiredLRP) GetVolumeMountedFiles() []*File

+ func (m *DesiredLRP) GetVolumeMounts() []*VolumeMount

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

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

+ func (m *DesiredLRP) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DesiredLRP) Reset()

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

+ func (m *DesiredLRP) Unmarshal(dAtA []byte) error

+ func (m *DesiredLRP) XXX_DiscardUnknown()

+ func (m *DesiredLRP) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *DesiredLRP) XXX_Merge(src proto.Message)

+ func (m *DesiredLRP) XXX_Size() int

+ func (m *DesiredLRP) XXX_Unmarshal(b []byte) error

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

+ func (this *DesiredLRP) GoString() string

+ func (this *DesiredLRP) String() string

+ type DesiredLRPByProcessGuidRequest struct

+ ProcessGuid string

+ func (*DesiredLRPByProcessGuidRequest) Descriptor() ([]byte, []int)

+ func (*DesiredLRPByProcessGuidRequest) ProtoMessage()

+ func (m *DesiredLRPByProcessGuidRequest) GetProcessGuid() string

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

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

+ func (m *DesiredLRPByProcessGuidRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DesiredLRPByProcessGuidRequest) Reset()

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

+ func (m *DesiredLRPByProcessGuidRequest) Unmarshal(dAtA []byte) error

+ func (m *DesiredLRPByProcessGuidRequest) XXX_DiscardUnknown()

+ func (m *DesiredLRPByProcessGuidRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *DesiredLRPByProcessGuidRequest) XXX_Merge(src proto.Message)

+ func (m *DesiredLRPByProcessGuidRequest) XXX_Size() int

+ func (m *DesiredLRPByProcessGuidRequest) XXX_Unmarshal(b []byte) error

+ func (request *DesiredLRPByProcessGuidRequest) Validate() error

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

+ func (this *DesiredLRPByProcessGuidRequest) GoString() string

+ func (this *DesiredLRPByProcessGuidRequest) String() string

+ type DesiredLRPChange struct

+ After *DesiredLRP

+ Before *DesiredLRP

+ type DesiredLRPChangedEvent struct

+ After *DesiredLRP

+ Before *DesiredLRP

+ TraceId string

+ func NewDesiredLRPChangedEvent(before, after *DesiredLRP, traceId string) *DesiredLRPChangedEvent

+ func (*DesiredLRPChangedEvent) Descriptor() ([]byte, []int)

+ func (*DesiredLRPChangedEvent) ProtoMessage()

+ func (event *DesiredLRPChangedEvent) EventType() string

+ func (event *DesiredLRPChangedEvent) Key() string

+ func (m *DesiredLRPChangedEvent) GetAfter() *DesiredLRP

+ func (m *DesiredLRPChangedEvent) GetBefore() *DesiredLRP

+ func (m *DesiredLRPChangedEvent) GetTraceId() string

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

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

+ func (m *DesiredLRPChangedEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DesiredLRPChangedEvent) Reset()

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

+ func (m *DesiredLRPChangedEvent) Unmarshal(dAtA []byte) error

+ func (m *DesiredLRPChangedEvent) XXX_DiscardUnknown()

+ func (m *DesiredLRPChangedEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *DesiredLRPChangedEvent) XXX_Merge(src proto.Message)

+ func (m *DesiredLRPChangedEvent) XXX_Size() int

+ func (m *DesiredLRPChangedEvent) XXX_Unmarshal(b []byte) error

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

+ func (this *DesiredLRPChangedEvent) GoString() string

+ func (this *DesiredLRPChangedEvent) String() string

+ type DesiredLRPCreatedEvent struct

+ DesiredLrp *DesiredLRP

+ TraceId string

+ func NewDesiredLRPCreatedEvent(desiredLRP *DesiredLRP, traceId string) *DesiredLRPCreatedEvent

+ func (*DesiredLRPCreatedEvent) Descriptor() ([]byte, []int)

+ func (*DesiredLRPCreatedEvent) ProtoMessage()

+ func (event *DesiredLRPCreatedEvent) EventType() string

+ func (event *DesiredLRPCreatedEvent) Key() string

+ func (m *DesiredLRPCreatedEvent) GetDesiredLrp() *DesiredLRP

+ func (m *DesiredLRPCreatedEvent) GetTraceId() string

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

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

+ func (m *DesiredLRPCreatedEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DesiredLRPCreatedEvent) Reset()

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

+ func (m *DesiredLRPCreatedEvent) Unmarshal(dAtA []byte) error

+ func (m *DesiredLRPCreatedEvent) XXX_DiscardUnknown()

+ func (m *DesiredLRPCreatedEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *DesiredLRPCreatedEvent) XXX_Merge(src proto.Message)

+ func (m *DesiredLRPCreatedEvent) XXX_Size() int

+ func (m *DesiredLRPCreatedEvent) XXX_Unmarshal(b []byte) error

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

+ func (this *DesiredLRPCreatedEvent) GoString() string

+ func (this *DesiredLRPCreatedEvent) String() string

+ type DesiredLRPFilter struct

+ AppGuids []string

+ Domain string

+ ProcessGuids []string

+ type DesiredLRPKey struct

+ Domain string

+ LogGuid string

+ ProcessGuid string

+ func NewDesiredLRPKey(processGuid, domain, logGuid string) DesiredLRPKey

+ func (*DesiredLRPKey) Descriptor() ([]byte, []int)

+ func (*DesiredLRPKey) ProtoMessage()

+ func (key DesiredLRPKey) Validate() error

+ func (m *DesiredLRPKey) GetDomain() string

+ func (m *DesiredLRPKey) GetLogGuid() string

+ func (m *DesiredLRPKey) GetProcessGuid() string

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

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

+ func (m *DesiredLRPKey) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DesiredLRPKey) Reset()

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

+ func (m *DesiredLRPKey) Unmarshal(dAtA []byte) error

+ func (m *DesiredLRPKey) XXX_DiscardUnknown()

+ func (m *DesiredLRPKey) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *DesiredLRPKey) XXX_Merge(src proto.Message)

+ func (m *DesiredLRPKey) XXX_Size() int

+ func (m *DesiredLRPKey) XXX_Unmarshal(b []byte) error

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

+ func (this *DesiredLRPKey) GoString() string

+ func (this *DesiredLRPKey) String() string

+ type DesiredLRPLifecycleResponse struct

+ Error *Error

+ func (*DesiredLRPLifecycleResponse) Descriptor() ([]byte, []int)

+ func (*DesiredLRPLifecycleResponse) ProtoMessage()

+ func (m *DesiredLRPLifecycleResponse) GetError() *Error

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

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

+ func (m *DesiredLRPLifecycleResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DesiredLRPLifecycleResponse) Reset()

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

+ func (m *DesiredLRPLifecycleResponse) Unmarshal(dAtA []byte) error

+ func (m *DesiredLRPLifecycleResponse) XXX_DiscardUnknown()

+ func (m *DesiredLRPLifecycleResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *DesiredLRPLifecycleResponse) XXX_Merge(src proto.Message)

+ func (m *DesiredLRPLifecycleResponse) XXX_Size() int

+ func (m *DesiredLRPLifecycleResponse) XXX_Unmarshal(b []byte) error

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

+ func (this *DesiredLRPLifecycleResponse) GoString() string

+ func (this *DesiredLRPLifecycleResponse) String() string

+ type DesiredLRPRemovedEvent struct

+ DesiredLrp *DesiredLRP

+ TraceId string

+ func NewDesiredLRPRemovedEvent(desiredLRP *DesiredLRP, traceId string) *DesiredLRPRemovedEvent

+ func (*DesiredLRPRemovedEvent) Descriptor() ([]byte, []int)

+ func (*DesiredLRPRemovedEvent) ProtoMessage()

+ func (event *DesiredLRPRemovedEvent) EventType() string

+ func (event DesiredLRPRemovedEvent) Key() string

+ func (m *DesiredLRPRemovedEvent) GetDesiredLrp() *DesiredLRP

+ func (m *DesiredLRPRemovedEvent) GetTraceId() string

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

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

+ func (m *DesiredLRPRemovedEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DesiredLRPRemovedEvent) Reset()

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

+ func (m *DesiredLRPRemovedEvent) Unmarshal(dAtA []byte) error

+ func (m *DesiredLRPRemovedEvent) XXX_DiscardUnknown()

+ func (m *DesiredLRPRemovedEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *DesiredLRPRemovedEvent) XXX_Merge(src proto.Message)

+ func (m *DesiredLRPRemovedEvent) XXX_Size() int

+ func (m *DesiredLRPRemovedEvent) XXX_Unmarshal(b []byte) error

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

+ func (this *DesiredLRPRemovedEvent) GoString() string

+ func (this *DesiredLRPRemovedEvent) String() string

+ type DesiredLRPResource struct

+ DiskMb int32

+ MaxPids int32

+ MemoryMb int32

+ RootFs string

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

+ func (*DesiredLRPResource) Descriptor() ([]byte, []int)

+ func (*DesiredLRPResource) ProtoMessage()

+ func (m *DesiredLRPResource) GetDiskMb() int32

+ func (m *DesiredLRPResource) GetMaxPids() int32

+ func (m *DesiredLRPResource) GetMemoryMb() int32

+ func (m *DesiredLRPResource) GetRootFs() string

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

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

+ func (m *DesiredLRPResource) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DesiredLRPResource) Reset()

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

+ func (m *DesiredLRPResource) Unmarshal(dAtA []byte) error

+ func (m *DesiredLRPResource) XXX_DiscardUnknown()

+ func (m *DesiredLRPResource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *DesiredLRPResource) XXX_Merge(src proto.Message)

+ func (m *DesiredLRPResource) XXX_Size() int

+ func (m *DesiredLRPResource) XXX_Unmarshal(b []byte) error

+ func (resource DesiredLRPResource) Validate() error

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

+ func (this *DesiredLRPResource) GoString() string

+ func (this *DesiredLRPResource) String() string

+ type DesiredLRPResponse struct

+ DesiredLrp *DesiredLRP

+ Error *Error

+ func (*DesiredLRPResponse) Descriptor() ([]byte, []int)

+ func (*DesiredLRPResponse) ProtoMessage()

+ func (m *DesiredLRPResponse) GetDesiredLrp() *DesiredLRP

+ func (m *DesiredLRPResponse) GetError() *Error

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

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

+ func (m *DesiredLRPResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DesiredLRPResponse) Reset()

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

+ func (m *DesiredLRPResponse) Unmarshal(dAtA []byte) error

+ func (m *DesiredLRPResponse) XXX_DiscardUnknown()

+ func (m *DesiredLRPResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *DesiredLRPResponse) XXX_Merge(src proto.Message)

+ func (m *DesiredLRPResponse) XXX_Size() int

+ func (m *DesiredLRPResponse) XXX_Unmarshal(b []byte) error

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

+ func (this *DesiredLRPResponse) GoString() string

+ func (this *DesiredLRPResponse) String() string

+ type DesiredLRPRunInfo struct

+ Action *Action

+ CachedDependencies []*CachedDependency

+ CertificateProperties *CertificateProperties

+ CheckDefinition *CheckDefinition

+ CpuWeight uint32

+ CreatedAt int64

+ DeprecatedStartTimeoutS uint32

+ EgressRules []SecurityGroupRule

+ EnvironmentVariables []EnvironmentVariable

+ ImageLayers []*ImageLayer

+ ImagePassword string

+ ImageUsername string

+ LegacyDownloadUser string

+ LogRateLimit *LogRateLimit

+ LogSource string

+ MetricTags map[string]*MetricTagValue

+ MetricsGuid string

+ Monitor *Action

+ Network *Network

+ Ports []uint32

+ Privileged bool

+ Setup *Action

+ Sidecars []*Sidecar

+ StartTimeoutMs int64

+ TrustedSystemCertificatesPath string

+ VolumeMountedFiles []*File

+ VolumeMounts []*VolumeMount

+ func NewDesiredLRPRunInfo(key DesiredLRPKey, createdAt time.Time, envVars []EnvironmentVariable, ...) DesiredLRPRunInfo

+ func (*DesiredLRPRunInfo) Descriptor() ([]byte, []int)

+ func (*DesiredLRPRunInfo) ProtoMessage()

+ func (m *DesiredLRPRunInfo) GetAction() *Action

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

+ func (m *DesiredLRPRunInfo) GetCertificateProperties() *CertificateProperties

+ func (m *DesiredLRPRunInfo) GetCheckDefinition() *CheckDefinition

+ func (m *DesiredLRPRunInfo) GetCpuWeight() uint32

+ func (m *DesiredLRPRunInfo) GetCreatedAt() int64

+ func (m *DesiredLRPRunInfo) GetDeprecatedStartTimeoutS() uint32

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

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

+ func (m *DesiredLRPRunInfo) GetImageLayers() []*ImageLayer

+ func (m *DesiredLRPRunInfo) GetImagePassword() string

+ func (m *DesiredLRPRunInfo) GetImageUsername() string

+ func (m *DesiredLRPRunInfo) GetLegacyDownloadUser() string

+ func (m *DesiredLRPRunInfo) GetLogRateLimit() *LogRateLimit

+ func (m *DesiredLRPRunInfo) GetLogSource() string

+ func (m *DesiredLRPRunInfo) GetMetricTags() map[string]*MetricTagValue

+ func (m *DesiredLRPRunInfo) GetMetricsGuid() string

+ func (m *DesiredLRPRunInfo) GetMonitor() *Action

+ func (m *DesiredLRPRunInfo) GetNetwork() *Network

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

+ func (m *DesiredLRPRunInfo) GetPrivileged() bool

+ func (m *DesiredLRPRunInfo) GetSetup() *Action

+ func (m *DesiredLRPRunInfo) GetSidecars() []*Sidecar

+ func (m *DesiredLRPRunInfo) GetStartTimeoutMs() int64

+ func (m *DesiredLRPRunInfo) GetTrustedSystemCertificatesPath() string

+ func (m *DesiredLRPRunInfo) GetVolumeMountedFiles() []*File

+ func (m *DesiredLRPRunInfo) GetVolumeMounts() []*VolumeMount

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

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

+ func (m *DesiredLRPRunInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DesiredLRPRunInfo) Reset()

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

+ func (m *DesiredLRPRunInfo) Unmarshal(dAtA []byte) error

+ func (m *DesiredLRPRunInfo) XXX_DiscardUnknown()

+ func (m *DesiredLRPRunInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *DesiredLRPRunInfo) XXX_Merge(src proto.Message)

+ func (m *DesiredLRPRunInfo) XXX_Size() int

+ func (m *DesiredLRPRunInfo) XXX_Unmarshal(b []byte) error

+ func (runInfo DesiredLRPRunInfo) Validate() error

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

+ func (this *DesiredLRPRunInfo) GoString() string

+ func (this *DesiredLRPRunInfo) String() string

+ type DesiredLRPSchedulingInfo struct

+ Annotation string

+ Instances int32

+ PlacementTags []string

+ Routes Routes

+ VolumePlacement *VolumePlacement

+ func NewDesiredLRPSchedulingInfo(key DesiredLRPKey, annotation string, instances int32, ...) DesiredLRPSchedulingInfo

+ func (*DesiredLRPSchedulingInfo) Descriptor() ([]byte, []int)

+ func (*DesiredLRPSchedulingInfo) ProtoMessage()

+ func (*DesiredLRPSchedulingInfo) Version() format.Version

+ func (m *DesiredLRPSchedulingInfo) GetAnnotation() string

+ func (m *DesiredLRPSchedulingInfo) GetInstances() int32

+ func (m *DesiredLRPSchedulingInfo) GetPlacementTags() []string

+ func (m *DesiredLRPSchedulingInfo) GetVolumePlacement() *VolumePlacement

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

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

+ func (m *DesiredLRPSchedulingInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DesiredLRPSchedulingInfo) Reset()

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

+ func (m *DesiredLRPSchedulingInfo) Unmarshal(dAtA []byte) error

+ func (m *DesiredLRPSchedulingInfo) XXX_DiscardUnknown()

+ func (m *DesiredLRPSchedulingInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *DesiredLRPSchedulingInfo) XXX_Merge(src proto.Message)

+ func (m *DesiredLRPSchedulingInfo) XXX_Size() int

+ func (m *DesiredLRPSchedulingInfo) XXX_Unmarshal(b []byte) error

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

+ func (s DesiredLRPSchedulingInfo) Validate() error

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

+ func (this *DesiredLRPSchedulingInfo) GoString() string

+ func (this *DesiredLRPSchedulingInfo) String() string

+ type DesiredLRPSchedulingInfoByProcessGuidResponse struct

+ DesiredLrpSchedulingInfo *DesiredLRPSchedulingInfo

+ Error *Error

+ func (*DesiredLRPSchedulingInfoByProcessGuidResponse) Descriptor() ([]byte, []int)

+ func (*DesiredLRPSchedulingInfoByProcessGuidResponse) ProtoMessage()

+ func (m *DesiredLRPSchedulingInfoByProcessGuidResponse) GetDesiredLrpSchedulingInfo() *DesiredLRPSchedulingInfo

+ func (m *DesiredLRPSchedulingInfoByProcessGuidResponse) GetError() *Error

+ func (m *DesiredLRPSchedulingInfoByProcessGuidResponse) Marshal() (dAtA []byte, err error)

+ func (m *DesiredLRPSchedulingInfoByProcessGuidResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *DesiredLRPSchedulingInfoByProcessGuidResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DesiredLRPSchedulingInfoByProcessGuidResponse) Reset()

+ func (m *DesiredLRPSchedulingInfoByProcessGuidResponse) Size() (n int)

+ func (m *DesiredLRPSchedulingInfoByProcessGuidResponse) Unmarshal(dAtA []byte) error

+ func (m *DesiredLRPSchedulingInfoByProcessGuidResponse) XXX_DiscardUnknown()

+ func (m *DesiredLRPSchedulingInfoByProcessGuidResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *DesiredLRPSchedulingInfoByProcessGuidResponse) XXX_Merge(src proto.Message)

+ func (m *DesiredLRPSchedulingInfoByProcessGuidResponse) XXX_Size() int

+ func (m *DesiredLRPSchedulingInfoByProcessGuidResponse) XXX_Unmarshal(b []byte) error

+ func (this *DesiredLRPSchedulingInfoByProcessGuidResponse) Equal(that interface{}) bool

+ func (this *DesiredLRPSchedulingInfoByProcessGuidResponse) GoString() string

+ func (this *DesiredLRPSchedulingInfoByProcessGuidResponse) String() string

+ type DesiredLRPSchedulingInfosResponse struct

+ DesiredLrpSchedulingInfos []*DesiredLRPSchedulingInfo

+ Error *Error

+ func (*DesiredLRPSchedulingInfosResponse) Descriptor() ([]byte, []int)

+ func (*DesiredLRPSchedulingInfosResponse) ProtoMessage()

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

+ func (m *DesiredLRPSchedulingInfosResponse) GetError() *Error

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

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

+ func (m *DesiredLRPSchedulingInfosResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DesiredLRPSchedulingInfosResponse) Reset()

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

+ func (m *DesiredLRPSchedulingInfosResponse) Unmarshal(dAtA []byte) error

+ func (m *DesiredLRPSchedulingInfosResponse) XXX_DiscardUnknown()

+ func (m *DesiredLRPSchedulingInfosResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *DesiredLRPSchedulingInfosResponse) XXX_Merge(src proto.Message)

+ func (m *DesiredLRPSchedulingInfosResponse) XXX_Size() int

+ func (m *DesiredLRPSchedulingInfosResponse) XXX_Unmarshal(b []byte) error

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

+ func (this *DesiredLRPSchedulingInfosResponse) GoString() string

+ func (this *DesiredLRPSchedulingInfosResponse) String() string

+ type DesiredLRPUpdate struct

+ MetricTags map[string]*MetricTagValue

+ OptionalAnnotation isDesiredLRPUpdate_OptionalAnnotation

+ OptionalImagePassword isDesiredLRPUpdate_OptionalImagePassword

+ OptionalImageUsername isDesiredLRPUpdate_OptionalImageUsername

+ OptionalInstances isDesiredLRPUpdate_OptionalInstances

+ Routes *Routes

+ func (*DesiredLRPUpdate) Descriptor() ([]byte, []int)

+ func (*DesiredLRPUpdate) ProtoMessage()

+ func (*DesiredLRPUpdate) XXX_OneofWrappers() []interface{}

+ func (desired *DesiredLRPUpdate) SetAnnotation(annotation string)

+ func (desired *DesiredLRPUpdate) SetImagePassword(imagePassword string)

+ func (desired *DesiredLRPUpdate) SetImageUsername(imageUsername string)

+ func (desired *DesiredLRPUpdate) SetInstances(instances int32)

+ func (desired *DesiredLRPUpdate) UnmarshalJSON(data []byte) error

+ func (desired *DesiredLRPUpdate) Validate() error

+ func (desired DesiredLRPUpdate) AnnotationExists() bool

+ func (desired DesiredLRPUpdate) ImagePasswordExists() bool

+ func (desired DesiredLRPUpdate) ImageUsernameExists() bool

+ func (desired DesiredLRPUpdate) InstancesExists() bool

+ func (desired DesiredLRPUpdate) IsImageCredentialsUpdated(existingLRP *DesiredLRP) bool

+ func (desired DesiredLRPUpdate) IsMetricTagsUpdated(existingTags map[string]*MetricTagValue) bool

+ func (desired DesiredLRPUpdate) IsRoutesGroupUpdated(routes *Routes, routerGroup string) bool

+ func (desired DesiredLRPUpdate) MarshalJSON() ([]byte, error)

+ func (m *DesiredLRPUpdate) GetAnnotation() string

+ func (m *DesiredLRPUpdate) GetImagePassword() string

+ func (m *DesiredLRPUpdate) GetImageUsername() string

+ func (m *DesiredLRPUpdate) GetInstances() int32

+ func (m *DesiredLRPUpdate) GetMetricTags() map[string]*MetricTagValue

+ func (m *DesiredLRPUpdate) GetOptionalAnnotation() isDesiredLRPUpdate_OptionalAnnotation

+ func (m *DesiredLRPUpdate) GetOptionalImagePassword() isDesiredLRPUpdate_OptionalImagePassword

+ func (m *DesiredLRPUpdate) GetOptionalImageUsername() isDesiredLRPUpdate_OptionalImageUsername

+ func (m *DesiredLRPUpdate) GetOptionalInstances() isDesiredLRPUpdate_OptionalInstances

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

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

+ func (m *DesiredLRPUpdate) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DesiredLRPUpdate) Reset()

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

+ func (m *DesiredLRPUpdate) Unmarshal(dAtA []byte) error

+ func (m *DesiredLRPUpdate) XXX_DiscardUnknown()

+ func (m *DesiredLRPUpdate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *DesiredLRPUpdate) XXX_Merge(src proto.Message)

+ func (m *DesiredLRPUpdate) XXX_Size() int

+ func (m *DesiredLRPUpdate) XXX_Unmarshal(b []byte) error

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

+ func (this *DesiredLRPUpdate) GoString() string

+ func (this *DesiredLRPUpdate) String() string

+ type DesiredLRPUpdate_Annotation struct

+ Annotation string

+ func (m *DesiredLRPUpdate_Annotation) MarshalTo(dAtA []byte) (int, error)

+ func (m *DesiredLRPUpdate_Annotation) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DesiredLRPUpdate_Annotation) Size() (n int)

+ func (this *DesiredLRPUpdate_Annotation) Equal(that interface{}) bool

+ func (this *DesiredLRPUpdate_Annotation) GoString() string

+ func (this *DesiredLRPUpdate_Annotation) String() string

+ type DesiredLRPUpdate_ImagePassword struct

+ ImagePassword string

+ func (m *DesiredLRPUpdate_ImagePassword) MarshalTo(dAtA []byte) (int, error)

+ func (m *DesiredLRPUpdate_ImagePassword) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DesiredLRPUpdate_ImagePassword) Size() (n int)

+ func (this *DesiredLRPUpdate_ImagePassword) Equal(that interface{}) bool

+ func (this *DesiredLRPUpdate_ImagePassword) GoString() string

+ func (this *DesiredLRPUpdate_ImagePassword) String() string

+ type DesiredLRPUpdate_ImageUsername struct

+ ImageUsername string

+ func (m *DesiredLRPUpdate_ImageUsername) MarshalTo(dAtA []byte) (int, error)

+ func (m *DesiredLRPUpdate_ImageUsername) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DesiredLRPUpdate_ImageUsername) Size() (n int)

+ func (this *DesiredLRPUpdate_ImageUsername) Equal(that interface{}) bool

+ func (this *DesiredLRPUpdate_ImageUsername) GoString() string

+ func (this *DesiredLRPUpdate_ImageUsername) String() string

+ type DesiredLRPUpdate_Instances struct

+ Instances int32

+ func (m *DesiredLRPUpdate_Instances) MarshalTo(dAtA []byte) (int, error)

+ func (m *DesiredLRPUpdate_Instances) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DesiredLRPUpdate_Instances) Size() (n int)

+ func (this *DesiredLRPUpdate_Instances) Equal(that interface{}) bool

+ func (this *DesiredLRPUpdate_Instances) GoString() string

+ func (this *DesiredLRPUpdate_Instances) String() string

+ type DesiredLRP_UpdateStrategy int32

+ const DesiredLRP_UpdateStrategyRecreate

+ const DesiredLRP_UpdateStrategyRolling

+ func (DesiredLRP_UpdateStrategy) EnumDescriptor() ([]byte, []int)

+ func (x DesiredLRP_UpdateStrategy) String() string

+ type DesiredLRPsRequest struct

+ AppGuids []string

+ Domain string

+ ProcessGuids []string

+ func (*DesiredLRPsRequest) Descriptor() ([]byte, []int)

+ func (*DesiredLRPsRequest) ProtoMessage()

+ func (m *DesiredLRPsRequest) GetAppGuids() []string

+ func (m *DesiredLRPsRequest) GetDomain() string

+ func (m *DesiredLRPsRequest) GetProcessGuids() []string

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

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

+ func (m *DesiredLRPsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DesiredLRPsRequest) Reset()

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

+ func (m *DesiredLRPsRequest) Unmarshal(dAtA []byte) error

+ func (m *DesiredLRPsRequest) XXX_DiscardUnknown()

+ func (m *DesiredLRPsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *DesiredLRPsRequest) XXX_Merge(src proto.Message)

+ func (m *DesiredLRPsRequest) XXX_Size() int

+ func (m *DesiredLRPsRequest) XXX_Unmarshal(b []byte) error

+ func (request *DesiredLRPsRequest) Validate() error

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

+ func (this *DesiredLRPsRequest) GoString() string

+ func (this *DesiredLRPsRequest) String() string

+ type DesiredLRPsResponse struct

+ DesiredLrps []*DesiredLRP

+ Error *Error

+ func (*DesiredLRPsResponse) Descriptor() ([]byte, []int)

+ func (*DesiredLRPsResponse) ProtoMessage()

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

+ func (m *DesiredLRPsResponse) GetError() *Error

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

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

+ func (m *DesiredLRPsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DesiredLRPsResponse) Reset()

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

+ func (m *DesiredLRPsResponse) Unmarshal(dAtA []byte) error

+ func (m *DesiredLRPsResponse) XXX_DiscardUnknown()

+ func (m *DesiredLRPsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *DesiredLRPsResponse) XXX_Merge(src proto.Message)

+ func (m *DesiredLRPsResponse) XXX_Size() int

+ func (m *DesiredLRPsResponse) XXX_Unmarshal(b []byte) error

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

+ func (this *DesiredLRPsResponse) GoString() string

+ func (this *DesiredLRPsResponse) String() string

+ type DomainSet map[string]struct

+ func NewDomainSet(domains []string) DomainSet

+ func (set DomainSet) Add(domain string)

+ func (set DomainSet) Contains(domain string) bool

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

+ type DomainsResponse struct

+ Domains []string

+ Error *Error

+ func (*DomainsResponse) Descriptor() ([]byte, []int)

+ func (*DomainsResponse) ProtoMessage()

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

+ func (m *DomainsResponse) GetError() *Error

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

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

+ func (m *DomainsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DomainsResponse) Reset()

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

+ func (m *DomainsResponse) Unmarshal(dAtA []byte) error

+ func (m *DomainsResponse) XXX_DiscardUnknown()

+ func (m *DomainsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *DomainsResponse) XXX_Merge(src proto.Message)

+ func (m *DomainsResponse) XXX_Size() int

+ func (m *DomainsResponse) XXX_Unmarshal(b []byte) error

+ func (this *DomainsResponse) GoString() string

+ func (this *DomainsResponse) String() string

+ type DownloadAction struct

+ Artifact string

+ CacheKey string

+ ChecksumAlgorithm string

+ ChecksumValue string

+ From string

+ LogSource string

+ To string

+ User string

+ func (*DownloadAction) Descriptor() ([]byte, []int)

+ func (*DownloadAction) ProtoMessage()

+ func (a *DownloadAction) ActionType() string

+ func (a DownloadAction) Validate() error

+ func (m *DownloadAction) GetArtifact() string

+ func (m *DownloadAction) GetCacheKey() string

+ func (m *DownloadAction) GetChecksumAlgorithm() string

+ func (m *DownloadAction) GetChecksumValue() string

+ func (m *DownloadAction) GetFrom() string

+ func (m *DownloadAction) GetLogSource() string

+ func (m *DownloadAction) GetTo() string

+ func (m *DownloadAction) GetUser() string

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

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

+ func (m *DownloadAction) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DownloadAction) Reset()

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

+ func (m *DownloadAction) Unmarshal(dAtA []byte) error

+ func (m *DownloadAction) XXX_DiscardUnknown()

+ func (m *DownloadAction) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *DownloadAction) XXX_Merge(src proto.Message)

+ func (m *DownloadAction) XXX_Size() int

+ func (m *DownloadAction) XXX_Unmarshal(b []byte) error

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

+ func (this *DownloadAction) GoString() string

+ func (this *DownloadAction) String() string

+ type EmitProgressAction struct

+ Action *Action

+ FailureMessagePrefix string

+ LogSource string

+ StartMessage string

+ SuccessMessage string

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

+ func (*EmitProgressAction) Descriptor() ([]byte, []int)

+ func (*EmitProgressAction) ProtoMessage()

+ func (a *EmitProgressAction) ActionType() string

+ func (a EmitProgressAction) Validate() error

+ func (m *EmitProgressAction) GetAction() *Action

+ func (m *EmitProgressAction) GetFailureMessagePrefix() string

+ func (m *EmitProgressAction) GetLogSource() string

+ func (m *EmitProgressAction) GetStartMessage() string

+ func (m *EmitProgressAction) GetSuccessMessage() string

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

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

+ func (m *EmitProgressAction) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *EmitProgressAction) Reset()

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

+ func (m *EmitProgressAction) Unmarshal(dAtA []byte) error

+ func (m *EmitProgressAction) XXX_DiscardUnknown()

+ func (m *EmitProgressAction) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *EmitProgressAction) XXX_Merge(src proto.Message)

+ func (m *EmitProgressAction) XXX_Size() int

+ func (m *EmitProgressAction) XXX_Unmarshal(b []byte) error

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

+ func (this *EmitProgressAction) GoString() string

+ func (this *EmitProgressAction) String() string

+ type EnvironmentVariable struct

+ Name string

+ Value string

+ func (*EnvironmentVariable) Descriptor() ([]byte, []int)

+ func (*EnvironmentVariable) ProtoMessage()

+ func (envVar EnvironmentVariable) Validate() error

+ func (m *EnvironmentVariable) GetName() string

+ func (m *EnvironmentVariable) GetValue() string

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

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

+ func (m *EnvironmentVariable) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *EnvironmentVariable) Reset()

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

+ func (m *EnvironmentVariable) Unmarshal(dAtA []byte) error

+ func (m *EnvironmentVariable) XXX_DiscardUnknown()

+ func (m *EnvironmentVariable) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *EnvironmentVariable) XXX_Merge(src proto.Message)

+ func (m *EnvironmentVariable) XXX_Size() int

+ func (m *EnvironmentVariable) XXX_Unmarshal(b []byte) error

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

+ func (this *EnvironmentVariable) GoString() string

+ func (this *EnvironmentVariable) String() string

+ type ErrInvalidField struct

+ Field string

+ func (err ErrInvalidField) Error() string

+ type ErrInvalidModification struct

+ InvalidField string

+ func (err ErrInvalidModification) Error() string

+ type Error struct

+ Message string

+ Type Error_Type

+ func ConvertError(err error) *Error

+ func NewError(errType Error_Type, msg string) *Error

+ func NewRunningOnDifferentCellError(expectedCellId, actualCellId string) *Error

+ func NewTaskTransitionError(from, to Task_State) *Error

+ func NewUnrecoverableError(err error) *Error

+ func (*Error) Descriptor() ([]byte, []int)

+ func (*Error) ProtoMessage()

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

+ func (err *Error) Error() string

+ func (err *Error) ToError() error

+ func (m *Error) GetMessage() string

+ func (m *Error) GetType() Error_Type

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

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

+ func (m *Error) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Error) Reset()

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

+ func (m *Error) Unmarshal(dAtA []byte) error

+ func (m *Error) XXX_DiscardUnknown()

+ func (m *Error) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Error) XXX_Merge(src proto.Message)

+ func (m *Error) XXX_Size() int

+ func (m *Error) XXX_Unmarshal(b []byte) error

+ func (this *Error) GoString() string

+ func (this *Error) String() string

+ type Error_Type int32

+ const Error_ActualLRPCannotBeClaimed

+ const Error_ActualLRPCannotBeCrashed

+ const Error_ActualLRPCannotBeFailed

+ const Error_ActualLRPCannotBeRemoved

+ const Error_ActualLRPCannotBeStarted

+ const Error_ActualLRPCannotBeUnclaimed

+ const Error_Deadlock

+ const Error_Deserialize

+ const Error_FailedToOpenEnvelope

+ const Error_GUIDGeneration

+ const Error_InvalidJSON

+ const Error_InvalidProtobufMessage

+ const Error_InvalidRecord

+ const Error_InvalidRequest

+ const Error_InvalidResponse

+ const Error_InvalidStateTransition

+ const Error_LockCollision

+ const Error_ResourceConflict

+ const Error_ResourceExists

+ const Error_ResourceNotFound

+ const Error_RouterError

+ const Error_RunningOnDifferentCell

+ const Error_Timeout

+ const Error_UnknownError

+ const Error_Unrecoverable

+ func (Error_Type) EnumDescriptor() ([]byte, []int)

+ func (d *Error_Type) UnmarshalJSON(data []byte) error

+ func (d Error_Type) MarshalJSON() ([]byte, error)

+ func (x Error_Type) String() string

+ type EvacuateClaimedActualLRPRequest struct

+ ActualLrpInstanceKey *ActualLRPInstanceKey

+ ActualLrpKey *ActualLRPKey

+ func (*EvacuateClaimedActualLRPRequest) Descriptor() ([]byte, []int)

+ func (*EvacuateClaimedActualLRPRequest) ProtoMessage()

+ func (m *EvacuateClaimedActualLRPRequest) GetActualLrpInstanceKey() *ActualLRPInstanceKey

+ func (m *EvacuateClaimedActualLRPRequest) GetActualLrpKey() *ActualLRPKey

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

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

+ func (m *EvacuateClaimedActualLRPRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *EvacuateClaimedActualLRPRequest) Reset()

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

+ func (m *EvacuateClaimedActualLRPRequest) Unmarshal(dAtA []byte) error

+ func (m *EvacuateClaimedActualLRPRequest) XXX_DiscardUnknown()

+ func (m *EvacuateClaimedActualLRPRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *EvacuateClaimedActualLRPRequest) XXX_Merge(src proto.Message)

+ func (m *EvacuateClaimedActualLRPRequest) XXX_Size() int

+ func (m *EvacuateClaimedActualLRPRequest) XXX_Unmarshal(b []byte) error

+ func (request *EvacuateClaimedActualLRPRequest) Validate() error

+ func (this *EvacuateClaimedActualLRPRequest) GoString() string

+ func (this *EvacuateClaimedActualLRPRequest) String() string

+ type EvacuateCrashedActualLRPRequest struct

+ ActualLrpInstanceKey *ActualLRPInstanceKey

+ ActualLrpKey *ActualLRPKey

+ ErrorMessage string

+ func (*EvacuateCrashedActualLRPRequest) Descriptor() ([]byte, []int)

+ func (*EvacuateCrashedActualLRPRequest) ProtoMessage()

+ func (m *EvacuateCrashedActualLRPRequest) GetActualLrpInstanceKey() *ActualLRPInstanceKey

+ func (m *EvacuateCrashedActualLRPRequest) GetActualLrpKey() *ActualLRPKey

+ func (m *EvacuateCrashedActualLRPRequest) GetErrorMessage() string

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

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

+ func (m *EvacuateCrashedActualLRPRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *EvacuateCrashedActualLRPRequest) Reset()

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

+ func (m *EvacuateCrashedActualLRPRequest) Unmarshal(dAtA []byte) error

+ func (m *EvacuateCrashedActualLRPRequest) XXX_DiscardUnknown()

+ func (m *EvacuateCrashedActualLRPRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *EvacuateCrashedActualLRPRequest) XXX_Merge(src proto.Message)

+ func (m *EvacuateCrashedActualLRPRequest) XXX_Size() int

+ func (m *EvacuateCrashedActualLRPRequest) XXX_Unmarshal(b []byte) error

+ func (request *EvacuateCrashedActualLRPRequest) Validate() error

+ func (this *EvacuateCrashedActualLRPRequest) GoString() string

+ func (this *EvacuateCrashedActualLRPRequest) String() string

+ type EvacuateRunningActualLRPRequest struct

+ ActualLrpInstanceKey *ActualLRPInstanceKey

+ ActualLrpInternalRoutes []*ActualLRPInternalRoute

+ ActualLrpKey *ActualLRPKey

+ ActualLrpNetInfo *ActualLRPNetInfo

+ AvailabilityZone string

+ MetricTags map[string]string

+ OptionalRoutable isEvacuateRunningActualLRPRequest_OptionalRoutable

+ func (*EvacuateRunningActualLRPRequest) Descriptor() ([]byte, []int)

+ func (*EvacuateRunningActualLRPRequest) ProtoMessage()

+ func (*EvacuateRunningActualLRPRequest) XXX_OneofWrappers() []interface{}

+ func (m *EvacuateRunningActualLRPRequest) GetActualLrpInstanceKey() *ActualLRPInstanceKey

+ func (m *EvacuateRunningActualLRPRequest) GetActualLrpInternalRoutes() []*ActualLRPInternalRoute

+ func (m *EvacuateRunningActualLRPRequest) GetActualLrpKey() *ActualLRPKey

+ func (m *EvacuateRunningActualLRPRequest) GetActualLrpNetInfo() *ActualLRPNetInfo

+ func (m *EvacuateRunningActualLRPRequest) GetAvailabilityZone() string

+ func (m *EvacuateRunningActualLRPRequest) GetMetricTags() map[string]string

+ func (m *EvacuateRunningActualLRPRequest) GetOptionalRoutable() isEvacuateRunningActualLRPRequest_OptionalRoutable

+ func (m *EvacuateRunningActualLRPRequest) GetRoutable() bool

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

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

+ func (m *EvacuateRunningActualLRPRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *EvacuateRunningActualLRPRequest) Reset()

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

+ func (m *EvacuateRunningActualLRPRequest) Unmarshal(dAtA []byte) error

+ func (m *EvacuateRunningActualLRPRequest) XXX_DiscardUnknown()

+ func (m *EvacuateRunningActualLRPRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *EvacuateRunningActualLRPRequest) XXX_Merge(src proto.Message)

+ func (m *EvacuateRunningActualLRPRequest) XXX_Size() int

+ func (m *EvacuateRunningActualLRPRequest) XXX_Unmarshal(b []byte) error

+ func (request *EvacuateRunningActualLRPRequest) RoutableExists() bool

+ func (request *EvacuateRunningActualLRPRequest) SetRoutable(routable bool)

+ func (request *EvacuateRunningActualLRPRequest) Validate() error

+ func (this *EvacuateRunningActualLRPRequest) GoString() string

+ func (this *EvacuateRunningActualLRPRequest) String() string

+ type EvacuateRunningActualLRPRequest_Routable struct

+ Routable bool

+ func (m *EvacuateRunningActualLRPRequest_Routable) MarshalTo(dAtA []byte) (int, error)

+ func (m *EvacuateRunningActualLRPRequest_Routable) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *EvacuateRunningActualLRPRequest_Routable) Size() (n int)

+ func (this *EvacuateRunningActualLRPRequest_Routable) GoString() string

+ func (this *EvacuateRunningActualLRPRequest_Routable) String() string

+ type EvacuateStoppedActualLRPRequest struct

+ ActualLrpInstanceKey *ActualLRPInstanceKey

+ ActualLrpKey *ActualLRPKey

+ func (*EvacuateStoppedActualLRPRequest) Descriptor() ([]byte, []int)

+ func (*EvacuateStoppedActualLRPRequest) ProtoMessage()

+ func (m *EvacuateStoppedActualLRPRequest) GetActualLrpInstanceKey() *ActualLRPInstanceKey

+ func (m *EvacuateStoppedActualLRPRequest) GetActualLrpKey() *ActualLRPKey

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

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

+ func (m *EvacuateStoppedActualLRPRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *EvacuateStoppedActualLRPRequest) Reset()

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

+ func (m *EvacuateStoppedActualLRPRequest) Unmarshal(dAtA []byte) error

+ func (m *EvacuateStoppedActualLRPRequest) XXX_DiscardUnknown()

+ func (m *EvacuateStoppedActualLRPRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *EvacuateStoppedActualLRPRequest) XXX_Merge(src proto.Message)

+ func (m *EvacuateStoppedActualLRPRequest) XXX_Size() int

+ func (m *EvacuateStoppedActualLRPRequest) XXX_Unmarshal(b []byte) error

+ func (request *EvacuateStoppedActualLRPRequest) Validate() error

+ func (this *EvacuateStoppedActualLRPRequest) GoString() string

+ func (this *EvacuateStoppedActualLRPRequest) String() string

+ type EvacuationResponse struct

+ Error *Error

+ KeepContainer bool

+ func (*EvacuationResponse) Descriptor() ([]byte, []int)

+ func (*EvacuationResponse) ProtoMessage()

+ func (m *EvacuationResponse) GetError() *Error

+ func (m *EvacuationResponse) GetKeepContainer() bool

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

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

+ func (m *EvacuationResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *EvacuationResponse) Reset()

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

+ func (m *EvacuationResponse) Unmarshal(dAtA []byte) error

+ func (m *EvacuationResponse) XXX_DiscardUnknown()

+ func (m *EvacuationResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *EvacuationResponse) XXX_Merge(src proto.Message)

+ func (m *EvacuationResponse) XXX_Size() int

+ func (m *EvacuationResponse) XXX_Unmarshal(b []byte) error

+ func (this *EvacuationResponse) GoString() string

+ func (this *EvacuationResponse) String() string

+ type Event interface

+ EventType func() string

+ Key func() string

+ func VersionDesiredLRPsTo(event Event, target format.Version) Event

+ func VersionTaskDefinitionsTo(event Event, target format.Version) Event

+ type EventsByCellId struct

+ CellId string

+ func (*EventsByCellId) Descriptor() ([]byte, []int)

+ func (*EventsByCellId) ProtoMessage()

+ func (m *EventsByCellId) GetCellId() string

+ func (m *EventsByCellId) Marshal() (dAtA []byte, err error)

+ func (m *EventsByCellId) MarshalTo(dAtA []byte) (int, error)

+ func (m *EventsByCellId) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *EventsByCellId) Reset()

+ func (m *EventsByCellId) Size() (n int)

+ func (m *EventsByCellId) Unmarshal(dAtA []byte) error

+ func (m *EventsByCellId) XXX_DiscardUnknown()

+ func (m *EventsByCellId) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *EventsByCellId) XXX_Merge(src proto.Message)

+ func (m *EventsByCellId) XXX_Size() int

+ func (m *EventsByCellId) XXX_Unmarshal(b []byte) error

+ func (request *EventsByCellId) Validate() error

+ func (this *EventsByCellId) Equal(that interface{}) bool

+ func (this *EventsByCellId) GoString() string

+ func (this *EventsByCellId) String() string

+ type FailActualLRPRequest struct

+ ActualLrpKey *ActualLRPKey

+ ErrorMessage string

+ func (*FailActualLRPRequest) Descriptor() ([]byte, []int)

+ func (*FailActualLRPRequest) ProtoMessage()

+ func (m *FailActualLRPRequest) GetActualLrpKey() *ActualLRPKey

+ func (m *FailActualLRPRequest) GetErrorMessage() string

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

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

+ func (m *FailActualLRPRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *FailActualLRPRequest) Reset()

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

+ func (m *FailActualLRPRequest) Unmarshal(dAtA []byte) error

+ func (m *FailActualLRPRequest) XXX_DiscardUnknown()

+ func (m *FailActualLRPRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *FailActualLRPRequest) XXX_Merge(src proto.Message)

+ func (m *FailActualLRPRequest) XXX_Size() int

+ func (m *FailActualLRPRequest) XXX_Unmarshal(b []byte) error

+ func (request *FailActualLRPRequest) Validate() error

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

+ func (this *FailActualLRPRequest) GoString() string

+ func (this *FailActualLRPRequest) String() string

+ type FailTaskRequest struct

+ FailureReason string

+ TaskGuid string

+ func (*FailTaskRequest) Descriptor() ([]byte, []int)

+ func (*FailTaskRequest) ProtoMessage()

+ func (m *FailTaskRequest) GetFailureReason() string

+ func (m *FailTaskRequest) GetTaskGuid() string

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

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

+ func (m *FailTaskRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *FailTaskRequest) Reset()

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

+ func (m *FailTaskRequest) Unmarshal(dAtA []byte) error

+ func (m *FailTaskRequest) XXX_DiscardUnknown()

+ func (m *FailTaskRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *FailTaskRequest) XXX_Merge(src proto.Message)

+ func (m *FailTaskRequest) XXX_Size() int

+ func (m *FailTaskRequest) XXX_Unmarshal(b []byte) error

+ func (req *FailTaskRequest) Validate() error

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

+ func (this *FailTaskRequest) GoString() string

+ func (this *FailTaskRequest) String() string

+ type File struct

+ Content string

+ Path string

+ func (*File) Descriptor() ([]byte, []int)

+ func (*File) ProtoMessage()

+ func (m *File) GetContent() string

+ func (m *File) GetPath() string

+ func (m *File) Marshal() (dAtA []byte, err error)

+ func (m *File) MarshalTo(dAtA []byte) (int, error)

+ func (m *File) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *File) Reset()

+ func (m *File) Size() (n int)

+ func (m *File) Unmarshal(dAtA []byte) error

+ func (m *File) XXX_DiscardUnknown()

+ func (m *File) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *File) XXX_Merge(src proto.Message)

+ func (m *File) XXX_Size() int

+ func (m *File) XXX_Unmarshal(b []byte) error

+ func (this *File) Equal(that interface{}) bool

+ func (this *File) GoString() string

+ func (this *File) String() string

+ type FixedSetRootFSProvider struct

+ FixedSet StringSet

+ func NewFixedSetRootFSProvider(rootfses ...string) FixedSetRootFSProvider

+ func (FixedSetRootFSProvider) Type() RootFSProviderType

+ func (provider *FixedSetRootFSProvider) UnmarshalJSON(payload []byte) error

+ func (provider FixedSetRootFSProvider) MarshalJSON() ([]byte, error)

+ func (provider FixedSetRootFSProvider) Match(rootfs url.URL) bool

+ type HTTPCheck struct

+ IntervalMs uint64

+ Path string

+ Port uint32

+ RequestTimeoutMs uint64

+ func (*HTTPCheck) Descriptor() ([]byte, []int)

+ func (*HTTPCheck) ProtoMessage()

+ func (m *HTTPCheck) GetIntervalMs() uint64

+ func (m *HTTPCheck) GetPath() string

+ func (m *HTTPCheck) GetPort() uint32

+ func (m *HTTPCheck) GetRequestTimeoutMs() uint64

+ func (m *HTTPCheck) Marshal() (dAtA []byte, err error)

+ func (m *HTTPCheck) MarshalTo(dAtA []byte) (int, error)

+ func (m *HTTPCheck) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *HTTPCheck) Reset()

+ func (m *HTTPCheck) Size() (n int)

+ func (m *HTTPCheck) Unmarshal(dAtA []byte) error

+ func (m *HTTPCheck) XXX_DiscardUnknown()

+ func (m *HTTPCheck) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *HTTPCheck) XXX_Merge(src proto.Message)

+ func (m *HTTPCheck) XXX_Size() int

+ func (m *HTTPCheck) XXX_Unmarshal(b []byte) error

+ func (this *HTTPCheck) Equal(that interface{}) bool

+ func (this *HTTPCheck) GoString() string

+ func (this *HTTPCheck) String() string

+ type ICMPInfo struct

+ Code int32

+ Type int32

+ func (*ICMPInfo) Descriptor() ([]byte, []int)

+ func (*ICMPInfo) ProtoMessage()

+ func (m *ICMPInfo) GetCode() int32

+ func (m *ICMPInfo) GetType() int32

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

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

+ func (m *ICMPInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ICMPInfo) Reset()

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

+ func (m *ICMPInfo) Unmarshal(dAtA []byte) error

+ func (m *ICMPInfo) XXX_DiscardUnknown()

+ func (m *ICMPInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ICMPInfo) XXX_Merge(src proto.Message)

+ func (m *ICMPInfo) XXX_Size() int

+ func (m *ICMPInfo) XXX_Unmarshal(b []byte) error

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

+ func (this *ICMPInfo) GoString() string

+ func (this *ICMPInfo) String() string

+ type ImageLayer struct

+ DestinationPath string

+ DigestAlgorithm ImageLayer_DigestAlgorithm

+ DigestValue string

+ LayerType ImageLayer_Type

+ MediaType ImageLayer_MediaType

+ Name string

+ Url string

+ func (*ImageLayer) Descriptor() ([]byte, []int)

+ func (*ImageLayer) ProtoMessage()

+ func (l *ImageLayer) Validate() error

+ func (m *ImageLayer) GetDestinationPath() string

+ func (m *ImageLayer) GetDigestAlgorithm() ImageLayer_DigestAlgorithm

+ func (m *ImageLayer) GetDigestValue() string

+ func (m *ImageLayer) GetLayerType() ImageLayer_Type

+ func (m *ImageLayer) GetMediaType() ImageLayer_MediaType

+ func (m *ImageLayer) GetName() string

+ func (m *ImageLayer) GetUrl() string

+ func (m *ImageLayer) Marshal() (dAtA []byte, err error)

+ func (m *ImageLayer) MarshalTo(dAtA []byte) (int, error)

+ func (m *ImageLayer) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ImageLayer) Reset()

+ func (m *ImageLayer) Size() (n int)

+ func (m *ImageLayer) Unmarshal(dAtA []byte) error

+ func (m *ImageLayer) XXX_DiscardUnknown()

+ func (m *ImageLayer) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ImageLayer) XXX_Merge(src proto.Message)

+ func (m *ImageLayer) XXX_Size() int

+ func (m *ImageLayer) XXX_Unmarshal(b []byte) error

+ func (this *ImageLayer) Equal(that interface{}) bool

+ func (this *ImageLayer) GoString() string

+ func (this *ImageLayer) String() string

+ type ImageLayer_DigestAlgorithm int32

+ const DigestAlgorithmInvalid

+ const DigestAlgorithmSha256

+ const DigestAlgorithmSha512

+ func (ImageLayer_DigestAlgorithm) EnumDescriptor() ([]byte, []int)

+ func (d *ImageLayer_DigestAlgorithm) UnmarshalJSON(data []byte) error

+ func (d ImageLayer_DigestAlgorithm) MarshalJSON() ([]byte, error)

+ func (d ImageLayer_DigestAlgorithm) Valid() bool

+ func (x ImageLayer_DigestAlgorithm) String() string

+ type ImageLayer_MediaType int32

+ const MediaTypeInvalid

+ const MediaTypeTar

+ const MediaTypeTgz

+ const MediaTypeZip

+ func (ImageLayer_MediaType) EnumDescriptor() ([]byte, []int)

+ func (m *ImageLayer_MediaType) UnmarshalJSON(data []byte) error

+ func (m ImageLayer_MediaType) MarshalJSON() ([]byte, error)

+ func (m ImageLayer_MediaType) Valid() bool

+ func (x ImageLayer_MediaType) String() string

+ type ImageLayer_Type int32

+ const LayerTypeExclusive

+ const LayerTypeInvalid

+ const LayerTypeShared

+ func (ImageLayer_Type) EnumDescriptor() ([]byte, []int)

+ func (t *ImageLayer_Type) UnmarshalJSON(data []byte) error

+ func (t ImageLayer_Type) MarshalJSON() ([]byte, error)

+ func (t ImageLayer_Type) Valid() bool

+ func (x ImageLayer_Type) String() string

+ type ImageLayers []*ImageLayer

+ func (layers ImageLayers) FilterByType(layerType ImageLayer_Type) ImageLayers

+ func (layers ImageLayers) ToCachedDependencies() []*CachedDependency

+ func (layers ImageLayers) ToDownloadActions(legacyDownloadUser string, existingAction *Action) *Action

+ type InsufficientResourcesError struct

+ Problems map[string]struct{}

+ func (i InsufficientResourcesError) Error() string

+ type InternalRoute struct

+ Hostname string

+ type InternalRoutes []InternalRoute

+ func InternalRoutesFromRoutingInfo(routingInfo Routes) (InternalRoutes, error)

+ func (r InternalRoutes) Equal(other InternalRoutes) bool

+ func (r InternalRoutes) RoutingInfo() Routes

+ type LRPStartRequest struct

+ Domain string

+ Indices []int

+ ProcessGuid string

+ func NewLRPStartRequest(processGuid, domain string, indices []int, res Resource, ...) LRPStartRequest

+ func NewLRPStartRequestFromModel(d *DesiredLRP, indices ...int) LRPStartRequest

+ func NewLRPStartRequestFromSchedulingInfo(s *DesiredLRPSchedulingInfo, indices ...int) LRPStartRequest

+ func (lrpstart *LRPStartRequest) Validate() error

+ type LRPUpdate struct

+ InstanceGUID string

+ InternalRoutes InternalRoutes

+ MetricTags map[string]string

+ func NewLRPUpdate(instanceGUID string, key ActualLRPKey, internalRoutes InternalRoutes, ...) LRPUpdate

+ type LogConfig struct

+ Guid string

+ Index int

+ SourceName string

+ Tags map[string]string

+ func (l LogConfig) GetSourceNameAndTagsForLogging() (string, map[string]string)

+ type LogRateLimit struct

+ BytesPerSecond int64

+ func (*LogRateLimit) Descriptor() ([]byte, []int)

+ func (*LogRateLimit) ProtoMessage()

+ func (m *LogRateLimit) GetBytesPerSecond() int64

+ func (m *LogRateLimit) Marshal() (dAtA []byte, err error)

+ func (m *LogRateLimit) MarshalTo(dAtA []byte) (int, error)

+ func (m *LogRateLimit) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *LogRateLimit) Reset()

+ func (m *LogRateLimit) Size() (n int)

+ func (m *LogRateLimit) Unmarshal(dAtA []byte) error

+ func (m *LogRateLimit) XXX_DiscardUnknown()

+ func (m *LogRateLimit) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *LogRateLimit) XXX_Merge(src proto.Message)

+ func (m *LogRateLimit) XXX_Size() int

+ func (m *LogRateLimit) XXX_Unmarshal(b []byte) error

+ func (this *LogRateLimit) Equal(that interface{}) bool

+ func (this *LogRateLimit) GoString() string

+ func (this *LogRateLimit) String() string

+ type MetricTagValue struct

+ Dynamic MetricTagValue_DynamicValue

+ Static string

+ func (*MetricTagValue) Descriptor() ([]byte, []int)

+ func (*MetricTagValue) ProtoMessage()

+ func (m *MetricTagValue) GetDynamic() MetricTagValue_DynamicValue

+ func (m *MetricTagValue) GetStatic() string

+ func (m *MetricTagValue) Marshal() (dAtA []byte, err error)

+ func (m *MetricTagValue) MarshalTo(dAtA []byte) (int, error)

+ func (m *MetricTagValue) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *MetricTagValue) Reset()

+ func (m *MetricTagValue) Size() (n int)

+ func (m *MetricTagValue) Unmarshal(dAtA []byte) error

+ func (m *MetricTagValue) Validate() error

+ func (m *MetricTagValue) XXX_DiscardUnknown()

+ func (m *MetricTagValue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *MetricTagValue) XXX_Merge(src proto.Message)

+ func (m *MetricTagValue) XXX_Size() int

+ func (m *MetricTagValue) XXX_Unmarshal(b []byte) error

+ func (this *MetricTagValue) Equal(that interface{}) bool

+ func (this *MetricTagValue) GoString() string

+ func (this *MetricTagValue) String() string

+ type MetricTagValue_DynamicValue int32

+ const DynamicValueInvalid

+ const MetricTagDynamicValueIndex

+ const MetricTagDynamicValueInstanceGuid

+ func (MetricTagValue_DynamicValue) EnumDescriptor() ([]byte, []int)

+ func (v *MetricTagValue_DynamicValue) UnmarshalJSON(data []byte) error

+ func (v MetricTagValue_DynamicValue) MarshalJSON() ([]byte, error)

+ func (v MetricTagValue_DynamicValue) Valid() bool

+ func (x MetricTagValue_DynamicValue) String() string

+ type ModificationTag struct

+ Epoch string

+ Index uint32

+ func NewModificationTag(epoch string, index uint32) ModificationTag

+ func (*ModificationTag) Descriptor() ([]byte, []int)

+ func (*ModificationTag) ProtoMessage()

+ func (m *ModificationTag) GetEpoch() string

+ func (m *ModificationTag) GetIndex() uint32

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

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

+ func (m *ModificationTag) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ModificationTag) Reset()

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

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

+ func (m *ModificationTag) Unmarshal(dAtA []byte) error

+ func (m *ModificationTag) XXX_DiscardUnknown()

+ func (m *ModificationTag) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ModificationTag) XXX_Merge(src proto.Message)

+ func (m *ModificationTag) XXX_Size() int

+ func (m *ModificationTag) XXX_Unmarshal(b []byte) error

+ func (t *ModificationTag) Increment()

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

+ func (this *ModificationTag) GoString() string

+ func (this *ModificationTag) String() string

+ type Network struct

+ Properties map[string]string

+ func (*Network) Descriptor() ([]byte, []int)

+ func (*Network) ProtoMessage()

+ func (m *Network) GetProperties() map[string]string

+ func (m *Network) Marshal() (dAtA []byte, err error)

+ func (m *Network) MarshalTo(dAtA []byte) (int, error)

+ func (m *Network) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Network) Reset()

+ func (m *Network) Size() (n int)

+ func (m *Network) Unmarshal(dAtA []byte) error

+ func (m *Network) XXX_DiscardUnknown()

+ func (m *Network) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Network) XXX_Merge(src proto.Message)

+ func (m *Network) XXX_Size() int

+ func (m *Network) XXX_Unmarshal(b []byte) error

+ func (this *Network) Equal(that interface{}) bool

+ func (this *Network) GoString() string

+ func (this *Network) String() string

+ type ParallelAction struct

+ Actions []*Action

+ LogSource string

+ func Parallel(actions ...ActionInterface) *ParallelAction

+ func (*ParallelAction) Descriptor() ([]byte, []int)

+ func (*ParallelAction) ProtoMessage()

+ func (*ParallelAction) Version() format.Version

+ func (a *ParallelAction) ActionType() string

+ func (a ParallelAction) Validate() error

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

+ func (m *ParallelAction) GetLogSource() string

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

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

+ func (m *ParallelAction) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ParallelAction) Reset()

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

+ func (m *ParallelAction) Unmarshal(dAtA []byte) error

+ func (m *ParallelAction) XXX_DiscardUnknown()

+ func (m *ParallelAction) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ParallelAction) XXX_Merge(src proto.Message)

+ func (m *ParallelAction) XXX_Size() int

+ func (m *ParallelAction) XXX_Unmarshal(b []byte) error

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

+ func (this *ParallelAction) GoString() string

+ func (this *ParallelAction) String() string

+ type PingResponse struct

+ Available bool

+ func (*PingResponse) Descriptor() ([]byte, []int)

+ func (*PingResponse) ProtoMessage()

+ func (m *PingResponse) GetAvailable() bool

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

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

+ func (m *PingResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *PingResponse) Reset()

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

+ func (m *PingResponse) Unmarshal(dAtA []byte) error

+ func (m *PingResponse) XXX_DiscardUnknown()

+ func (m *PingResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *PingResponse) XXX_Merge(src proto.Message)

+ func (m *PingResponse) XXX_Size() int

+ func (m *PingResponse) XXX_Unmarshal(b []byte) error

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

+ func (this *PingResponse) GoString() string

+ func (this *PingResponse) String() string

+ type PlacementConstraint struct

+ PlacementTags []string

+ RootFs string

+ VolumeDrivers []string

+ func NewPlacementConstraint(rootFs string, placementTags, volumeDrivers []string) PlacementConstraint

+ func (p *PlacementConstraint) Valid() bool

+ type PortChecker interface

+ GetPort func() uint32

+ type PortMapping struct

+ ContainerPort uint32

+ ContainerTlsProxyPort uint32

+ HostPort uint32

+ HostTlsProxyPort uint32

+ func NewPortMapping(hostPort, containerPort uint32) *PortMapping

+ func NewPortMappingWithTLSProxy(hostPort, containerPort, tlsHost, tlsContainer uint32) *PortMapping

+ func (*PortMapping) Descriptor() ([]byte, []int)

+ func (*PortMapping) ProtoMessage()

+ func (m *PortMapping) GetContainerPort() uint32

+ func (m *PortMapping) GetContainerTlsProxyPort() uint32

+ func (m *PortMapping) GetHostPort() uint32

+ func (m *PortMapping) GetHostTlsProxyPort() uint32

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

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

+ func (m *PortMapping) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *PortMapping) Reset()

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

+ func (m *PortMapping) Unmarshal(dAtA []byte) error

+ func (m *PortMapping) XXX_DiscardUnknown()

+ func (m *PortMapping) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *PortMapping) XXX_Merge(src proto.Message)

+ func (m *PortMapping) XXX_Size() int

+ func (m *PortMapping) XXX_Unmarshal(b []byte) error

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

+ func (this *PortMapping) GoString() string

+ func (this *PortMapping) String() string

+ type PortRange struct

+ End uint32

+ Start uint32

+ func (*PortRange) Descriptor() ([]byte, []int)

+ func (*PortRange) ProtoMessage()

+ func (m *PortRange) GetEnd() uint32

+ func (m *PortRange) GetStart() uint32

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

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

+ func (m *PortRange) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *PortRange) Reset()

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

+ func (m *PortRange) Unmarshal(dAtA []byte) error

+ func (m *PortRange) XXX_DiscardUnknown()

+ func (m *PortRange) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *PortRange) XXX_Merge(src proto.Message)

+ func (m *PortRange) XXX_Size() int

+ func (m *PortRange) XXX_Unmarshal(b []byte) error

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

+ func (this *PortRange) GoString() string

+ func (this *PortRange) String() string

+ type ProtoRoutes struct

+ Routes map[string][]byte

+ func (*ProtoRoutes) Descriptor() ([]byte, []int)

+ func (*ProtoRoutes) ProtoMessage()

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

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

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

+ func (m *ProtoRoutes) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ProtoRoutes) Reset()

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

+ func (m *ProtoRoutes) Unmarshal(dAtA []byte) error

+ func (m *ProtoRoutes) XXX_DiscardUnknown()

+ func (m *ProtoRoutes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ProtoRoutes) XXX_Merge(src proto.Message)

+ func (m *ProtoRoutes) XXX_Size() int

+ func (m *ProtoRoutes) XXX_Unmarshal(b []byte) error

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

+ func (this *ProtoRoutes) GoString() string

+ func (this *ProtoRoutes) String() string

+ type Provider struct

+ Name string

+ Properties []string

+ func (*Provider) Descriptor() ([]byte, []int)

+ func (*Provider) ProtoMessage()

+ func (m *Provider) GetName() string

+ func (m *Provider) GetProperties() []string

+ func (m *Provider) Marshal() (dAtA []byte, err error)

+ func (m *Provider) MarshalTo(dAtA []byte) (int, error)

+ func (m *Provider) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Provider) Reset()

+ func (m *Provider) Size() (n int)

+ func (m *Provider) Unmarshal(dAtA []byte) error

+ func (m *Provider) XXX_DiscardUnknown()

+ func (m *Provider) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Provider) XXX_Merge(src proto.Message)

+ func (m *Provider) XXX_Size() int

+ func (m *Provider) XXX_Unmarshal(b []byte) error

+ func (this *Provider) Equal(that interface{}) bool

+ func (this *Provider) GoString() string

+ func (this *Provider) String() string

+ type RejectTaskRequest struct

+ RejectionReason string

+ TaskGuid string

+ func (*RejectTaskRequest) Descriptor() ([]byte, []int)

+ func (*RejectTaskRequest) ProtoMessage()

+ func (m *RejectTaskRequest) GetRejectionReason() string

+ func (m *RejectTaskRequest) GetTaskGuid() string

+ func (m *RejectTaskRequest) Marshal() (dAtA []byte, err error)

+ func (m *RejectTaskRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *RejectTaskRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *RejectTaskRequest) Reset()

+ func (m *RejectTaskRequest) Size() (n int)

+ func (m *RejectTaskRequest) Unmarshal(dAtA []byte) error

+ func (m *RejectTaskRequest) XXX_DiscardUnknown()

+ func (m *RejectTaskRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RejectTaskRequest) XXX_Merge(src proto.Message)

+ func (m *RejectTaskRequest) XXX_Size() int

+ func (m *RejectTaskRequest) XXX_Unmarshal(b []byte) error

+ func (req *RejectTaskRequest) Validate() error

+ func (this *RejectTaskRequest) Equal(that interface{}) bool

+ func (this *RejectTaskRequest) GoString() string

+ func (this *RejectTaskRequest) String() string

+ type RemoveActualLRPRequest struct

+ ActualLrpInstanceKey *ActualLRPInstanceKey

+ Index int32

+ ProcessGuid string

+ func (*RemoveActualLRPRequest) Descriptor() ([]byte, []int)

+ func (*RemoveActualLRPRequest) ProtoMessage()

+ func (m *RemoveActualLRPRequest) GetActualLrpInstanceKey() *ActualLRPInstanceKey

+ func (m *RemoveActualLRPRequest) GetIndex() int32

+ func (m *RemoveActualLRPRequest) GetProcessGuid() string

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

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

+ func (m *RemoveActualLRPRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *RemoveActualLRPRequest) Reset()

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

+ func (m *RemoveActualLRPRequest) Unmarshal(dAtA []byte) error

+ func (m *RemoveActualLRPRequest) XXX_DiscardUnknown()

+ func (m *RemoveActualLRPRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RemoveActualLRPRequest) XXX_Merge(src proto.Message)

+ func (m *RemoveActualLRPRequest) XXX_Size() int

+ func (m *RemoveActualLRPRequest) XXX_Unmarshal(b []byte) error

+ func (request *RemoveActualLRPRequest) Validate() error

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

+ func (this *RemoveActualLRPRequest) GoString() string

+ func (this *RemoveActualLRPRequest) String() string

+ type RemoveDesiredLRPRequest struct

+ ProcessGuid string

+ func (*RemoveDesiredLRPRequest) Descriptor() ([]byte, []int)

+ func (*RemoveDesiredLRPRequest) ProtoMessage()

+ func (m *RemoveDesiredLRPRequest) GetProcessGuid() string

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

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

+ func (m *RemoveDesiredLRPRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *RemoveDesiredLRPRequest) Reset()

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

+ func (m *RemoveDesiredLRPRequest) Unmarshal(dAtA []byte) error

+ func (m *RemoveDesiredLRPRequest) XXX_DiscardUnknown()

+ func (m *RemoveDesiredLRPRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RemoveDesiredLRPRequest) XXX_Merge(src proto.Message)

+ func (m *RemoveDesiredLRPRequest) XXX_Size() int

+ func (m *RemoveDesiredLRPRequest) XXX_Unmarshal(b []byte) error

+ func (request *RemoveDesiredLRPRequest) Validate() error

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

+ func (this *RemoveDesiredLRPRequest) GoString() string

+ func (this *RemoveDesiredLRPRequest) String() string

+ type RemoveEvacuatingActualLRPRequest struct

+ ActualLrpInstanceKey *ActualLRPInstanceKey

+ ActualLrpKey *ActualLRPKey

+ func (*RemoveEvacuatingActualLRPRequest) Descriptor() ([]byte, []int)

+ func (*RemoveEvacuatingActualLRPRequest) ProtoMessage()

+ func (m *RemoveEvacuatingActualLRPRequest) GetActualLrpInstanceKey() *ActualLRPInstanceKey

+ func (m *RemoveEvacuatingActualLRPRequest) GetActualLrpKey() *ActualLRPKey

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

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

+ func (m *RemoveEvacuatingActualLRPRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *RemoveEvacuatingActualLRPRequest) Reset()

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

+ func (m *RemoveEvacuatingActualLRPRequest) Unmarshal(dAtA []byte) error

+ func (m *RemoveEvacuatingActualLRPRequest) XXX_DiscardUnknown()

+ func (m *RemoveEvacuatingActualLRPRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RemoveEvacuatingActualLRPRequest) XXX_Merge(src proto.Message)

+ func (m *RemoveEvacuatingActualLRPRequest) XXX_Size() int

+ func (m *RemoveEvacuatingActualLRPRequest) XXX_Unmarshal(b []byte) error

+ func (request *RemoveEvacuatingActualLRPRequest) Validate() error

+ func (this *RemoveEvacuatingActualLRPRequest) GoString() string

+ func (this *RemoveEvacuatingActualLRPRequest) String() string

+ type RemoveEvacuatingActualLRPResponse struct

+ Error *Error

+ func (*RemoveEvacuatingActualLRPResponse) Descriptor() ([]byte, []int)

+ func (*RemoveEvacuatingActualLRPResponse) ProtoMessage()

+ func (m *RemoveEvacuatingActualLRPResponse) GetError() *Error

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

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

+ func (m *RemoveEvacuatingActualLRPResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *RemoveEvacuatingActualLRPResponse) Reset()

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

+ func (m *RemoveEvacuatingActualLRPResponse) Unmarshal(dAtA []byte) error

+ func (m *RemoveEvacuatingActualLRPResponse) XXX_DiscardUnknown()

+ func (m *RemoveEvacuatingActualLRPResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RemoveEvacuatingActualLRPResponse) XXX_Merge(src proto.Message)

+ func (m *RemoveEvacuatingActualLRPResponse) XXX_Size() int

+ func (m *RemoveEvacuatingActualLRPResponse) XXX_Unmarshal(b []byte) error

+ func (this *RemoveEvacuatingActualLRPResponse) GoString() string

+ func (this *RemoveEvacuatingActualLRPResponse) String() string

+ type RepClient interface

+ CancelTask func(logger lager.Logger, taskGuid string) error

+ Perform func(logger lager.Logger, work Work) (Work, error)

+ SetStateClient func(stateClient *http.Client)

+ State func(logger lager.Logger) (CellState, error)

+ StateClientTimeout func() time.Duration

+ StopLRPInstance func(logger lager.Logger, key ActualLRPKey, instanceKey ActualLRPInstanceKey) error

+ UpdateLRPInstance func(logger lager.Logger, update LRPUpdate) error

+ type RepClientFactory interface

+ CreateClient func(address, url, traceID string) (RepClient, error)

+ type RepSimClient interface

+ Reset func() error

+ type Resource struct

+ DiskMB int32

+ MaxPids int32

+ MemoryMB int32

+ func NewResource(memoryMb, diskMb int32, maxPids int32) Resource

+ func (r *Resource) Copy() Resource

+ func (r *Resource) Valid() bool

+ type ResourceLimits struct

+ OptionalNofile isResourceLimits_OptionalNofile

+ OptionalNproc isResourceLimits_OptionalNproc

+ func (*ResourceLimits) Descriptor() ([]byte, []int)

+ func (*ResourceLimits) ProtoMessage()

+ func (*ResourceLimits) XXX_OneofWrappers() []interface{}

+ func (l *ResourceLimits) NofileExists() bool

+ func (l *ResourceLimits) NprocExists() bool

+ func (l *ResourceLimits) SetNofile(nofile uint64)

+ func (l *ResourceLimits) SetNproc(nproc uint64)

+ func (l *ResourceLimits) UnmarshalJSON(data []byte) error

+ func (l ResourceLimits) MarshalJSON() ([]byte, error)

+ func (m *ResourceLimits) GetNofile() uint64

+ func (m *ResourceLimits) GetNofilePtr() *uint64

+ func (m *ResourceLimits) GetNproc() uint64

+ func (m *ResourceLimits) GetOptionalNofile() isResourceLimits_OptionalNofile

+ func (m *ResourceLimits) GetOptionalNproc() isResourceLimits_OptionalNproc

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

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

+ func (m *ResourceLimits) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ResourceLimits) Reset()

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

+ func (m *ResourceLimits) Unmarshal(dAtA []byte) error

+ func (m *ResourceLimits) XXX_DiscardUnknown()

+ func (m *ResourceLimits) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ResourceLimits) XXX_Merge(src proto.Message)

+ func (m *ResourceLimits) XXX_Size() int

+ func (m *ResourceLimits) XXX_Unmarshal(b []byte) error

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

+ func (this *ResourceLimits) GoString() string

+ func (this *ResourceLimits) String() string

+ type ResourceLimits_Nofile struct

+ Nofile uint64

+ func (m *ResourceLimits_Nofile) MarshalTo(dAtA []byte) (int, error)

+ func (m *ResourceLimits_Nofile) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ResourceLimits_Nofile) Size() (n int)

+ func (this *ResourceLimits_Nofile) Equal(that interface{}) bool

+ func (this *ResourceLimits_Nofile) GoString() string

+ func (this *ResourceLimits_Nofile) String() string

+ type ResourceLimits_Nproc struct

+ Nproc uint64

+ func (m *ResourceLimits_Nproc) MarshalTo(dAtA []byte) (int, error)

+ func (m *ResourceLimits_Nproc) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ResourceLimits_Nproc) Size() (n int)

+ func (this *ResourceLimits_Nproc) Equal(that interface{}) bool

+ func (this *ResourceLimits_Nproc) GoString() string

+ func (this *ResourceLimits_Nproc) String() string

+ type Resources struct

+ Containers int

+ DiskMB int32

+ MemoryMB int32

+ func NewResources(memoryMb, diskMb int32, containerCount int) Resources

+ func (r *Resources) ComputeScore(total *Resources) float64

+ func (r *Resources) Copy() Resources

+ func (r *Resources) Subtract(res *Resource)

+ type RestartCalculator struct

+ ImmediateRestarts int32

+ MaxBackoffCount int32

+ MaxBackoffDuration time.Duration

+ MaxRestartAttempts int32

+ func NewDefaultRestartCalculator() RestartCalculator

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

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

+ func (r RestartCalculator) Validate() error

+ type RetireActualLRPRequest struct

+ ActualLrpKey *ActualLRPKey

+ func (*RetireActualLRPRequest) Descriptor() ([]byte, []int)

+ func (*RetireActualLRPRequest) ProtoMessage()

+ func (m *RetireActualLRPRequest) GetActualLrpKey() *ActualLRPKey

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

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

+ func (m *RetireActualLRPRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *RetireActualLRPRequest) Reset()

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

+ func (m *RetireActualLRPRequest) Unmarshal(dAtA []byte) error

+ func (m *RetireActualLRPRequest) XXX_DiscardUnknown()

+ func (m *RetireActualLRPRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RetireActualLRPRequest) XXX_Merge(src proto.Message)

+ func (m *RetireActualLRPRequest) XXX_Size() int

+ func (m *RetireActualLRPRequest) XXX_Unmarshal(b []byte) error

+ func (request *RetireActualLRPRequest) Validate() error

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

+ func (this *RetireActualLRPRequest) GoString() string

+ func (this *RetireActualLRPRequest) String() string

+ type RootFSProvider interface

+ Match func(url.URL) bool

+ Type func() RootFSProviderType

+ type RootFSProviderType string

+ const RootFSProviderTypeArbitrary

+ const RootFSProviderTypeFixedSet

+ type RootFSProviders map[string]RootFSProvider

+ func (p RootFSProviders) Copy() RootFSProviders

+ func (p RootFSProviders) Match(rootFS url.URL) bool

+ func (providers *RootFSProviders) UnmarshalJSON(payload []byte) error

+ type Routes map[string]*json.RawMessage

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

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

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

+ func (r *Routes) Size() int

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

+ func (r Routes) Validate() error

+ type RunAction struct

+ Args []string

+ Dir string

+ Env []*EnvironmentVariable

+ LogSource string

+ Path string

+ ResourceLimits *ResourceLimits

+ SuppressLogOutput bool

+ User string

+ VolumeMountedFiles []*File

+ func (*RunAction) Descriptor() ([]byte, []int)

+ func (*RunAction) ProtoMessage()

+ func (a *RunAction) ActionType() string

+ func (a RunAction) Validate() error

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

+ func (m *RunAction) GetDir() string

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

+ func (m *RunAction) GetLogSource() string

+ func (m *RunAction) GetPath() string

+ func (m *RunAction) GetResourceLimits() *ResourceLimits

+ func (m *RunAction) GetSuppressLogOutput() bool

+ func (m *RunAction) GetUser() string

+ func (m *RunAction) GetVolumeMountedFiles() []*File

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

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

+ func (m *RunAction) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *RunAction) Reset()

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

+ func (m *RunAction) Unmarshal(dAtA []byte) error

+ func (m *RunAction) XXX_DiscardUnknown()

+ func (m *RunAction) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RunAction) XXX_Merge(src proto.Message)

+ func (m *RunAction) XXX_Size() int

+ func (m *RunAction) XXX_Unmarshal(b []byte) error

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

+ func (this *RunAction) GoString() string

+ func (this *RunAction) String() string

+ type SchedulingLRP struct

+ InstanceGUID string

+ State string

+ func NewSchedulingLRP(instanceGUID string, key ActualLRPKey, res Resource, pc PlacementConstraint) SchedulingLRP

+ func (lrp *SchedulingLRP) Copy() SchedulingLRP

+ func (lrp *SchedulingLRP) Identifier() string

+ type SchedulingTask struct

+ Domain string

+ Failed bool

+ State Task_State

+ TaskGuid string

+ func NewSchedulingTask(guid string, domain string, res Resource, pc PlacementConstraint) SchedulingTask

+ func (task *SchedulingTask) Identifier() string

+ func (task SchedulingTask) Copy() SchedulingTask

+ type SecurityGroupRule struct

+ Annotations []string

+ Destinations []string

+ IcmpInfo *ICMPInfo

+ Log bool

+ PortRange *PortRange

+ Ports []uint32

+ Protocol string

+ func (*SecurityGroupRule) Descriptor() ([]byte, []int)

+ func (*SecurityGroupRule) ProtoMessage()

+ func (m *SecurityGroupRule) GetAnnotations() []string

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

+ func (m *SecurityGroupRule) GetIcmpInfo() *ICMPInfo

+ func (m *SecurityGroupRule) GetLog() bool

+ func (m *SecurityGroupRule) GetPortRange() *PortRange

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

+ func (m *SecurityGroupRule) GetProtocol() string

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

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

+ func (m *SecurityGroupRule) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *SecurityGroupRule) Reset()

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

+ func (m *SecurityGroupRule) Unmarshal(dAtA []byte) error

+ func (m *SecurityGroupRule) XXX_DiscardUnknown()

+ func (m *SecurityGroupRule) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *SecurityGroupRule) XXX_Merge(src proto.Message)

+ func (m *SecurityGroupRule) XXX_Size() int

+ func (m *SecurityGroupRule) XXX_Unmarshal(b []byte) error

+ func (rule SecurityGroupRule) Validate() error

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

+ func (this *SecurityGroupRule) GoString() string

+ func (this *SecurityGroupRule) String() string

+ type SerialAction struct

+ Actions []*Action

+ LogSource string

+ func Serial(actions ...ActionInterface) *SerialAction

+ func (*SerialAction) Descriptor() ([]byte, []int)

+ func (*SerialAction) ProtoMessage()

+ func (a *SerialAction) ActionType() string

+ func (a SerialAction) Validate() error

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

+ func (m *SerialAction) GetLogSource() string

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

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

+ func (m *SerialAction) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *SerialAction) Reset()

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

+ func (m *SerialAction) Unmarshal(dAtA []byte) error

+ func (m *SerialAction) XXX_DiscardUnknown()

+ func (m *SerialAction) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *SerialAction) XXX_Merge(src proto.Message)

+ func (m *SerialAction) XXX_Size() int

+ func (m *SerialAction) XXX_Unmarshal(b []byte) error

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

+ func (this *SerialAction) GoString() string

+ func (this *SerialAction) String() string

+ type SharedDevice struct

+ MountConfig string

+ VolumeId string

+ func (*SharedDevice) Descriptor() ([]byte, []int)

+ func (*SharedDevice) ProtoMessage()

+ func (m *SharedDevice) GetMountConfig() string

+ func (m *SharedDevice) GetVolumeId() string

+ func (m *SharedDevice) Marshal() (dAtA []byte, err error)

+ func (m *SharedDevice) MarshalTo(dAtA []byte) (int, error)

+ func (m *SharedDevice) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *SharedDevice) Reset()

+ func (m *SharedDevice) Size() (n int)

+ func (m *SharedDevice) Unmarshal(dAtA []byte) error

+ func (m *SharedDevice) XXX_DiscardUnknown()

+ func (m *SharedDevice) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *SharedDevice) XXX_Merge(src proto.Message)

+ func (m *SharedDevice) XXX_Size() int

+ func (m *SharedDevice) XXX_Unmarshal(b []byte) error

+ func (this *SharedDevice) Equal(that interface{}) bool

+ func (this *SharedDevice) GoString() string

+ func (this *SharedDevice) String() string

+ type Sidecar struct

+ Action *Action

+ DiskMb int32

+ MemoryMb int32

+ func (*Sidecar) Descriptor() ([]byte, []int)

+ func (*Sidecar) ProtoMessage()

+ func (m *Sidecar) GetAction() *Action

+ func (m *Sidecar) GetDiskMb() int32

+ func (m *Sidecar) GetMemoryMb() int32

+ func (m *Sidecar) Marshal() (dAtA []byte, err error)

+ func (m *Sidecar) MarshalTo(dAtA []byte) (int, error)

+ func (m *Sidecar) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Sidecar) Reset()

+ func (m *Sidecar) Size() (n int)

+ func (m *Sidecar) Unmarshal(dAtA []byte) error

+ func (m *Sidecar) XXX_DiscardUnknown()

+ func (m *Sidecar) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Sidecar) XXX_Merge(src proto.Message)

+ func (m *Sidecar) XXX_Size() int

+ func (m *Sidecar) XXX_Unmarshal(b []byte) error

+ func (s Sidecar) Validate() error

+ func (this *Sidecar) Equal(that interface{}) bool

+ func (this *Sidecar) GoString() string

+ func (this *Sidecar) String() string

+ type StartActualLRPRequest struct

+ ActualLrpInstanceKey *ActualLRPInstanceKey

+ ActualLrpInternalRoutes []*ActualLRPInternalRoute

+ ActualLrpKey *ActualLRPKey

+ ActualLrpNetInfo *ActualLRPNetInfo

+ AvailabilityZone string

+ MetricTags map[string]string

+ OptionalRoutable isStartActualLRPRequest_OptionalRoutable

+ func (*StartActualLRPRequest) Descriptor() ([]byte, []int)

+ func (*StartActualLRPRequest) ProtoMessage()

+ func (*StartActualLRPRequest) XXX_OneofWrappers() []interface{}

+ func (m *StartActualLRPRequest) GetActualLrpInstanceKey() *ActualLRPInstanceKey

+ func (m *StartActualLRPRequest) GetActualLrpInternalRoutes() []*ActualLRPInternalRoute

+ func (m *StartActualLRPRequest) GetActualLrpKey() *ActualLRPKey

+ func (m *StartActualLRPRequest) GetActualLrpNetInfo() *ActualLRPNetInfo

+ func (m *StartActualLRPRequest) GetAvailabilityZone() string

+ func (m *StartActualLRPRequest) GetMetricTags() map[string]string

+ func (m *StartActualLRPRequest) GetOptionalRoutable() isStartActualLRPRequest_OptionalRoutable

+ func (m *StartActualLRPRequest) GetRoutable() bool

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

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

+ func (m *StartActualLRPRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *StartActualLRPRequest) Reset()

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

+ func (m *StartActualLRPRequest) Unmarshal(dAtA []byte) error

+ func (m *StartActualLRPRequest) XXX_DiscardUnknown()

+ func (m *StartActualLRPRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *StartActualLRPRequest) XXX_Merge(src proto.Message)

+ func (m *StartActualLRPRequest) XXX_Size() int

+ func (m *StartActualLRPRequest) XXX_Unmarshal(b []byte) error

+ func (request *StartActualLRPRequest) RoutableExists() bool

+ func (request *StartActualLRPRequest) SetRoutable(routable bool)

+ func (request *StartActualLRPRequest) Validate() error

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

+ func (this *StartActualLRPRequest) GoString() string

+ func (this *StartActualLRPRequest) String() string

+ type StartActualLRPRequest_Routable struct

+ Routable bool

+ func (m *StartActualLRPRequest_Routable) MarshalTo(dAtA []byte) (int, error)

+ func (m *StartActualLRPRequest_Routable) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *StartActualLRPRequest_Routable) Size() (n int)

+ func (this *StartActualLRPRequest_Routable) Equal(that interface{}) bool

+ func (this *StartActualLRPRequest_Routable) GoString() string

+ func (this *StartActualLRPRequest_Routable) String() string

+ type StartTaskRequest struct

+ CellId string

+ TaskGuid string

+ func (*StartTaskRequest) Descriptor() ([]byte, []int)

+ func (*StartTaskRequest) ProtoMessage()

+ func (m *StartTaskRequest) GetCellId() string

+ func (m *StartTaskRequest) GetTaskGuid() string

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

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

+ func (m *StartTaskRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *StartTaskRequest) Reset()

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

+ func (m *StartTaskRequest) Unmarshal(dAtA []byte) error

+ func (m *StartTaskRequest) XXX_DiscardUnknown()

+ func (m *StartTaskRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *StartTaskRequest) XXX_Merge(src proto.Message)

+ func (m *StartTaskRequest) XXX_Size() int

+ func (m *StartTaskRequest) XXX_Unmarshal(b []byte) error

+ func (req *StartTaskRequest) Validate() error

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

+ func (this *StartTaskRequest) GoString() string

+ func (this *StartTaskRequest) String() string

+ type StartTaskResponse struct

+ Error *Error

+ ShouldStart bool

+ func (*StartTaskResponse) Descriptor() ([]byte, []int)

+ func (*StartTaskResponse) ProtoMessage()

+ func (m *StartTaskResponse) GetError() *Error

+ func (m *StartTaskResponse) GetShouldStart() bool

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

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

+ func (m *StartTaskResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *StartTaskResponse) Reset()

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

+ func (m *StartTaskResponse) Unmarshal(dAtA []byte) error

+ func (m *StartTaskResponse) XXX_DiscardUnknown()

+ func (m *StartTaskResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *StartTaskResponse) XXX_Merge(src proto.Message)

+ func (m *StartTaskResponse) XXX_Size() int

+ func (m *StartTaskResponse) XXX_Unmarshal(b []byte) error

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

+ func (this *StartTaskResponse) GoString() string

+ func (this *StartTaskResponse) String() string

+ type StringSet map[string]struct

+ func NewStringSet(entries ...string) StringSet

+ func (set StringSet) Contains(candidate string) bool

+ type TCPCheck struct

+ ConnectTimeoutMs uint64

+ IntervalMs uint64

+ Port uint32

+ func (*TCPCheck) Descriptor() ([]byte, []int)

+ func (*TCPCheck) ProtoMessage()

+ func (m *TCPCheck) GetConnectTimeoutMs() uint64

+ func (m *TCPCheck) GetIntervalMs() uint64

+ func (m *TCPCheck) GetPort() uint32

+ func (m *TCPCheck) Marshal() (dAtA []byte, err error)

+ func (m *TCPCheck) MarshalTo(dAtA []byte) (int, error)

+ func (m *TCPCheck) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *TCPCheck) Reset()

+ func (m *TCPCheck) Size() (n int)

+ func (m *TCPCheck) Unmarshal(dAtA []byte) error

+ func (m *TCPCheck) XXX_DiscardUnknown()

+ func (m *TCPCheck) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TCPCheck) XXX_Merge(src proto.Message)

+ func (m *TCPCheck) XXX_Size() int

+ func (m *TCPCheck) XXX_Unmarshal(b []byte) error

+ func (this *TCPCheck) Equal(that interface{}) bool

+ func (this *TCPCheck) GoString() string

+ func (this *TCPCheck) String() string

+ type Task struct

+ CellId string

+ CreatedAt int64

+ Domain string

+ Failed bool

+ FailureReason string

+ FirstCompletedAt int64

+ RejectionCount int32

+ RejectionReason string

+ Result string

+ State Task_State

+ TaskGuid string

+ UpdatedAt int64

+ func (*Task) Descriptor() ([]byte, []int)

+ func (*Task) ProtoMessage()

+ func (m *Task) GetCellId() string

+ func (m *Task) GetCreatedAt() int64

+ func (m *Task) GetDomain() string

+ func (m *Task) GetFailed() bool

+ func (m *Task) GetFailureReason() string

+ func (m *Task) GetFirstCompletedAt() int64

+ func (m *Task) GetRejectionCount() int32

+ func (m *Task) GetRejectionReason() string

+ func (m *Task) GetResult() string

+ func (m *Task) GetState() Task_State

+ func (m *Task) GetTaskGuid() string

+ func (m *Task) GetUpdatedAt() int64

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

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

+ func (m *Task) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Task) Reset()

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

+ func (m *Task) Unmarshal(dAtA []byte) error

+ func (m *Task) XXX_DiscardUnknown()

+ func (m *Task) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Task) XXX_Merge(src proto.Message)

+ func (m *Task) XXX_Size() int

+ func (m *Task) XXX_Unmarshal(b []byte) error

+ func (t *Task) Copy() *Task

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

+ func (t *Task) ValidateTransitionTo(to Task_State) error

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

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

+ func (task *Task) Validate() error

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

+ func (this *Task) GoString() string

+ func (this *Task) String() string

+ type TaskByGuidRequest struct

+ TaskGuid string

+ func (*TaskByGuidRequest) Descriptor() ([]byte, []int)

+ func (*TaskByGuidRequest) ProtoMessage()

+ func (m *TaskByGuidRequest) GetTaskGuid() string

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

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

+ func (m *TaskByGuidRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *TaskByGuidRequest) Reset()

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

+ func (m *TaskByGuidRequest) Unmarshal(dAtA []byte) error

+ func (m *TaskByGuidRequest) XXX_DiscardUnknown()

+ func (m *TaskByGuidRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TaskByGuidRequest) XXX_Merge(src proto.Message)

+ func (m *TaskByGuidRequest) XXX_Size() int

+ func (m *TaskByGuidRequest) XXX_Unmarshal(b []byte) error

+ func (request *TaskByGuidRequest) Validate() error

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

+ func (this *TaskByGuidRequest) GoString() string

+ func (this *TaskByGuidRequest) String() string

+ type TaskCallbackResponse struct

+ Annotation string

+ CreatedAt int64

+ Failed bool

+ FailureReason string

+ Result string

+ TaskGuid string

+ func (*TaskCallbackResponse) Descriptor() ([]byte, []int)

+ func (*TaskCallbackResponse) ProtoMessage()

+ func (m *TaskCallbackResponse) GetAnnotation() string

+ func (m *TaskCallbackResponse) GetCreatedAt() int64

+ func (m *TaskCallbackResponse) GetFailed() bool

+ func (m *TaskCallbackResponse) GetFailureReason() string

+ func (m *TaskCallbackResponse) GetResult() string

+ func (m *TaskCallbackResponse) GetTaskGuid() string

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

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

+ func (m *TaskCallbackResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *TaskCallbackResponse) Reset()

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

+ func (m *TaskCallbackResponse) Unmarshal(dAtA []byte) error

+ func (m *TaskCallbackResponse) XXX_DiscardUnknown()

+ func (m *TaskCallbackResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TaskCallbackResponse) XXX_Merge(src proto.Message)

+ func (m *TaskCallbackResponse) XXX_Size() int

+ func (m *TaskCallbackResponse) XXX_Unmarshal(b []byte) error

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

+ func (this *TaskCallbackResponse) GoString() string

+ func (this *TaskCallbackResponse) String() string

+ type TaskChange struct

+ After *Task

+ Before *Task

+ type TaskChangedEvent struct

+ After *Task

+ Before *Task

+ func NewTaskChangedEvent(before, after *Task) *TaskChangedEvent

+ func (*TaskChangedEvent) Descriptor() ([]byte, []int)

+ func (*TaskChangedEvent) ProtoMessage()

+ func (event *TaskChangedEvent) EventType() string

+ func (event *TaskChangedEvent) Key() string

+ func (m *TaskChangedEvent) GetAfter() *Task

+ func (m *TaskChangedEvent) GetBefore() *Task

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

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

+ func (m *TaskChangedEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *TaskChangedEvent) Reset()

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

+ func (m *TaskChangedEvent) Unmarshal(dAtA []byte) error

+ func (m *TaskChangedEvent) XXX_DiscardUnknown()

+ func (m *TaskChangedEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TaskChangedEvent) XXX_Merge(src proto.Message)

+ func (m *TaskChangedEvent) XXX_Size() int

+ func (m *TaskChangedEvent) XXX_Unmarshal(b []byte) error

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

+ func (this *TaskChangedEvent) GoString() string

+ func (this *TaskChangedEvent) String() string

+ type TaskCreatedEvent struct

+ Task *Task

+ func NewTaskCreatedEvent(task *Task) *TaskCreatedEvent

+ func (*TaskCreatedEvent) Descriptor() ([]byte, []int)

+ func (*TaskCreatedEvent) ProtoMessage()

+ func (event *TaskCreatedEvent) EventType() string

+ func (event *TaskCreatedEvent) Key() string

+ func (m *TaskCreatedEvent) GetTask() *Task

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

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

+ func (m *TaskCreatedEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *TaskCreatedEvent) Reset()

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

+ func (m *TaskCreatedEvent) Unmarshal(dAtA []byte) error

+ func (m *TaskCreatedEvent) XXX_DiscardUnknown()

+ func (m *TaskCreatedEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TaskCreatedEvent) XXX_Merge(src proto.Message)

+ func (m *TaskCreatedEvent) XXX_Size() int

+ func (m *TaskCreatedEvent) XXX_Unmarshal(b []byte) error

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

+ func (this *TaskCreatedEvent) GoString() string

+ func (this *TaskCreatedEvent) String() string

+ type TaskDefinition struct

+ Action *Action

+ Annotation string

+ CachedDependencies []*CachedDependency

+ CertificateProperties *CertificateProperties

+ CompletionCallbackUrl string

+ CpuWeight uint32

+ DiskMb int32

+ EgressRules []*SecurityGroupRule

+ EnvironmentVariables []*EnvironmentVariable

+ ImageLayers []*ImageLayer

+ ImagePassword string

+ ImageUsername string

+ LegacyDownloadUser string

+ LogGuid string

+ LogRateLimit *LogRateLimit

+ LogSource string

+ MaxPids int32

+ MemoryMb int32

+ MetricTags map[string]*MetricTagValue

+ MetricsGuid string

+ Network *Network

+ PlacementTags []string

+ Privileged bool

+ ResultFile string

+ RootFs string

+ TrustedSystemCertificatesPath string

+ VolumeMountedFiles []*File

+ VolumeMounts []*VolumeMount

+ func (*TaskDefinition) Descriptor() ([]byte, []int)

+ func (*TaskDefinition) ProtoMessage()

+ func (def *TaskDefinition) Validate() error

+ func (m *TaskDefinition) GetAction() *Action

+ func (m *TaskDefinition) GetAnnotation() string

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

+ func (m *TaskDefinition) GetCertificateProperties() *CertificateProperties

+ func (m *TaskDefinition) GetCompletionCallbackUrl() string

+ func (m *TaskDefinition) GetCpuWeight() uint32

+ func (m *TaskDefinition) GetDiskMb() int32

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

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

+ func (m *TaskDefinition) GetImageLayers() []*ImageLayer

+ func (m *TaskDefinition) GetImagePassword() string

+ func (m *TaskDefinition) GetImageUsername() string

+ func (m *TaskDefinition) GetLegacyDownloadUser() string

+ func (m *TaskDefinition) GetLogGuid() string

+ func (m *TaskDefinition) GetLogRateLimit() *LogRateLimit

+ func (m *TaskDefinition) GetLogSource() string

+ func (m *TaskDefinition) GetMaxPids() int32

+ func (m *TaskDefinition) GetMemoryMb() int32

+ func (m *TaskDefinition) GetMetricTags() map[string]*MetricTagValue

+ func (m *TaskDefinition) GetMetricsGuid() string

+ func (m *TaskDefinition) GetNetwork() *Network

+ func (m *TaskDefinition) GetPlacementTags() []string

+ func (m *TaskDefinition) GetPrivileged() bool

+ func (m *TaskDefinition) GetResultFile() string

+ func (m *TaskDefinition) GetRootFs() string

+ func (m *TaskDefinition) GetTrustedSystemCertificatesPath() string

+ func (m *TaskDefinition) GetVolumeMountedFiles() []*File

+ func (m *TaskDefinition) GetVolumeMounts() []*VolumeMount

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

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

+ func (m *TaskDefinition) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *TaskDefinition) Reset()

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

+ func (m *TaskDefinition) Unmarshal(dAtA []byte) error

+ func (m *TaskDefinition) XXX_DiscardUnknown()

+ func (m *TaskDefinition) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TaskDefinition) XXX_Merge(src proto.Message)

+ func (m *TaskDefinition) XXX_Size() int

+ func (m *TaskDefinition) XXX_Unmarshal(b []byte) error

+ func (t *TaskDefinition) Copy() *TaskDefinition

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

+ func (this *TaskDefinition) GoString() string

+ func (this *TaskDefinition) String() string

+ type TaskFilter struct

+ CellID string

+ Domain string

+ type TaskGuidRequest struct

+ TaskGuid string

+ func (*TaskGuidRequest) Descriptor() ([]byte, []int)

+ func (*TaskGuidRequest) ProtoMessage()

+ func (m *TaskGuidRequest) GetTaskGuid() string

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

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

+ func (m *TaskGuidRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *TaskGuidRequest) Reset()

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

+ func (m *TaskGuidRequest) Unmarshal(dAtA []byte) error

+ func (m *TaskGuidRequest) XXX_DiscardUnknown()

+ func (m *TaskGuidRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TaskGuidRequest) XXX_Merge(src proto.Message)

+ func (m *TaskGuidRequest) XXX_Size() int

+ func (m *TaskGuidRequest) XXX_Unmarshal(b []byte) error

+ func (request *TaskGuidRequest) Validate() error

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

+ func (this *TaskGuidRequest) GoString() string

+ func (this *TaskGuidRequest) String() string

+ type TaskLifecycleResponse struct

+ Error *Error

+ func (*TaskLifecycleResponse) Descriptor() ([]byte, []int)

+ func (*TaskLifecycleResponse) ProtoMessage()

+ func (m *TaskLifecycleResponse) GetError() *Error

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

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

+ func (m *TaskLifecycleResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *TaskLifecycleResponse) Reset()

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

+ func (m *TaskLifecycleResponse) Unmarshal(dAtA []byte) error

+ func (m *TaskLifecycleResponse) XXX_DiscardUnknown()

+ func (m *TaskLifecycleResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TaskLifecycleResponse) XXX_Merge(src proto.Message)

+ func (m *TaskLifecycleResponse) XXX_Size() int

+ func (m *TaskLifecycleResponse) XXX_Unmarshal(b []byte) error

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

+ func (this *TaskLifecycleResponse) GoString() string

+ func (this *TaskLifecycleResponse) String() string

+ type TaskRemovedEvent struct

+ Task *Task

+ func NewTaskRemovedEvent(task *Task) *TaskRemovedEvent

+ func (*TaskRemovedEvent) Descriptor() ([]byte, []int)

+ func (*TaskRemovedEvent) ProtoMessage()

+ func (event *TaskRemovedEvent) EventType() string

+ func (event TaskRemovedEvent) Key() string

+ func (m *TaskRemovedEvent) GetTask() *Task

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

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

+ func (m *TaskRemovedEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *TaskRemovedEvent) Reset()

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

+ func (m *TaskRemovedEvent) Unmarshal(dAtA []byte) error

+ func (m *TaskRemovedEvent) XXX_DiscardUnknown()

+ func (m *TaskRemovedEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TaskRemovedEvent) XXX_Merge(src proto.Message)

+ func (m *TaskRemovedEvent) XXX_Size() int

+ func (m *TaskRemovedEvent) XXX_Unmarshal(b []byte) error

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

+ func (this *TaskRemovedEvent) GoString() string

+ func (this *TaskRemovedEvent) String() string

+ type TaskResponse struct

+ Error *Error

+ Task *Task

+ func (*TaskResponse) Descriptor() ([]byte, []int)

+ func (*TaskResponse) ProtoMessage()

+ func (m *TaskResponse) GetError() *Error

+ func (m *TaskResponse) GetTask() *Task

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

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

+ func (m *TaskResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *TaskResponse) Reset()

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

+ func (m *TaskResponse) Unmarshal(dAtA []byte) error

+ func (m *TaskResponse) XXX_DiscardUnknown()

+ func (m *TaskResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TaskResponse) XXX_Merge(src proto.Message)

+ func (m *TaskResponse) XXX_Size() int

+ func (m *TaskResponse) XXX_Unmarshal(b []byte) error

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

+ func (this *TaskResponse) GoString() string

+ func (this *TaskResponse) String() string

+ type TaskStartRequest struct

+ Task SchedulingTask

+ func NewTaskStartRequest(task SchedulingTask) TaskStartRequest

+ func NewTaskStartRequestFromModel(taskGuid, domain string, taskDef *TaskDefinition) TaskStartRequest

+ func (t *TaskStartRequest) Validate() error

+ type Task_State int32

+ const Task_Completed

+ const Task_Invalid

+ const Task_Pending

+ const Task_Resolving

+ const Task_Running

+ func (Task_State) EnumDescriptor() ([]byte, []int)

+ func (s *Task_State) UnmarshalJSON(data []byte) error

+ func (s Task_State) MarshalJSON() ([]byte, error)

+ func (x Task_State) String() string

+ type TasksRequest struct

+ CellId string

+ Domain string

+ func (*TasksRequest) Descriptor() ([]byte, []int)

+ func (*TasksRequest) ProtoMessage()

+ func (m *TasksRequest) GetCellId() string

+ func (m *TasksRequest) GetDomain() string

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

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

+ func (m *TasksRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *TasksRequest) Reset()

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

+ func (m *TasksRequest) Unmarshal(dAtA []byte) error

+ func (m *TasksRequest) XXX_DiscardUnknown()

+ func (m *TasksRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TasksRequest) XXX_Merge(src proto.Message)

+ func (m *TasksRequest) XXX_Size() int

+ func (m *TasksRequest) XXX_Unmarshal(b []byte) error

+ func (req *TasksRequest) Validate() error

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

+ func (this *TasksRequest) GoString() string

+ func (this *TasksRequest) String() string

+ type TasksResponse struct

+ Error *Error

+ Tasks []*Task

+ func (*TasksResponse) Descriptor() ([]byte, []int)

+ func (*TasksResponse) ProtoMessage()

+ func (m *TasksResponse) GetError() *Error

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

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

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

+ func (m *TasksResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *TasksResponse) Reset()

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

+ func (m *TasksResponse) Unmarshal(dAtA []byte) error

+ func (m *TasksResponse) XXX_DiscardUnknown()

+ func (m *TasksResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TasksResponse) XXX_Merge(src proto.Message)

+ func (m *TasksResponse) XXX_Size() int

+ func (m *TasksResponse) XXX_Unmarshal(b []byte) error

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

+ func (this *TasksResponse) GoString() string

+ func (this *TasksResponse) String() string

+ type TimeoutAction struct

+ Action *Action

+ DeprecatedTimeoutNs int64

+ LogSource string

+ TimeoutMs int64

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

+ func (*TimeoutAction) Descriptor() ([]byte, []int)

+ func (*TimeoutAction) ProtoMessage()

+ func (a *TimeoutAction) ActionType() string

+ func (a TimeoutAction) Validate() error

+ func (m *TimeoutAction) GetAction() *Action

+ func (m *TimeoutAction) GetDeprecatedTimeoutNs() int64

+ func (m *TimeoutAction) GetLogSource() string

+ func (m *TimeoutAction) GetTimeoutMs() int64

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

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

+ func (m *TimeoutAction) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *TimeoutAction) Reset()

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

+ func (m *TimeoutAction) Unmarshal(dAtA []byte) error

+ func (m *TimeoutAction) XXX_DiscardUnknown()

+ func (m *TimeoutAction) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TimeoutAction) XXX_Merge(src proto.Message)

+ func (m *TimeoutAction) XXX_Size() int

+ func (m *TimeoutAction) XXX_Unmarshal(b []byte) error

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

+ func (this *TimeoutAction) GoString() string

+ func (this *TimeoutAction) String() string

+ type TryAction struct

+ Action *Action

+ LogSource string

+ func Try(action ActionInterface) *TryAction

+ func (*TryAction) Descriptor() ([]byte, []int)

+ func (*TryAction) ProtoMessage()

+ func (a *TryAction) ActionType() string

+ func (a TryAction) Validate() error

+ func (m *TryAction) GetAction() *Action

+ func (m *TryAction) GetLogSource() string

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

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

+ func (m *TryAction) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *TryAction) Reset()

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

+ func (m *TryAction) Unmarshal(dAtA []byte) error

+ func (m *TryAction) XXX_DiscardUnknown()

+ func (m *TryAction) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TryAction) XXX_Merge(src proto.Message)

+ func (m *TryAction) XXX_Size() int

+ func (m *TryAction) XXX_Unmarshal(b []byte) error

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

+ func (this *TryAction) GoString() string

+ func (this *TryAction) String() string

+ type UpdateDesiredLRPRequest struct

+ ProcessGuid string

+ Update *DesiredLRPUpdate

+ func (*UpdateDesiredLRPRequest) Descriptor() ([]byte, []int)

+ func (*UpdateDesiredLRPRequest) ProtoMessage()

+ func (m *UpdateDesiredLRPRequest) GetProcessGuid() string

+ func (m *UpdateDesiredLRPRequest) GetUpdate() *DesiredLRPUpdate

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

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

+ func (m *UpdateDesiredLRPRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *UpdateDesiredLRPRequest) Reset()

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

+ func (m *UpdateDesiredLRPRequest) Unmarshal(dAtA []byte) error

+ func (m *UpdateDesiredLRPRequest) XXX_DiscardUnknown()

+ func (m *UpdateDesiredLRPRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *UpdateDesiredLRPRequest) XXX_Merge(src proto.Message)

+ func (m *UpdateDesiredLRPRequest) XXX_Size() int

+ func (m *UpdateDesiredLRPRequest) XXX_Unmarshal(b []byte) error

+ func (request *UpdateDesiredLRPRequest) Validate() error

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

+ func (this *UpdateDesiredLRPRequest) GoString() string

+ func (this *UpdateDesiredLRPRequest) String() string

+ type UploadAction struct

+ Artifact string

+ From string

+ LogSource string

+ To string

+ User string

+ func (*UploadAction) Descriptor() ([]byte, []int)

+ func (*UploadAction) ProtoMessage()

+ func (a *UploadAction) ActionType() string

+ func (a UploadAction) Validate() error

+ func (m *UploadAction) GetArtifact() string

+ func (m *UploadAction) GetFrom() string

+ func (m *UploadAction) GetLogSource() string

+ func (m *UploadAction) GetTo() string

+ func (m *UploadAction) GetUser() string

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

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

+ func (m *UploadAction) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *UploadAction) Reset()

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

+ func (m *UploadAction) Unmarshal(dAtA []byte) error

+ func (m *UploadAction) XXX_DiscardUnknown()

+ func (m *UploadAction) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *UploadAction) XXX_Merge(src proto.Message)

+ func (m *UploadAction) XXX_Size() int

+ func (m *UploadAction) XXX_Unmarshal(b []byte) error

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

+ func (this *UploadAction) GoString() string

+ func (this *UploadAction) String() string

+ type UpsertDomainRequest struct

+ Domain string

+ Ttl uint32

+ func (*UpsertDomainRequest) Descriptor() ([]byte, []int)

+ func (*UpsertDomainRequest) ProtoMessage()

+ func (m *UpsertDomainRequest) GetDomain() string

+ func (m *UpsertDomainRequest) GetTtl() uint32

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

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

+ func (m *UpsertDomainRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *UpsertDomainRequest) Reset()

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

+ func (m *UpsertDomainRequest) Unmarshal(dAtA []byte) error

+ func (m *UpsertDomainRequest) XXX_DiscardUnknown()

+ func (m *UpsertDomainRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *UpsertDomainRequest) XXX_Merge(src proto.Message)

+ func (m *UpsertDomainRequest) XXX_Size() int

+ func (m *UpsertDomainRequest) XXX_Unmarshal(b []byte) error

+ func (request *UpsertDomainRequest) Validate() error

+ func (this *UpsertDomainRequest) GoString() string

+ func (this *UpsertDomainRequest) String() string

+ type UpsertDomainResponse struct

+ Error *Error

+ func (*UpsertDomainResponse) Descriptor() ([]byte, []int)

+ func (*UpsertDomainResponse) ProtoMessage()

+ func (m *UpsertDomainResponse) GetError() *Error

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

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

+ func (m *UpsertDomainResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *UpsertDomainResponse) Reset()

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

+ func (m *UpsertDomainResponse) Unmarshal(dAtA []byte) error

+ func (m *UpsertDomainResponse) XXX_DiscardUnknown()

+ func (m *UpsertDomainResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *UpsertDomainResponse) XXX_Merge(src proto.Message)

+ func (m *UpsertDomainResponse) XXX_Size() int

+ func (m *UpsertDomainResponse) XXX_Unmarshal(b []byte) error

+ func (this *UpsertDomainResponse) GoString() string

+ func (this *UpsertDomainResponse) String() string

+ type ValidationError []error

+ func (ve ValidationError) Append(err error) ValidationError

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

+ func (ve ValidationError) Empty() bool

+ func (ve ValidationError) Error() string

+ func (ve ValidationError) ToError() error

+ type Validator interface

+ Validate func() error

+ type Version struct

+ CurrentVersion int64

+ type VolumeMount struct

+ ContainerDir string

+ Dedicated *DedicatedDevice

+ Driver string

+ Mode string

+ Shared *SharedDevice

+ func (*VolumeMount) Descriptor() ([]byte, []int)

+ func (*VolumeMount) ProtoMessage()

+ func (m *VolumeMount) GetContainerDir() string

+ func (m *VolumeMount) GetDedicated() *DedicatedDevice

+ func (m *VolumeMount) GetDriver() string

+ func (m *VolumeMount) GetMode() string

+ func (m *VolumeMount) GetShared() *SharedDevice

+ func (m *VolumeMount) Marshal() (dAtA []byte, err error)

+ func (m *VolumeMount) MarshalTo(dAtA []byte) (int, error)

+ func (m *VolumeMount) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *VolumeMount) Reset()

+ func (m *VolumeMount) Size() (n int)

+ func (m *VolumeMount) Unmarshal(dAtA []byte) error

+ func (m *VolumeMount) XXX_DiscardUnknown()

+ func (m *VolumeMount) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *VolumeMount) XXX_Merge(src proto.Message)

+ func (m *VolumeMount) XXX_Size() int

+ func (m *VolumeMount) XXX_Unmarshal(b []byte) error

+ func (this *VolumeMount) Equal(that interface{}) bool

+ func (this *VolumeMount) GoString() string

+ func (this *VolumeMount) String() string

+ func (v *VolumeMount) Validate() error

+ type VolumePlacement struct

+ DriverNames []string

+ func (*VolumePlacement) Descriptor() ([]byte, []int)

+ func (*VolumePlacement) ProtoMessage()

+ func (*VolumePlacement) Validate() error

+ func (*VolumePlacement) Version() format.Version

+ func (m *VolumePlacement) GetDriverNames() []string

+ func (m *VolumePlacement) Marshal() (dAtA []byte, err error)

+ func (m *VolumePlacement) MarshalTo(dAtA []byte) (int, error)

+ func (m *VolumePlacement) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *VolumePlacement) Reset()

+ func (m *VolumePlacement) Size() (n int)

+ func (m *VolumePlacement) Unmarshal(dAtA []byte) error

+ func (m *VolumePlacement) XXX_DiscardUnknown()

+ func (m *VolumePlacement) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *VolumePlacement) XXX_Merge(src proto.Message)

+ func (m *VolumePlacement) XXX_Size() int

+ func (m *VolumePlacement) XXX_Unmarshal(b []byte) error

+ func (this *VolumePlacement) Equal(that interface{}) bool

+ func (this *VolumePlacement) GoString() string

+ func (this *VolumePlacement) String() string

+ type Work struct

+ CellID string

+ LRPs []SchedulingLRP

+ Tasks []SchedulingTask

Other modules containing this package

code.cloudfoundry.org/bbs