inventory

package
v0.0.0-...-3e52749 Latest Latest
Warning

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

 Go to latest Published: Mar 26, 2022 License: Apache-2.0 Imports: 29 Imported by: 0

Documentation

Overview

Package inventory contains the implementation of the simulated inventory. Each physical element is simulated using a state machine based local actor structure.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewTracker 

func NewTracker() *tracker

NewTracker constructs a new tracker instance.

func Register 

func Register(svc *grpc.Server, cfg *config.GlobalConfig) error

Types

type MockedBlade 

type MockedBlade struct {
	// contains filtered or unexported fields
}

func (*MockedBlade) Actual 

func (m *MockedBlade) Actual() inventory.BladeViewActualOperations

func (*MockedBlade) Definition 

func (m *MockedBlade) Definition() inventory.BladeViewDefinitionOperations

func (*MockedBlade) Moniker 

func (m *MockedBlade) Moniker() string

func (*MockedBlade) Observed 

func (m *MockedBlade) Observed() inventory.BladeViewObservedOperations

type MockedBladeActual 

type MockedBladeActual struct {
	// contains filtered or unexported fields
}

func (*MockedBladeActual) Create 

func (m *MockedBladeActual) Create(ctx context.Context) (int64, error)

func (*MockedBladeActual) Delete 

func (m *MockedBladeActual) Delete(ctx context.Context, unconditional bool) (int64, error)

func (*MockedBladeActual) Equal 

func (m *MockedBladeActual) Equal(x *pb.Actual_Blade) bool

func (*MockedBladeActual) GetAllUsage 

func (m *MockedBladeActual) GetAllUsage() map[string]*pb.Usage

func (*MockedBladeActual) GetAvail 

func (m *MockedBladeActual) GetAvail() *pb.BladeCapacity

func (*MockedBladeActual) GetState 

func (m *MockedBladeActual) GetState() pb.BladeState_SM

func (*MockedBladeActual) GetStoreData 

func (m *MockedBladeActual) GetStoreData() *pb.Actual_Blade

func (*MockedBladeActual) GetTimer 

func (m *MockedBladeActual) GetTimer() *pb.ActiveTimer

func (*MockedBladeActual) GetUsage 

func (m *MockedBladeActual) GetUsage(id string) *pb.Usage

func (*MockedBladeActual) NotEqual 

func (m *MockedBladeActual) NotEqual(x *pb.Actual_Blade) bool

func (*MockedBladeActual) Read 

func (m *MockedBladeActual) Read(ctx context.Context) (int64, error)

func (*MockedBladeActual) RemoveUsage 

func (m *MockedBladeActual) RemoveUsage(id string) bool

func (*MockedBladeActual) SetAllUsage 

func (m *MockedBladeActual) SetAllUsage(usages map[string]*pb.Usage)

func (*MockedBladeActual) SetAvail 

func (m *MockedBladeActual) SetAvail(value *pb.BladeCapacity)

func (*MockedBladeActual) SetState 

func (m *MockedBladeActual) SetState(state pb.BladeState_SM)

func (*MockedBladeActual) SetTimer 

func (m *MockedBladeActual) SetTimer(t *pb.ActiveTimer)

func (*MockedBladeActual) SetUsage 

func (m *MockedBladeActual) SetUsage(id string, usage *pb.Usage)

func (*MockedBladeActual) Update 

func (m *MockedBladeActual) Update(ctx context.Context, unconditional bool) (int64, error)

type MockedBladeDefinition 

type MockedBladeDefinition struct {
	// contains filtered or unexported fields
}

func (*MockedBladeDefinition) ChildIndexName 

func (m *MockedBladeDefinition) ChildIndexName() string

func (*MockedBladeDefinition) Create 

func (m *MockedBladeDefinition) Create(ctx context.Context) (int64, error)

func (*MockedBladeDefinition) Delete 

