problemclient

Documentation

Index

• Constants
• type Client
  • func NewClientOrDie(npdo *options.NodeProblemDetectorOptions) Client
• type FakeProblemClient
  • func NewFakeProblemClient() *FakeProblemClient
  • func (f *FakeProblemClient) AssertConditions(expected []v1.NodeCondition) error
  • func (f *FakeProblemClient) Eventf(eventType string, source, reason, messageFmt string, args ...interface{})
  • func (f *FakeProblemClient) GetConditions(ctx context.Context, types []v1.NodeConditionType) ([]*v1.NodeCondition, error)
  • func (f *FakeProblemClient) GetNode(ctx context.Context) (*v1.Node, error)
  • func (f *FakeProblemClient) InjectError(fun string, err error)
  • func (f *FakeProblemClient) SetConditions(ctx context.Context, conditions []v1.NodeCondition) error

Constants

const (
	APIVersion = "v1"
)

Types

type Client

type Client interface {
	// GetConditions get all specific conditions of current node.
	GetConditions(ctx context.Context, conditionTypes []v1.NodeConditionType) ([]*v1.NodeCondition, error)
	// SetConditions set or update conditions of current node.
	SetConditions(ctx context.Context, conditionTypes []v1.NodeCondition) error
	// Eventf reports the event.
	Eventf(eventType string, source, reason, messageFmt string, args ...interface{})
	// GetNode returns the Node object of the node on which the
	// node-problem-detector runs.
	GetNode(ctx context.Context) (*v1.Node, error)
}

Client is the interface of problem client

func NewClientOrDie

func NewClientOrDie(npdo *options.NodeProblemDetectorOptions) Client

NewClientOrDie creates a new problem client, panics if error occurs.

type FakeProblemClient

type FakeProblemClient struct {
	sync.Mutex
	// contains filtered or unexported fields
}

FakeProblemClient is a fake problem client for debug.

func NewFakeProblemClient

func NewFakeProblemClient() *FakeProblemClient

NewFakeProblemClient creates a new fake problem client.

func (*FakeProblemClient) AssertConditions

func (f *FakeProblemClient) AssertConditions(expected []v1.NodeCondition) error

AssertConditions asserts that the internal conditions in fake problem client should match the expected conditions.

func (*FakeProblemClient) Eventf

func (f *FakeProblemClient) Eventf(eventType string, source, reason, messageFmt string, args ...interface{})

Eventf does nothing now.

func (*FakeProblemClient) GetConditions

func (f *FakeProblemClient) GetConditions(ctx context.Context, types []v1.NodeConditionType) ([]*v1.NodeCondition, error)

GetConditions is a fake mimic of GetConditions, it returns the conditions cached internally.

func (*FakeProblemClient) GetNode

func (f *FakeProblemClient) GetNode(ctx context.Context) (*v1.Node, error)

func (*FakeProblemClient) InjectError

func (f *FakeProblemClient) InjectError(fun string, err error)

InjectError injects error to specific function.

func (*FakeProblemClient) SetConditions

func (f *FakeProblemClient) SetConditions(ctx context.Context, conditions []v1.NodeCondition) error

SetConditions is a fake mimic of SetConditions, it only update the internal condition cache.