maintenance

package
v0.0.11 Latest Latest
Warning

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

Go to latest
Published: May 15, 2020 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Overview

Package maintenance is a generated protocol buffer package.

It is generated from these files:

maintenance/maintenance.proto

It has these top-level messages:

Window
Schedule
ClusterStatus

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrInvalidLengthMaintenance = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMaintenance   = fmt.Errorf("proto: integer overflow")
)

Functions

This section is empty.

Types

type ClusterStatus

type ClusterStatus struct {
	DrainingMachines []ClusterStatus_DrainingMachine `protobuf:"bytes,1,rep,name=draining_machines,json=drainingMachines" json:"draining_machines"`
	DownMachines     []mesos.MachineID               `protobuf:"bytes,2,rep,name=down_machines,json=downMachines" json:"down_machines"`
}

* Represents the maintenance status of each machine in the cluster. The lists correspond to the `MachineInfo.Mode` enumeration.

func NewPopulatedClusterStatus

func NewPopulatedClusterStatus(r randyMaintenance, easy bool) *ClusterStatus

func (*ClusterStatus) Descriptor

func (*ClusterStatus) Descriptor() ([]byte, []int)

func (*ClusterStatus) Equal

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

func (*ClusterStatus) GetDownMachines

func (m *ClusterStatus) GetDownMachines() []mesos.MachineID

func (*ClusterStatus) GetDrainingMachines

func (m *ClusterStatus) GetDrainingMachines() []ClusterStatus_DrainingMachine

func (*ClusterStatus) GoString

func (this *ClusterStatus) GoString() string

func (*ClusterStatus) Marshal

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

func (*ClusterStatus) MarshalJSON

func (mj *ClusterStatus) MarshalJSON() ([]byte, error)

func (*ClusterStatus) MarshalJSONBuf

func (mj *ClusterStatus) MarshalJSONBuf(buf fflib.EncodingBuffer) error

func (*ClusterStatus) MarshalTo

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

func (*ClusterStatus) ProtoMessage

func (*ClusterStatus) ProtoMessage()

func (*ClusterStatus) Reset

func (m *ClusterStatus) Reset()

func (*ClusterStatus) Size added in v0.0.11

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

func (*ClusterStatus) String

func (this *ClusterStatus) String() string

func (*ClusterStatus) Unmarshal

func (m *ClusterStatus) Unmarshal(dAtA []byte) error

func (*ClusterStatus) UnmarshalJSON

func (uj *ClusterStatus) UnmarshalJSON(input []byte) error

func (*ClusterStatus) UnmarshalJSONFFLexer

func (uj *ClusterStatus) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error

func (*ClusterStatus) VerboseEqual

func (this *ClusterStatus) VerboseEqual(that interface{}) error

type ClusterStatus_DrainingMachine

type ClusterStatus_DrainingMachine struct {
	ID mesos.MachineID `protobuf:"bytes,1,req,name=id" json:"id"`
	// A list of the most recent responses to inverse offers from frameworks
	// running on this draining machine.
	Statuses []mesos_allocator.InverseOfferStatus `protobuf:"bytes,2,rep,name=statuses" json:"statuses"`
}

func NewPopulatedClusterStatus_DrainingMachine

func NewPopulatedClusterStatus_DrainingMachine(r randyMaintenance, easy bool) *ClusterStatus_DrainingMachine

func (*ClusterStatus_DrainingMachine) Descriptor

func (*ClusterStatus_DrainingMachine) Descriptor() ([]byte, []int)

func (*ClusterStatus_DrainingMachine) Equal

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

func (*ClusterStatus_DrainingMachine) GetID

func (*ClusterStatus_DrainingMachine) GetStatuses

func (*ClusterStatus_DrainingMachine) GoString

func (this *ClusterStatus_DrainingMachine) GoString() string

func (*ClusterStatus_DrainingMachine) Marshal

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

func (*ClusterStatus_DrainingMachine) MarshalJSON

func (mj *ClusterStatus_DrainingMachine) MarshalJSON() ([]byte, error)

func (*ClusterStatus_DrainingMachine) MarshalJSONBuf

func (mj *ClusterStatus_DrainingMachine) MarshalJSONBuf(buf fflib.EncodingBuffer) error

func (*ClusterStatus_DrainingMachine) MarshalTo

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

func (*ClusterStatus_DrainingMachine) ProtoMessage

func (*ClusterStatus_DrainingMachine) ProtoMessage()