func (m *MockedBladeDefinition) Delete(ctx context.Context, unconditional bool) (int64, error)

func (*MockedBladeDefinition) Equal 

func (m *MockedBladeDefinition) Equal(d *pb.Definition_Blade) bool

func (*MockedBladeDefinition) GetBootInfo 

func (m *MockedBladeDefinition) GetBootInfo() *pb.BladeBootInfo

func (*MockedBladeDefinition) GetBootOnPowerOn 

func (m *MockedBladeDefinition) GetBootOnPowerOn() bool

func (*MockedBladeDefinition) GetCapacity 

func (m *MockedBladeDefinition) GetCapacity() *pb.BladeCapacity

func (*MockedBladeDefinition) GetDetails 

func (m *MockedBladeDefinition) GetDetails() *pb.BladeDetails

func (*MockedBladeDefinition) GetStoreData 

func (m *MockedBladeDefinition) GetStoreData() *pb.Definition_Blade

func (*MockedBladeDefinition) IndexName 

func (m *MockedBladeDefinition) IndexName() string

func (*MockedBladeDefinition) KeyName 

func (m *MockedBladeDefinition) KeyName() string

func (*MockedBladeDefinition) ListChildren 

func (m *MockedBladeDefinition) ListChildren(ctx context.Context) (int64, []string, error)

func (*MockedBladeDefinition) NotEqual 

func (m *MockedBladeDefinition) NotEqual(d *pb.Definition_Blade) bool

func (*MockedBladeDefinition) Read 

func (m *MockedBladeDefinition) Read(ctx context.Context) (rev int64, err error)

func (*MockedBladeDefinition) SetBootInfo 

func (m *MockedBladeDefinition) SetBootInfo(bootInfo *pb.BladeBootInfo)

func (*MockedBladeDefinition) SetBootPowerOn 

func (m *MockedBladeDefinition) SetBootPowerOn(bootOnPowerOn bool)

func (*MockedBladeDefinition) SetCapacity 

func (m *MockedBladeDefinition) SetCapacity(capacity *pb.BladeCapacity)

func (*MockedBladeDefinition) SetDetails 

func (m *MockedBladeDefinition) SetDetails(details *pb.BladeDetails)

func (*MockedBladeDefinition) Update 

func (m *MockedBladeDefinition) Update(ctx context.Context, unconditional bool) (int64, error)

type MockedPdu 

type MockedPdu struct {
	// contains filtered or unexported fields
}

func (*MockedPdu) Actual 

func (m *MockedPdu) Actual() inventory.PduViewActualOperations

func (*MockedPdu) Definition 

func (m *MockedPdu) Definition() inventory.PduViewDefinitionOperations

func (*MockedPdu) Moniker 

func (m *MockedPdu) Moniker() string

func (*MockedPdu) Observed 

func (m *MockedPdu) Observed() inventory.PduViewObservedOperations

type MockedPduActual 

type MockedPduActual struct {
	// contains filtered or unexported fields
}

func (*MockedPduActual) Create 

func (m *MockedPduActual) Create(ctx context.Context) (int64, error)

func (*MockedPduActual) Delete 

func (m *MockedPduActual) Delete(ctx context.Context, unconditional bool) (int64, error)

func (*MockedPduActual) Describe 

func (m *MockedPduActual) Describe() string

func (*MockedPduActual) Equal 

func (m *MockedPduActual) Equal(x *pb.Actual_Pdu) bool

func (*MockedPduActual) GetCables 

func (m *MockedPduActual) GetCables() map[int64]*pb.Cable

func (*MockedPduActual) GetCondition 

func (m *MockedPduActual) GetCondition() pb.Condition

func (*MockedPduActual) GetCore 

func (m *MockedPduActual) GetCore() *pb.MachineCore

func (*MockedPduActual) GetState 

func (m *MockedPduActual) GetState() pb.PduState_SM

func (*MockedPduActual) GetStoreData 

