grpc

Documentation

Index

• type TestClient
  • func NewTestClient(addr string) (*TestClient, error)
  • func (t *TestClient) Close() error
  • func (t *TestClient) FailureStatusFailureStateList(ctx context.Context, nID *pbfs.NodeId) (pbfs.FailureStatus_FailureStateListClient, error)
  • func (t *TestClient) FailureStatusGetFailure(ctx context.Context, fID *pbfs.FailureId) (*chaosv1pb.Failure, error)
  • func (t *TestClient) NodeStatusHeartbeat(ctx context.Context, n *clusterv1pb.Node) (*pbempty.Empty, error)
  • func (t *TestClient) NodeStatusRegister(ctx context.Context, n *clusterv1pb.Node) (*pbempty.Empty, error)

Types

type TestClient

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

TestClient is a GRPC client ready to test GRPC services

func NewTestClient

func NewTestClient(addr string) (*TestClient, error)

NewTestClient creates and returns a new test client

func (*TestClient) Close

func (t *TestClient) Close() error

Close closes the GRPC connection.

func (*TestClient) FailureStatusFailureStateList

func (t *TestClient) FailureStatusFailureStateList(ctx context.Context, nID *pbfs.NodeId) (pbfs.FailureStatus_FailureStateListClient, error)

FailureStatusFailureStateList wraps the call to failurestatus service.

func (*TestClient) FailureStatusGetFailure

func (t *TestClient) FailureStatusGetFailure(ctx context.Context, fID *pbfs.FailureId) (*chaosv1pb.Failure, error)

FailureStatusGetFailure wraps the call to failurestatus service.

func (*TestClient) NodeStatusHeartbeat

func (t *TestClient) NodeStatusHeartbeat(ctx context.Context, n *clusterv1pb.Node) (*pbempty.Empty, error)

NodeStatusHeartbeat wraps the call to nodestatus service.

func (*TestClient) NodeStatusRegister

func (t *TestClient) NodeStatusRegister(ctx context.Context, n *clusterv1pb.Node) (*pbempty.Empty, error)

NodeStatusRegister wraps the call to nodestatus service.