maintenance

package
v0.0.7 Latest Latest
Warning

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

 Go to latest Published: Jul 24, 2018 License: Apache-2.0 Imports: 11 Imported by: 10

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) ProtoSize 

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

func (*ClusterStatus) Reset 

func (m *ClusterStatus) Reset()

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 (m *ClusterStatus_DrainingMachine) GetID() mesos.MachineID

func (*ClusterStatus_DrainingMachine) GetStatuses 

func (m *ClusterStatus_DrainingMachine) GetStatuses() []mesos_allocator.InverseOfferStatus

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) ProtoSize 

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

func (*ClusterStatus_DrainingMachine) Reset 

func (m *ClusterStatus_DrainingMachine) Reset()

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) ProtoSize 

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

func (*Schedule) Reset 

func (m *Schedule) Reset()

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) ProtoSize 

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

func (*Window) Reset 

func (m *Window) Reset()

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

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