func (m *MockedPduActual) GetStoreData() *pb.Actual_Pdu

func (*MockedPduActual) NotEqual 

func (m *MockedPduActual) NotEqual(x *pb.Actual_Pdu) bool

func (*MockedPduActual) Read 

func (m *MockedPduActual) Read(ctx context.Context) (int64, error)

func (*MockedPduActual) SetCables 

func (m *MockedPduActual) SetCables(cables map[int64]*pb.Cable)

func (*MockedPduActual) SetCondition 

func (m *MockedPduActual) SetCondition(cond pb.Condition)

func (*MockedPduActual) SetCore 

func (m *MockedPduActual) SetCore(item *pb.MachineCore)

func (*MockedPduActual) SetState 

func (m *MockedPduActual) SetState(state pb.PduState_SM)

func (*MockedPduActual) Update 

func (m *MockedPduActual) Update(ctx context.Context, unconditional bool) (int64, error)

type MockedPduDefinition 

type MockedPduDefinition struct {
	// contains filtered or unexported fields
}

func (*MockedPduDefinition) ChildIndexName 

func (m *MockedPduDefinition) ChildIndexName() string

func (*MockedPduDefinition) Create 

func (m *MockedPduDefinition) Create(ctx context.Context) (int64, error)

func (*MockedPduDefinition) Delete 

func (m *MockedPduDefinition) Delete(ctx context.Context, unconditional bool) (int64, error)

func (*MockedPduDefinition) Equal 

func (m *MockedPduDefinition) Equal(d *pb.Definition_Pdu) bool

func (*MockedPduDefinition) EqualPorts 

func (m *MockedPduDefinition) EqualPorts(ports map[int64]*pb.PowerPort) bool

func (*MockedPduDefinition) GetDetails 

func (m *MockedPduDefinition) GetDetails() *pb.PduDetails

func (*MockedPduDefinition) GetPorts 

func (m *MockedPduDefinition) GetPorts() map[int64]*pb.PowerPort

func (*MockedPduDefinition) GetStoreData 

func (m *MockedPduDefinition) GetStoreData() *pb.Definition_Pdu

func (*MockedPduDefinition) IndexName 

func (m *MockedPduDefinition) IndexName() string

func (*MockedPduDefinition) KeyName 

func (m *MockedPduDefinition) KeyName() string

func (*MockedPduDefinition) ListChildren 

func (m *MockedPduDefinition) ListChildren(ctx context.Context) (int64, []string, error)

func (*MockedPduDefinition) NotEqual 

func (m *MockedPduDefinition) NotEqual(d *pb.Definition_Pdu) bool

func (*MockedPduDefinition) Read 

func (m *MockedPduDefinition) Read(ctx context.Context) (int64, error)

func (*MockedPduDefinition) SetDetails 

func (m *MockedPduDefinition) SetDetails(details *pb.PduDetails)

func (*MockedPduDefinition) SetPorts 

func (m *MockedPduDefinition) SetPorts(ports map[int64]*pb.PowerPort)

func (*MockedPduDefinition) Update 

func (m *MockedPduDefinition) Update(ctx context.Context, unconditional bool) (int64, error)

type MockedPduObserved 

type MockedPduObserved struct {
	// contains filtered or unexported fields
}

func (*MockedPduObserved) Create 

func (m *MockedPduObserved) Create(ctx context.Context) (int64, error)

func (*MockedPduObserved) Delete 

func (m *MockedPduObserved) Delete(ctx context.Context, unconditional bool) (int64, error)

func (*MockedPduObserved) Describe 

func (m *MockedPduObserved) Describe() string

func (*MockedPduObserved) Equal 

func (m *MockedPduObserved) Equal(x *pb.Observed_Pdu) bool

func (*MockedPduObserved) GetCables 

func (m *MockedPduObserved) GetCables() map[int64]*pb.Cable

func (*MockedPduObserved) GetCondition 

func (m *MockedPduObserved) GetCondition() pb.Condition