func (*ClusterStatus_DrainingMachine) Reset

func (m *ClusterStatus_DrainingMachine) Reset()

func (*ClusterStatus_DrainingMachine) Size added in v0.0.11

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

func (*ClusterStatus_DrainingMachine) String

func (this *ClusterStatus_DrainingMachine) String() string

func (*ClusterStatus_DrainingMachine) Unmarshal

func (m *ClusterStatus_DrainingMachine) Unmarshal(dAtA []byte) error

func (*ClusterStatus_DrainingMachine) UnmarshalJSON

func (uj *ClusterStatus_DrainingMachine) UnmarshalJSON(input []byte) error

func (*ClusterStatus_DrainingMachine) UnmarshalJSONFFLexer

func (uj *ClusterStatus_DrainingMachine) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error

func (*ClusterStatus_DrainingMachine) VerboseEqual

func (this *ClusterStatus_DrainingMachine) VerboseEqual(that interface{}) error

type Schedule

type Schedule struct {
	Windows []Window `protobuf:"bytes,1,rep,name=windows" json:"windows"`
}

* A list of maintenance windows. For example, this may represent a rolling restart of agents.

func NewPopulatedSchedule

func NewPopulatedSchedule(r randyMaintenance, easy bool) *Schedule

func (*Schedule) Descriptor

func (*Schedule) Descriptor() ([]byte, []int)

func (*Schedule) Equal

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

func (*Schedule) GetWindows

func (m *Schedule) GetWindows() []Window

func (*Schedule) GoString

func (this *Schedule) GoString() string

func (*Schedule) Marshal

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

func (*Schedule) MarshalJSON

func (mj *Schedule) MarshalJSON() ([]byte, error)

func (*Schedule) MarshalJSONBuf

func (mj *Schedule) MarshalJSONBuf(buf fflib.EncodingBuffer) error

func (*Schedule) MarshalTo

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

func (*Schedule) ProtoMessage

func (*Schedule) ProtoMessage()

func (*Schedule) Reset

func (m *Schedule) Reset()

func (*Schedule) Size added in v0.0.11

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

func (*Schedule) String

func (this *Schedule) String() string

func (*Schedule) Unmarshal

func (m *Schedule) Unmarshal(dAtA []byte) error

func (*Schedule) UnmarshalJSON

func (uj *Schedule) UnmarshalJSON(input []byte) error

func (*Schedule) UnmarshalJSONFFLexer

func (uj *Schedule) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error

func (*Schedule) VerboseEqual

func (this *Schedule) VerboseEqual(that interface{}) error

type Window

type Window struct {
	// Machines affected by this maintenance window.
	MachineIDs []mesos.MachineID `protobuf:"bytes,1,rep,name=machine_ids,json=machineIds" json:"machine_ids"`
	// Interval during which this set of machines is expected to be down.
	Unavailability mesos.Unavailability `protobuf:"bytes,2,req,name=unavailability" json:"unavailability"`
}

* A set of machines scheduled to go into maintenance in the same `unavailability`.

func NewPopulatedWindow

func NewPopulatedWindow(r randyMaintenance, easy bool) *Window

func (*Window) Descriptor

func (*Window) Descriptor() ([]byte, []int)

func (*Window) Equal

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

func (*Window) GetMachineIDs

func (m *Window) GetMachineIDs() []mesos.MachineID

func (*Window) GetUnavailability

func (m *Window) GetUnavailability() mesos.Unavailability

func (*Window) GoString

func (this *Window) GoString() string

func (*Window) Marshal

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

func (*Window) MarshalJSON

func (mj *Window) MarshalJSON() ([]byte, error)

func (*Window) MarshalJSONBuf

func (mj *Window) MarshalJSONBuf(buf fflib.EncodingBuffer) error

func (*Window) MarshalTo

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

func (*Window) ProtoMessage

func (*Window) ProtoMessage()

func (*Window) Reset

func (m *Window) Reset()

func (*Window) Size added in v0.0.11

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

func (*Window) String

func (this *Window) String() string

func (*Window) Unmarshal

func (m *Window) Unmarshal(dAtA []byte) error

func (*Window) UnmarshalJSON

func (uj *Window) UnmarshalJSON(input []byte) error

func (*Window) UnmarshalJSONFFLexer

func (uj *Window) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error

func (*Window) VerboseEqual

func (this *Window) VerboseEqual(that interface{}) error

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL