Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type FailureStatus ¶
type FailureStatus struct {
// contains filtered or unexported fields
}
FailureStatus implements the required methods for the FailureStatus GRPC service.
func NewFailureStatus ¶
func NewFailureStatus(stateUpdateInterval time.Duration, serializer serializer.Serializer, service service.FailureStatusService, clock clock.Clock, logger log.Logger) *FailureStatus
NewFailureStatus returns a new FailureStatus.
func (*FailureStatus) FailureStateList ¶
func (f *FailureStatus) FailureStateList(nodeID *pbfs.NodeId, stream pbfs.FailureStatus_FailureStateListServer) error
FailureStateList returns periodically the state of the current state of the failures.
func (*FailureStatus) GetFailure ¶
func (f *FailureStatus) GetFailure(ctx context.Context, fID *pbfs.FailureId) (*chaosv1pb.Failure, error)
GetFailure returns a failure detail.
type NodeStatus ¶
type NodeStatus struct {
// contains filtered or unexported fields
}
NodeStatus implements the required GRPC service methods for node status service.
func NewNodeStatus ¶
func NewNodeStatus(service service.NodeStatusService, serializer serializer.Serializer, logger log.Logger) *NodeStatus
NewNodeStatus returns a new NodeStatus.
func (*NodeStatus) Heartbeat ¶
func (n *NodeStatus) Heartbeat(ctx context.Context, nodepb *clusterv1pb.Node) (*emptypb.Empty, error)
Heartbeat sets the current status of a node.
func (*NodeStatus) Register ¶
func (n *NodeStatus) Register(ctx context.Context, nodepb *clusterv1pb.Node) (*emptypb.Empty, error)
Register registers a node on the master.
Source Files
Click to show internal directories.
Click to hide internal directories.