func (*MockedPduObserved) GetCore 

func (m *MockedPduObserved) GetCore() *pb.MachineCore

func (*MockedPduObserved) GetLastGoodObservation 

func (m *MockedPduObserved) GetLastGoodObservation() int64

func (*MockedPduObserved) GetObservationFailedReason 

func (m *MockedPduObserved) GetObservationFailedReason() string

func (*MockedPduObserved) GetObservedAt 

func (m *MockedPduObserved) GetObservedAt() int64

func (*MockedPduObserved) GetState 

func (m *MockedPduObserved) GetState() pb.PduState_SM

func (*MockedPduObserved) GetStoreData 

func (m *MockedPduObserved) GetStoreData() *pb.Observed_Pdu

func (*MockedPduObserved) NotEqual 

func (m *MockedPduObserved) NotEqual(x *pb.Observed_Pdu) bool

func (*MockedPduObserved) Observe 

func (m *MockedPduObserved) Observe(at int64, actual *pb.Actual_Pdu)

func (*MockedPduObserved) Read 

func (m *MockedPduObserved) Read(ctx context.Context) (int64, error)

func (*MockedPduObserved) SetCables 

func (m *MockedPduObserved) SetCables(cables map[int64]*pb.Cable)

func (*MockedPduObserved) SetCondition 

func (m *MockedPduObserved) SetCondition(cond pb.Condition)

func (*MockedPduObserved) SetCore 

func (m *MockedPduObserved) SetCore(item *pb.MachineCore)

func (*MockedPduObserved) SetLastGoodObservation 

func (m *MockedPduObserved) SetLastGoodObservation(at int64)

func (*MockedPduObserved) SetObservationFailedReason 

func (m *MockedPduObserved) SetObservationFailedReason(x string)

func (*MockedPduObserved) SetObservedAt 

func (m *MockedPduObserved) SetObservedAt(at int64)

func (*MockedPduObserved) SetState 

func (m *MockedPduObserved) SetState(state pb.PduState_SM)

func (*MockedPduObserved) Update 

func (m *MockedPduObserved) Update(ctx context.Context, unconditional bool) (int64, error)

type MockedRack 

type MockedRack struct {
	// contains filtered or unexported fields
}

func (*MockedRack) Actual 

func (m *MockedRack) Actual() inventory.RackViewActualOperations

func (*MockedRack) Definition 

func (m *MockedRack) Definition() inventory.RackViewDefinitionOperations

func (*MockedRack) Moniker 

func (m *MockedRack) Moniker() string

func (*MockedRack) NewBlade 

func (m *MockedRack) NewBlade(ID int64) (inventory.BladeOperations, error)

func (*MockedRack) NewChild 

func (m *MockedRack) NewChild(name string) (interface{}, error)

func (*MockedRack) NewPdu 

func (m *MockedRack) NewPdu(ID int64) (inventory.PduOperations, error)

func (*MockedRack) NewTor 

func (m *MockedRack) NewTor(ID int64) (inventory.TorOperations, error)

type MockedRackActual 

type MockedRackActual struct {
	// contains filtered or unexported fields
}

func (*MockedRackActual) ChildIndexName 

func (m *MockedRackActual) ChildIndexName() string

func (*MockedRackActual) Create 

func (m *MockedRackActual) Create(ctx context.Context) (int64, error)

func (*MockedRackActual) Delete 

func (m *MockedRackActual) Delete(ctx context.Context, unconditional bool) (int64, error)

func (*MockedRackActual) Equal 

func (m *MockedRackActual) Equal(d *pb.Actual_Rack) bool

func (*MockedRackActual) FetchBlades 

func (m *MockedRackActual) FetchBlades(ctx context.Context) (int64, map[int64]inventory.BladeOperations, error)

func (*MockedRackActual) FetchChildren 

func (m *MockedRackActual) FetchChildren(ctx context.Context) (int64, *map[string]interface{}, error)

