Versions in this module Expand all Collapse all v0 v0.1.0 Jun 10, 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 + 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) Validate() error + 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/models
Go to main page