func (*MockedRackActual) FetchPdus 

func (m *MockedRackActual) FetchPdus(ctx context.Context) (int64, map[int64]inventory.PduOperations, error)

func (*MockedRackActual) FetchTors 

func (m *MockedRackActual) FetchTors(ctx context.Context) (int64, map[int64]inventory.TorOperations, error)

func (*MockedRackActual) GetCore 

func (m *MockedRackActual) GetCore() *pb.MachineCore

func (*MockedRackActual) GetState 

func (m *MockedRackActual) GetState() pb.RackState_SM

func (*MockedRackActual) GetStoreData 

func (m *MockedRackActual) GetStoreData() *pb.Actual_Rack

func (*MockedRackActual) GetStoreDataWithChildren 

func (m *MockedRackActual) GetStoreDataWithChildren(ctx context.Context) (*pb.Actual_Rack, error)

func (*MockedRackActual) IndexName 

func (m *MockedRackActual) IndexName() string

func (*MockedRackActual) KeyName 

func (m *MockedRackActual) KeyName() string

func (*MockedRackActual) ListBlades 

func (m *MockedRackActual) ListBlades(ctx context.Context) (int64, []int64, error)

func (*MockedRackActual) ListChildren 

func (m *MockedRackActual) ListChildren(ctx context.Context) (int64, []string, error)

func (*MockedRackActual) ListPdus 

func (m *MockedRackActual) ListPdus(ctx context.Context) (int64, []int64, error)

func (*MockedRackActual) ListTors 

func (m *MockedRackActual) ListTors(ctx context.Context) (int64, []int64, error)

func (*MockedRackActual) NotEqual 

func (m *MockedRackActual) NotEqual(d *pb.Actual_Rack) bool

func (*MockedRackActual) Read 

func (m *MockedRackActual) Read(ctx context.Context) (int64, error)

func (*MockedRackActual) SetCore 

func (m *MockedRackActual) SetCore(item *pb.MachineCore)

func (*MockedRackActual) SetState 

func (m *MockedRackActual) SetState(value pb.RackState_SM)

func (*MockedRackActual) Update 

func (m *MockedRackActual) Update(ctx context.Context, unconditional bool) (int64, error)

type MockedRackDefinition 

type MockedRackDefinition struct {
	// contains filtered or unexported fields
}

func (*MockedRackDefinition) ChildIndexName 

func (m *MockedRackDefinition) ChildIndexName() string

func (*MockedRackDefinition) Create 

func (m *MockedRackDefinition) Create(ctx context.Context) (rev int64, err error)

func (*MockedRackDefinition) Delete 

func (m *MockedRackDefinition) Delete(ctx context.Context, unconditional bool) (int64, error)

func (*MockedRackDefinition) Equal 

func (m *MockedRackDefinition) Equal(d *pb.Definition_Rack) bool

func (*MockedRackDefinition) FetchBlades 

func (m *MockedRackDefinition) FetchBlades(ctx context.Context) (int64, map[int64]inventory.BladeOperations, error)

func (*MockedRackDefinition) FetchChildren 

func (m *MockedRackDefinition) FetchChildren(ctx context.Context) (int64, *map[string]interface{}, error)

func (*MockedRackDefinition) FetchPdus 

func (m *MockedRackDefinition) FetchPdus(ctx context.Context) (int64, map[int64]inventory.PduOperations, error)

func (*MockedRackDefinition) FetchTors 

func (m *MockedRackDefinition) FetchTors(ctx context.Context) (int64, map[int64]inventory.TorOperations, error)

func (*MockedRackDefinition) GetDetails 

func (m *MockedRackDefinition) GetDetails() *pb.RackDetails

func (*MockedRackDefinition) GetStoreData 

func (m *MockedRackDefinition) GetStoreData() *pb.Definition_Rack

func (*MockedRackDefinition) GetStoreDataWithChildren 

func (m *MockedRackDefinition) GetStoreDataWithChildren(ctx context.Context) (*pb.Definition_Rack, error)

func (*MockedRackDefinition) IndexName 

func (m *MockedRackDefinition) IndexName() string

func (*MockedRackDefinition) KeyName 

func (m *MockedRackDefinition) KeyName() string

func (*MockedRackDefinition) ListBlades 

func (m *MockedRackDefinition) ListBlades(ctx context.Context) (int64, []int64, error)

func (*MockedRackDefinition) ListChildren 

func (m *MockedRackDefinition) ListChildren(ctx context.Context) (int64, []string, error)

func (*MockedRackDefinition) ListPdus 

func (m *MockedRackDefinition) ListPdus(ctx context.Context) (int64, []int64, error)

func (*MockedRackDefinition) ListTors 

func (m *MockedRackDefinition) ListTors(ctx context.Context) (int64, []int64, error)

func (*MockedRackDefinition) NotEqual 

func (m *MockedRackDefinition) NotEqual(d *pb.Definition_Rack) bool

func (*MockedRackDefinition) Read 

func (m *MockedRackDefinition) Read(ctx context.Context) (rev int64, err error)

func (*MockedRackDefinition) SetDetails 

func (m *MockedRackDefinition) SetDetails(details *pb.RackDetails)

func (*MockedRackDefinition) Update 

func (m *MockedRackDefinition) Update(ctx context.Context, unconditional bool) (rev int64, err error)

type MockedTor 

type MockedTor struct {
	// contains filtered or unexported fields
}

func (*MockedTor) Actual 

func (m *MockedTor) Actual() inventory.TorViewActualOperations

func (*MockedTor) Definition 

func (m *MockedTor) Definition() inventory.TorViewDefinitionOperations

func (*MockedTor) Moniker 

func (m *MockedTor) Moniker() string

func (*MockedTor) Observed 

func (m *MockedTor) Observed() inventory.TorViewObservedOperations

type MockedTorActual 

type MockedTorActual struct {
	// contains filtered or unexported fields
}

func (*MockedTorActual) Create 

func (m *MockedTorActual) Create(ctx context.Context) (int64, error)

func (*MockedTorActual) Delete 

func (m *MockedTorActual) Delete(ctx context.Context, unconditional bool) (int64, error)

func (*MockedTorActual) Describe 

func (m *MockedTorActual) Describe() string

func (*MockedTorActual) Equal 

func (m *MockedTorActual) Equal(x *pb.Actual_Tor) bool

func (*MockedTorActual) GetCables 

func (m *MockedTorActual) GetCables() map[int64]*pb.Cable

func (*MockedTorActual) GetCondition 

func (m *MockedTorActual) GetCondition() pb.Condition

func (*MockedTorActual) GetCore 

func (m *MockedTorActual) GetCore() *pb.MachineCore

func (*MockedTorActual) GetState 

func (m *MockedTorActual) GetState() pb.TorState_SM

func (*MockedTorActual) GetStoreData 

func (m *MockedTorActual) GetStoreData() *pb.Actual_Tor

func (*MockedTorActual) NotEqual 

func (m *MockedTorActual) NotEqual(x *pb.Actual_Tor) bool

func (*MockedTorActual) Read 

func (m *MockedTorActual) Read(ctx context.Context) (int64, error)

func (*MockedTorActual) SetCables 

func (m *MockedTorActual) SetCables(cables map[int64]*pb.Cable)

func (*MockedTorActual) SetCondition 

func (m *MockedTorActual) SetCondition(cond pb.Condition)

func (*MockedTorActual) SetCore 

func (m *MockedTorActual) SetCore(item *pb.MachineCore)

func (*MockedTorActual) SetState 

func (m *MockedTorActual) SetState(state pb.TorState_SM)

func (*MockedTorActual) Update 

func (m *MockedTorActual) Update(ctx context.Context, unconditional bool) (int64, error)

type MockedTorDefinition 

type MockedTorDefinition struct {
	// contains filtered or unexported fields
}

func (*MockedTorDefinition) ChildIndexName 

func (m *MockedTorDefinition) ChildIndexName() string

func (*MockedTorDefinition) Create 

func (m *MockedTorDefinition) Create(ctx context.Context) (int64, error)

func (*MockedTorDefinition) Delete 

func (m *MockedTorDefinition) Delete(ctx context.Context, unconditional bool) (int64, error)

func (*MockedTorDefinition) Equal 

func (m *MockedTorDefinition) Equal(d *pb.Definition_Tor) bool

func (*MockedTorDefinition) EqualPorts 

func (m *MockedTorDefinition) EqualPorts(ports map[int64]*pb.NetworkPort) bool

func (*MockedTorDefinition) GetDetails 

func (m *MockedTorDefinition) GetDetails() *pb.TorDetails

func (*MockedTorDefinition) GetPorts 

func (m *MockedTorDefinition) GetPorts() map[int64]*pb.NetworkPort

func (*MockedTorDefinition) GetStoreData 

func (m *MockedTorDefinition) GetStoreData() *pb.Definition_Tor

func (*MockedTorDefinition) IndexName 

func (m *MockedTorDefinition) IndexName() string

func (*MockedTorDefinition) KeyName 

func (m *MockedTorDefinition) KeyName() string

func (*MockedTorDefinition) ListChildren 

func (m *MockedTorDefinition) ListChildren(ctx context.Context) (int64, []string, error)

func (*MockedTorDefinition) NotEqual 

func (m *MockedTorDefinition) NotEqual(d *pb.Definition_Tor) bool

func (*MockedTorDefinition) Read 

func (m *MockedTorDefinition) Read(ctx context.Context) (int64, error)

func (*MockedTorDefinition) SetDetails 

func (m *MockedTorDefinition) SetDetails(details *pb.TorDetails)

func (*MockedTorDefinition) SetPorts 

func (m *MockedTorDefinition) SetPorts(ports map[int64]*pb.NetworkPort)

func (*MockedTorDefinition) Update 

func (m *MockedTorDefinition) Update(ctx context.Context, unconditional bool) (int64, error)

type MockedTorObserved 

type MockedTorObserved struct {
	// contains filtered or unexported fields
}

func (*MockedTorObserved) Create 

func (t *MockedTorObserved) Create(ctx context.Context) (int64, error)

func (*MockedTorObserved) Delete 

func (t *MockedTorObserved) Delete(ctx context.Context, unconditional bool) (int64, error)

func (*MockedTorObserved) Describe 

func (t *MockedTorObserved) Describe() string

func (*MockedTorObserved) Equal 

func (t *MockedTorObserved) Equal(x *pb.Observed_Tor) bool

func (*MockedTorObserved) GetCables 

func (t *MockedTorObserved) GetCables() map[int64]*pb.Cable

func (*MockedTorObserved) GetCondition 

func (m *MockedTorObserved) GetCondition() pb.Condition

func (*MockedTorObserved) GetCore 

func (m *MockedTorObserved) GetCore() *pb.MachineCore

func (*MockedTorObserved) GetLastGoodObservation 

func (t *MockedTorObserved) GetLastGoodObservation() int64

func (*MockedTorObserved) GetObservationFailedReason 

func (t *MockedTorObserved) GetObservationFailedReason() string

func (*MockedTorObserved) GetObservedAt 

func (t *MockedTorObserved) GetObservedAt() int64

func (*MockedTorObserved) GetState 

func (t *MockedTorObserved) GetState() pb.TorState_SM

func (*MockedTorObserved) GetStoreData 

func (t *MockedTorObserved) GetStoreData() *pb.Observed_Tor

func (*MockedTorObserved) NotEqual 

func (t *MockedTorObserved) NotEqual(x *pb.Observed_Tor) bool

func (*MockedTorObserved) Observe 

func (t *MockedTorObserved) Observe(at int64, actual *pb.Actual_Tor)

func (*MockedTorObserved) Read 

func (t *MockedTorObserved) Read(ctx context.Context) (int64, error)

func (*MockedTorObserved) SetCables 

func (t *MockedTorObserved) SetCables(cables map[int64]*pb.Cable)

func (*MockedTorObserved) SetCondition 

func (m *MockedTorObserved) SetCondition(cond pb.Condition)

func (*MockedTorObserved) SetCore 

func (m *MockedTorObserved) SetCore(item *pb.MachineCore)

func (*MockedTorObserved) SetLastGoodObservation 

func (t *MockedTorObserved) SetLastGoodObservation(at int64)

func (*MockedTorObserved) SetObservationFailedReason 

func (t *MockedTorObserved) SetObservationFailedReason(x string)

func (*MockedTorObserved) SetObservedAt 

func (t *MockedTorObserved) SetObservedAt(at int64)

func (*MockedTorObserved) SetState 

func (t *MockedTorObserved) SetState(state pb.TorState_SM)

func (*MockedTorObserved) Update 

func (t *MockedTorObserved) Update(ctx context.Context, unconditional bool) (int64, error)

type Rack 

type Rack struct {
	// contains filtered or unexported fields
}

Rack holds a simulated Rack, consisting of a TOR (top of Rack switch), a PDU (power distribution unit), and some number of blades. These are governed by a mesh of state machines rooted in the one for the Rack as a whole.

func (*Rack) AddToPduMap 

func (r *Rack) AddToPduMap(key string, id int64)

AddToPduMap sets the specified target to route through the PDU at the index supplied by the id parameter.

func (*Rack) AddToTorMap 

func (r *Rack) AddToTorMap(key string, id int64)

AddToTorMap sets the specified target to route through the TOR at the index supplied by the id parameter.

func (*Rack) Receive 

func (r *Rack) Receive(msg sm.Envelope)

Receive handles incoming requests from outside, forwarding to the rack's state machine handler.

func (*Rack) ToBlade 

func (r *Rack) ToBlade(ctx context.Context, id int64, msg sm.Envelope) error

ToBlade forwards the supplied message directly to the target blade, without any intermediate hops. This should only be used by events that do not need to simulate a working network connection for reachability, or a working power cable for execution.

func (*Rack) ToPdu 

func (r *Rack) ToPdu(ctx context.Context, id int64, msg sm.Envelope) error

ToPdu forwards the supplied message directly to the target PDU, without any intermediate hops. This should only be used by events that do not need to simulate a working network connection for reachability, or a working power cable for execution.

func (*Rack) ToTarget 

func (r *Rack) ToTarget(
	ctx context.Context,
	t *messages.MessageTarget,
	msg sm.Envelope) error

ToTarget forwards the message directly to the element described in the supplied target, regardless of type.

func (*Rack) ToTor 

func (r *Rack) ToTor(ctx context.Context, id int64, msg sm.Envelope) error

ToTor forwards the supplied message directly to the target TOR, without any intermediate hops. This should only be used by events that do not need to simulate a working network connection for reachability, or a working power cable for execution.

func (*Rack) ViaPDU 

func (r *Rack) ViaPDU(ctx context.Context, t *messages.MessageTarget, msg sm.Envelope) error

ViaPDU forwards the supplied message to the Rack's simulated PDU for processing. This may or may not impact the full PDU and the all blades, or only one blade's power state.

func (*Rack) ViaTor 

func (r *Rack) ViaTor(ctx context.Context, t *messages.MessageTarget, msg sm.Envelope) error

ViaTor forwards the supplied message to the Rack's simulated TOR for processing. This will likely not be the final destination, but requires operation by the TOR in order to reach its final destination.

Source Files

View all Source files

Directories

Path Synopsis

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.