pb

package
v2.0.0 Latest Latest
Warning

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

Go to latest
Published: Apr 23, 2023 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	Chain_Direction_name = map[int32]string{
		0: "INPUT",
		1: "OUTPUT",
	}
	Chain_Direction_value = map[string]int32{
		"INPUT":  0,
		"OUTPUT": 1,
	}
)

Enum value maps for Chain_Direction.

View Source
var (
	ContainerAction_Action_name = map[int32]string{
		0: "KILL",
		1: "GETPID",
	}
	ContainerAction_Action_value = map[string]int32{
		"KILL":   0,
		"GETPID": 1,
	}
)

Enum value maps for ContainerAction_Action.

View Source
var (
	ExecStressRequest_Scope_name = map[int32]string{
		0: "CONTAINER",
		1: "POD",
	}
	ExecStressRequest_Scope_value = map[string]int32{
		"CONTAINER": 0,
		"POD":       1,
	}
)

Enum value maps for ExecStressRequest_Scope.

View Source
var (
	Tc_Type_name = map[int32]string{
		0: "NETEM",
		1: "BANDWIDTH",
	}
	Tc_Type_value = map[string]int32{
		"NETEM":     0,
		"BANDWIDTH": 1,
	}
)

Enum value maps for Tc_Type.

View Source
var (
	ApplyBlockChaosRequest_Action_name = map[int32]string{
		0: "Delay",
	}
	ApplyBlockChaosRequest_Action_value = map[string]int32{
		"Delay": 0,
	}
)

Enum value maps for ApplyBlockChaosRequest_Action.

View Source
var File_chaosdaemon_proto protoreflect.FileDescriptor

Functions

func RegisterChaosDaemonServer

func RegisterChaosDaemonServer(s *grpc.Server, srv ChaosDaemonServer)

Types

type ApplyBlockChaosRequest

type ApplyBlockChaosRequest struct {
	ContainerId string                        `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	VolumePath  string                        `protobuf:"bytes,2,opt,name=volume_path,json=volumePath,proto3" json:"volume_path,omitempty"`
	Action      ApplyBlockChaosRequest_Action `protobuf:"varint,3,opt,name=action,proto3,enum=pb.ApplyBlockChaosRequest_Action" json:"action,omitempty"`
	Delay       *BlockDelaySpec               `protobuf:"bytes,5,opt,name=delay,proto3" json:"delay,omitempty"`
	EnterNS     bool                          `protobuf:"varint,6,opt,name=enterNS,proto3" json:"enterNS,omitempty"`
	// contains filtered or unexported fields
}

func (*ApplyBlockChaosRequest) Descriptor deprecated

func (*ApplyBlockChaosRequest) Descriptor() ([]byte, []int)

Deprecated: Use ApplyBlockChaosRequest.ProtoReflect.Descriptor instead.

func (*ApplyBlockChaosRequest) GetAction

func (*ApplyBlockChaosRequest) GetContainerId

func (x *ApplyBlockChaosRequest) GetContainerId() string

func (*ApplyBlockChaosRequest) GetDelay

func (x *ApplyBlockChaosRequest) GetDelay() *BlockDelaySpec

func (*ApplyBlockChaosRequest) GetEnterNS

func (x *ApplyBlockChaosRequest) GetEnterNS() bool

func (*ApplyBlockChaosRequest) GetVolumePath

func (x *ApplyBlockChaosRequest) GetVolumePath() string

func (*ApplyBlockChaosRequest) ProtoMessage

func (*ApplyBlockChaosRequest) ProtoMessage()

func (*ApplyBlockChaosRequest) ProtoReflect

func (x *ApplyBlockChaosRequest) ProtoReflect() protoreflect.Message

func (*ApplyBlockChaosRequest) Reset

func (x *ApplyBlockChaosRequest) Reset()

func (*ApplyBlockChaosRequest) String

func (x *ApplyBlockChaosRequest) String() string

type ApplyBlockChaosRequest_Action

type ApplyBlockChaosRequest_Action int32
const (
	ApplyBlockChaosRequest_Delay ApplyBlockChaosRequest_Action = 0
)

func (ApplyBlockChaosRequest_Action) Descriptor

func (ApplyBlockChaosRequest_Action) Enum

func (ApplyBlockChaosRequest_Action) EnumDescriptor deprecated

func (ApplyBlockChaosRequest_Action) EnumDescriptor() ([]byte, []int)

Deprecated: Use ApplyBlockChaosRequest_Action.Descriptor instead.

func (ApplyBlockChaosRequest_Action) Number

func (ApplyBlockChaosRequest_Action) String

func (ApplyBlockChaosRequest_Action) Type

type ApplyBlockChaosResponse

type ApplyBlockChaosResponse struct {
	InjectionId int32 `protobuf:"varint,1,opt,name=injection_id,json=injectionId,proto3" json:"injection_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ApplyBlockChaosResponse) Descriptor deprecated

func (*ApplyBlockChaosResponse) Descriptor() ([]byte, []int)

Deprecated: Use ApplyBlockChaosResponse.ProtoReflect.Descriptor instead.

func (*ApplyBlockChaosResponse) GetInjectionId

func (x *ApplyBlockChaosResponse) GetInjectionId() int32

func (*ApplyBlockChaosResponse) ProtoMessage

func (*ApplyBlockChaosResponse) ProtoMessage()

func (*ApplyBlockChaosResponse) ProtoReflect

func (x *ApplyBlockChaosResponse) ProtoReflect() protoreflect.Message

func (*ApplyBlockChaosResponse) Reset

func (x *ApplyBlockChaosResponse) Reset()

func (*ApplyBlockChaosResponse) String

func (x *ApplyBlockChaosResponse) String() string

type ApplyHttpChaosRequest

type ApplyHttpChaosRequest struct {
	Rules       string   `protobuf:"bytes,1,opt,name=rules,proto3" json:"rules,omitempty"`
	ProxyPorts  []uint32 `protobuf:"varint,2,rep,packed,name=proxy_ports,json=proxyPorts,proto3" json:"proxy_ports,omitempty"`
	ContainerId string   `protobuf:"bytes,3,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	Instance    int64    `protobuf:"varint,4,opt,name=instance,proto3" json:"instance,omitempty"`
	StartTime   int64    `protobuf:"varint,5,opt,name=startTime,proto3" json:"startTime,omitempty"`
	EnterNS     bool     `protobuf:"varint,6,opt,name=enterNS,proto3" json:"enterNS,omitempty"`
	InstanceUid string   `protobuf:"bytes,7,opt,name=instance_uid,json=instanceUid,proto3" json:"instance_uid,omitempty"`
	Tls         string   `protobuf:"bytes,8,opt,name=tls,proto3" json:"tls,omitempty"`
	// contains filtered or unexported fields
}

func (*ApplyHttpChaosRequest) Descriptor deprecated

func (*ApplyHttpChaosRequest) Descriptor() ([]byte, []int)

Deprecated: Use ApplyHttpChaosRequest.ProtoReflect.Descriptor instead.

func (*ApplyHttpChaosRequest) GetContainerId

func (x *ApplyHttpChaosRequest) GetContainerId() string

func (*ApplyHttpChaosRequest) GetEnterNS

func (x *ApplyHttpChaosRequest) GetEnterNS() bool

func (*ApplyHttpChaosRequest) GetInstance

func (x *ApplyHttpChaosRequest) GetInstance() int64

func (*ApplyHttpChaosRequest) GetInstanceUid

func (x *ApplyHttpChaosRequest) GetInstanceUid() string

func (*ApplyHttpChaosRequest) GetProxyPorts

func (x *ApplyHttpChaosRequest) GetProxyPorts() []uint32

func (*ApplyHttpChaosRequest) GetRules

func (x *ApplyHttpChaosRequest) GetRules() string

func (*ApplyHttpChaosRequest) GetStartTime

func (x *ApplyHttpChaosRequest) GetStartTime() int64

func (*ApplyHttpChaosRequest) GetTls

func (x *ApplyHttpChaosRequest) GetTls() string

func (*ApplyHttpChaosRequest) ProtoMessage

func (*ApplyHttpChaosRequest) ProtoMessage()

func (*ApplyHttpChaosRequest) ProtoReflect

func (x *ApplyHttpChaosRequest) ProtoReflect() protoreflect.Message

func (*ApplyHttpChaosRequest) Reset

func (x *ApplyHttpChaosRequest) Reset()

func (*ApplyHttpChaosRequest) String

func (x *ApplyHttpChaosRequest) String() string

type ApplyHttpChaosResponse

type ApplyHttpChaosResponse struct {
	Instance    int64  `protobuf:"varint,1,opt,name=instance,proto3" json:"instance,omitempty"`
	StartTime   int64  `protobuf:"varint,2,opt,name=startTime,proto3" json:"startTime,omitempty"`
	StatusCode  int32  `protobuf:"varint,3,opt,name=statusCode,proto3" json:"statusCode,omitempty"`
	Error       string `protobuf:"bytes,4,opt,name=error,proto3" json:"error,omitempty"`
	InstanceUid string `protobuf:"bytes,5,opt,name=instance_uid,json=instanceUid,proto3" json:"instance_uid,omitempty"`
	// contains filtered or unexported fields
}

func (*ApplyHttpChaosResponse) Descriptor deprecated

func (*ApplyHttpChaosResponse) Descriptor() ([]byte, []int)

Deprecated: Use ApplyHttpChaosResponse.ProtoReflect.Descriptor instead.

func (*ApplyHttpChaosResponse) GetError

func (x *ApplyHttpChaosResponse) GetError() string

func (*ApplyHttpChaosResponse) GetInstance

func (x *ApplyHttpChaosResponse) GetInstance() int64

func (*ApplyHttpChaosResponse) GetInstanceUid

func (x *ApplyHttpChaosResponse) GetInstanceUid() string

func (*ApplyHttpChaosResponse) GetStartTime

func (x *ApplyHttpChaosResponse) GetStartTime() int64

func (*ApplyHttpChaosResponse) GetStatusCode

func (x *ApplyHttpChaosResponse) GetStatusCode() int32

func (*ApplyHttpChaosResponse) ProtoMessage

func (*ApplyHttpChaosResponse) ProtoMessage()

func (*ApplyHttpChaosResponse) ProtoReflect

func (x *ApplyHttpChaosResponse) ProtoReflect() protoreflect.Message

func (*ApplyHttpChaosResponse) Reset

func (x *ApplyHttpChaosResponse) Reset()

func (*ApplyHttpChaosResponse) String

func (x *ApplyHttpChaosResponse) String() string

type ApplyIOChaosRequest

type ApplyIOChaosRequest struct {
	Actions     string `protobuf:"bytes,1,opt,name=actions,proto3" json:"actions,omitempty"`
	Volume      string `protobuf:"bytes,2,opt,name=volume,proto3" json:"volume,omitempty"`
	ContainerId string `protobuf:"bytes,3,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	Instance    int64  `protobuf:"varint,4,opt,name=instance,proto3" json:"instance,omitempty"`
	StartTime   int64  `protobuf:"varint,5,opt,name=startTime,proto3" json:"startTime,omitempty"`
	EnterNS     bool   `protobuf:"varint,6,opt,name=enterNS,proto3" json:"enterNS,omitempty"`
	InstanceUid string `protobuf:"bytes,7,opt,name=instance_uid,json=instanceUid,proto3" json:"instance_uid,omitempty"`
	// contains filtered or unexported fields
}

func (*ApplyIOChaosRequest) Descriptor deprecated

func (*ApplyIOChaosRequest) Descriptor() ([]byte, []int)

Deprecated: Use ApplyIOChaosRequest.ProtoReflect.Descriptor instead.

func (*ApplyIOChaosRequest) GetActions

func (x *ApplyIOChaosRequest) GetActions() string

func (*ApplyIOChaosRequest) GetContainerId

func (x *ApplyIOChaosRequest) GetContainerId() string

func (*ApplyIOChaosRequest) GetEnterNS

func (x *ApplyIOChaosRequest) GetEnterNS() bool

func (*ApplyIOChaosRequest) GetInstance

func (x *ApplyIOChaosRequest) GetInstance() int64

func (*ApplyIOChaosRequest) GetInstanceUid

func (x *ApplyIOChaosRequest) GetInstanceUid() string

func (*ApplyIOChaosRequest) GetStartTime

func (x *ApplyIOChaosRequest) GetStartTime() int64

func (*ApplyIOChaosRequest) GetVolume

func (x *ApplyIOChaosRequest) GetVolume() string

func (*ApplyIOChaosRequest) ProtoMessage

func (*ApplyIOChaosRequest) ProtoMessage()

func (*ApplyIOChaosRequest) ProtoReflect

func (x *ApplyIOChaosRequest) ProtoReflect() protoreflect.Message

func (*ApplyIOChaosRequest) Reset

func (x *ApplyIOChaosRequest) Reset()

func (*ApplyIOChaosRequest) String

func (x *ApplyIOChaosRequest) String() string

type ApplyIOChaosResponse

type ApplyIOChaosResponse struct {
	Instance    int64  `protobuf:"varint,1,opt,name=instance,proto3" json:"instance,omitempty"`
	StartTime   int64  `protobuf:"varint,2,opt,name=startTime,proto3" json:"startTime,omitempty"`
	InstanceUid string `protobuf:"bytes,3,opt,name=instance_uid,json=instanceUid,proto3" json:"instance_uid,omitempty"`
	// contains filtered or unexported fields
}

func (*ApplyIOChaosResponse) Descriptor deprecated

func (*ApplyIOChaosResponse) Descriptor() ([]byte, []int)

Deprecated: Use ApplyIOChaosResponse.ProtoReflect.Descriptor instead.

func (*ApplyIOChaosResponse) GetInstance

func (x *ApplyIOChaosResponse) GetInstance() int64

func (*ApplyIOChaosResponse) GetInstanceUid

func (x *ApplyIOChaosResponse) GetInstanceUid() string

func (*ApplyIOChaosResponse) GetStartTime

func (x *ApplyIOChaosResponse) GetStartTime() int64

func (*ApplyIOChaosResponse) ProtoMessage

func (*ApplyIOChaosResponse) ProtoMessage()

func (*ApplyIOChaosResponse) ProtoReflect

func (x *ApplyIOChaosResponse) ProtoReflect() protoreflect.Message

func (*ApplyIOChaosResponse) Reset

func (x *ApplyIOChaosResponse) Reset()

func (*ApplyIOChaosResponse) String

func (x *ApplyIOChaosResponse) String() string

type BlockDelaySpec

type BlockDelaySpec struct {
	Delay       int64   `protobuf:"varint,1,opt,name=delay,proto3" json:"delay,omitempty"`
	Correlation float64 `protobuf:"fixed64,2,opt,name=correlation,proto3" json:"correlation,omitempty"`
	Jitter      int64   `protobuf:"varint,3,opt,name=jitter,proto3" json:"jitter,omitempty"`
	// contains filtered or unexported fields
}

func (*BlockDelaySpec) Descriptor deprecated

func (*BlockDelaySpec) Descriptor() ([]byte, []int)

Deprecated: Use BlockDelaySpec.ProtoReflect.Descriptor instead.

func (*BlockDelaySpec) GetCorrelation

func (x *BlockDelaySpec) GetCorrelation() float64

func (*BlockDelaySpec) GetDelay

func (x *BlockDelaySpec) GetDelay() int64

func (*BlockDelaySpec) GetJitter

func (x *BlockDelaySpec) GetJitter() int64

func (*BlockDelaySpec) ProtoMessage

func (*BlockDelaySpec) ProtoMessage()

func (*BlockDelaySpec) ProtoReflect

func (x *BlockDelaySpec) ProtoReflect() protoreflect.Message

func (*BlockDelaySpec) Reset

func (x *BlockDelaySpec) Reset()

func (*BlockDelaySpec) String

func (x *BlockDelaySpec) String() string

type BlockLimitSpec

type BlockLimitSpec struct {
	Quota    uint64 `protobuf:"varint,1,opt,name=quota,proto3" json:"quota,omitempty"`
	PeriodUs uint64 `protobuf:"varint,2,opt,name=period_us,json=periodUs,proto3" json:"period_us,omitempty"`
	// contains filtered or unexported fields
}

func (*BlockLimitSpec) Descriptor deprecated

func (*BlockLimitSpec) Descriptor() ([]byte, []int)

Deprecated: Use BlockLimitSpec.ProtoReflect.Descriptor instead.

func (*BlockLimitSpec) GetPeriodUs

func (x *BlockLimitSpec) GetPeriodUs() uint64

func (*BlockLimitSpec) GetQuota

func (x *BlockLimitSpec) GetQuota() uint64

func (*BlockLimitSpec) ProtoMessage

func (*BlockLimitSpec) ProtoMessage()

func (*BlockLimitSpec) ProtoReflect

func (x *BlockLimitSpec) ProtoReflect() protoreflect.Message

func (*BlockLimitSpec) Reset

func (x *BlockLimitSpec) Reset()

func (*BlockLimitSpec) String

func (x *BlockLimitSpec) String() string

type CancelStressRequest

type CancelStressRequest struct {
	CpuInstance       string `protobuf:"bytes,1,opt,name=cpuInstance,proto3" json:"cpuInstance,omitempty"`
	CpuStartTime      int64  `protobuf:"varint,2,opt,name=cpuStartTime,proto3" json:"cpuStartTime,omitempty"`
	MemoryInstance    string `protobuf:"bytes,3,opt,name=memoryInstance,proto3" json:"memoryInstance,omitempty"`
	MemoryStartTime   int64  `protobuf:"varint,4,opt,name=memoryStartTime,proto3" json:"memoryStartTime,omitempty"`
	CpuInstanceUid    string `protobuf:"bytes,5,opt,name=cpuInstanceUid,proto3" json:"cpuInstanceUid,omitempty"`
	MemoryInstanceUid string `protobuf:"bytes,6,opt,name=memoryInstanceUid,proto3" json:"memoryInstanceUid,omitempty"`
	// contains filtered or unexported fields
}

func (*CancelStressRequest) Descriptor deprecated

func (*CancelStressRequest) Descriptor() ([]byte, []int)

Deprecated: Use CancelStressRequest.ProtoReflect.Descriptor instead.

func (*CancelStressRequest) GetCpuInstance

func (x *CancelStressRequest) GetCpuInstance() string

func (*CancelStressRequest) GetCpuInstanceUid

func (x *CancelStressRequest) GetCpuInstanceUid() string

func (*CancelStressRequest) GetCpuStartTime

func (x *CancelStressRequest) GetCpuStartTime() int64

func (*CancelStressRequest) GetMemoryInstance

func (x *CancelStressRequest) GetMemoryInstance() string

func (*CancelStressRequest) GetMemoryInstanceUid

func (x *CancelStressRequest) GetMemoryInstanceUid() string

func (*CancelStressRequest) GetMemoryStartTime

func (x *CancelStressRequest) GetMemoryStartTime() int64

func (*CancelStressRequest) ProtoMessage

func (*CancelStressRequest) ProtoMessage()

func (*CancelStressRequest) ProtoReflect

func (x *CancelStressRequest) ProtoReflect() protoreflect.Message

func (*CancelStressRequest) Reset

func (x *CancelStressRequest) Reset()

func (*CancelStressRequest) String

func (x *CancelStressRequest) String() string

type Chain

type Chain struct {
	Name             string          `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Direction        Chain_Direction `protobuf:"varint,2,opt,name=direction,proto3,enum=pb.Chain_Direction" json:"direction,omitempty"`
	Ipsets           []string        `protobuf:"bytes,3,rep,name=ipsets,proto3" json:"ipsets,omitempty"`
	Target           string          `protobuf:"bytes,4,opt,name=target,proto3" json:"target,omitempty"`
	Protocol         string          `protobuf:"bytes,5,opt,name=protocol,proto3" json:"protocol,omitempty"`
	SourcePorts      string          `protobuf:"bytes,6,opt,name=source_ports,json=sourcePorts,proto3" json:"source_ports,omitempty"`
	DestinationPorts string          `protobuf:"bytes,7,opt,name=destination_ports,json=destinationPorts,proto3" json:"destination_ports,omitempty"`
	TcpFlags         string          `protobuf:"bytes,8,opt,name=tcp_flags,json=tcpFlags,proto3" json:"tcp_flags,omitempty"`
	Device           string          `protobuf:"bytes,9,opt,name=device,proto3" json:"device,omitempty"`
	// contains filtered or unexported fields
}

func (*Chain) Descriptor deprecated

func (*Chain) Descriptor() ([]byte, []int)

Deprecated: Use Chain.ProtoReflect.Descriptor instead.

func (*Chain) GetDestinationPorts

func (x *Chain) GetDestinationPorts() string

func (*Chain) GetDevice

func (x *Chain) GetDevice() string

func (*Chain) GetDirection

func (x *Chain) GetDirection() Chain_Direction

func (*Chain) GetIpsets

func (x *Chain) GetIpsets() []string

func (*Chain) GetName

func (x *Chain) GetName() string

func (*Chain) GetProtocol

func (x *Chain) GetProtocol() string

func (*Chain) GetSourcePorts

func (x *Chain) GetSourcePorts() string

func (*Chain) GetTarget

func (x *Chain) GetTarget() string

func (*Chain) GetTcpFlags

func (x *Chain) GetTcpFlags() string

func (*Chain) ProtoMessage

func (*Chain) ProtoMessage()

func (*Chain) ProtoReflect

func (x *Chain) ProtoReflect() protoreflect.Message

func (*Chain) Reset

func (x *Chain) Reset()

func (*Chain) String

func (x *Chain) String() string

type Chain_Direction

type Chain_Direction int32
const (
	Chain_INPUT  Chain_Direction = 0
	Chain_OUTPUT Chain_Direction = 1
)

func (Chain_Direction) Descriptor

func (Chain_Direction) Enum

func (x Chain_Direction) Enum() *Chain_Direction

func (Chain_Direction) EnumDescriptor deprecated

func (Chain_Direction) EnumDescriptor() ([]byte, []int)

Deprecated: Use Chain_Direction.Descriptor instead.

func (Chain_Direction) Number

func (Chain_Direction) String

func (x Chain_Direction) String() string

func (Chain_Direction) Type

type ChaosDaemonClient

type ChaosDaemonClient interface {
	SetTcs(ctx context.Context, in *TcsRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	FlushIPSets(ctx context.Context, in *IPSetsRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	SetIptablesChains(ctx context.Context, in *IptablesChainsRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	SetTimeOffset(ctx context.Context, in *TimeRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	RecoverTimeOffset(ctx context.Context, in *TimeRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	ContainerKill(ctx context.Context, in *ContainerRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	ContainerGetPid(ctx context.Context, in *ContainerRequest, opts ...grpc.CallOption) (*ContainerResponse, error)
	ExecStressors(ctx context.Context, in *ExecStressRequest, opts ...grpc.CallOption) (*ExecStressResponse, error)
	CancelStressors(ctx context.Context, in *CancelStressRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	ApplyIOChaos(ctx context.Context, in *ApplyIOChaosRequest, opts ...grpc.CallOption) (*ApplyIOChaosResponse, error)
	ApplyHttpChaos(ctx context.Context, in *ApplyHttpChaosRequest, opts ...grpc.CallOption) (*ApplyHttpChaosResponse, error)
	ApplyBlockChaos(ctx context.Context, in *ApplyBlockChaosRequest, opts ...grpc.CallOption) (*ApplyBlockChaosResponse, error)
	RecoverBlockChaos(ctx context.Context, in *RecoverBlockChaosRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	SetDNSServer(ctx context.Context, in *SetDNSServerRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	InstallJVMRules(ctx context.Context, in *InstallJVMRulesRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	UninstallJVMRules(ctx context.Context, in *UninstallJVMRulesRequest, opts ...grpc.CallOption) (*empty.Empty, error)
}

ChaosDaemonClient is the client API for ChaosDaemon service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

type ChaosDaemonServer

ChaosDaemonServer is the server API for ChaosDaemon service.

type CidrAndPort

type CidrAndPort struct {
	Cidr string `protobuf:"bytes,1,opt,name=cidr,proto3" json:"cidr,omitempty"`
	Port uint32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
	// contains filtered or unexported fields
}

func (*CidrAndPort) Descriptor deprecated

func (*CidrAndPort) Descriptor() ([]byte, []int)

Deprecated: Use CidrAndPort.ProtoReflect.Descriptor instead.

func (*CidrAndPort) GetCidr

func (x *CidrAndPort) GetCidr() string

func (*CidrAndPort) GetPort

func (x *CidrAndPort) GetPort() uint32

func (*CidrAndPort) ProtoMessage

func (*CidrAndPort) ProtoMessage()

func (*CidrAndPort) ProtoReflect

func (x *CidrAndPort) ProtoReflect() protoreflect.Message

func (*CidrAndPort) Reset

func (x *CidrAndPort) Reset()

func (*CidrAndPort) String

func (x *CidrAndPort) String() string

type ContainerAction

type ContainerAction struct {
	Action ContainerAction_Action `protobuf:"varint,1,opt,name=action,proto3,enum=pb.ContainerAction_Action" json:"action,omitempty"`
	// contains filtered or unexported fields
}

func (*ContainerAction) Descriptor deprecated

func (*ContainerAction) Descriptor() ([]byte, []int)

Deprecated: Use ContainerAction.ProtoReflect.Descriptor instead.

func (*ContainerAction) GetAction

func (x *ContainerAction) GetAction() ContainerAction_Action

func (*ContainerAction) ProtoMessage

func (*ContainerAction) ProtoMessage()

func (*ContainerAction) ProtoReflect

func (x *ContainerAction) ProtoReflect() protoreflect.Message

func (*ContainerAction) Reset

func (x *ContainerAction) Reset()

func (*ContainerAction) String

func (x *ContainerAction) String() string

type ContainerAction_Action

type ContainerAction_Action int32
const (
	ContainerAction_KILL   ContainerAction_Action = 0
	ContainerAction_GETPID ContainerAction_Action = 1
)

func (ContainerAction_Action) Descriptor

func (ContainerAction_Action) Enum

func (ContainerAction_Action) EnumDescriptor deprecated

func (ContainerAction_Action) EnumDescriptor() ([]byte, []int)

Deprecated: Use ContainerAction_Action.Descriptor instead.

func (ContainerAction_Action) Number

func (ContainerAction_Action) String

func (x ContainerAction_Action) String() string

func (ContainerAction_Action) Type

type ContainerRequest

type ContainerRequest struct {
	Action      *ContainerAction `protobuf:"bytes,1,opt,name=action,proto3" json:"action,omitempty"`
	ContainerId string           `protobuf:"bytes,2,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ContainerRequest) Descriptor deprecated

func (*ContainerRequest) Descriptor() ([]byte, []int)

Deprecated: Use ContainerRequest.ProtoReflect.Descriptor instead.

func (*ContainerRequest) GetAction

func (x *ContainerRequest) GetAction() *ContainerAction

func (*ContainerRequest) GetContainerId

func (x *ContainerRequest) GetContainerId() string

func (*ContainerRequest) ProtoMessage

func (*ContainerRequest) ProtoMessage()

func (*ContainerRequest) ProtoReflect

func (x *ContainerRequest) ProtoReflect() protoreflect.Message

func (*ContainerRequest) Reset

func (x *ContainerRequest) Reset()

func (*ContainerRequest) String

func (x *ContainerRequest) String() string

type ContainerResponse

type ContainerResponse struct {
	Pid uint32 `protobuf:"varint,1,opt,name=pid,proto3" json:"pid,omitempty"`
	// contains filtered or unexported fields
}

func (*ContainerResponse) Descriptor deprecated

func (*ContainerResponse) Descriptor() ([]byte, []int)

Deprecated: Use ContainerResponse.ProtoReflect.Descriptor instead.

func (*ContainerResponse) GetPid

func (x *ContainerResponse) GetPid() uint32

func (*ContainerResponse) ProtoMessage

func (*ContainerResponse) ProtoMessage()

func (*ContainerResponse) ProtoReflect

func (x *ContainerResponse) ProtoReflect() protoreflect.Message

func (*ContainerResponse) Reset

func (x *ContainerResponse) Reset()

func (*ContainerResponse) String

func (x *ContainerResponse) String() string

type EmatchFilter

type EmatchFilter struct {
	Match   string    `protobuf:"bytes,1,opt,name=match,proto3" json:"match,omitempty"`
	Parent  *TcHandle `protobuf:"bytes,2,opt,name=parent,proto3" json:"parent,omitempty"`
	Classid *TcHandle `protobuf:"bytes,3,opt,name=classid,proto3" json:"classid,omitempty"`
	// contains filtered or unexported fields
}

func (*EmatchFilter) Descriptor deprecated

func (*EmatchFilter) Descriptor() ([]byte, []int)

Deprecated: Use EmatchFilter.ProtoReflect.Descriptor instead.

func (*EmatchFilter) GetClassid

func (x *EmatchFilter) GetClassid() *TcHandle

func (*EmatchFilter) GetMatch

func (x *EmatchFilter) GetMatch() string

func (*EmatchFilter) GetParent

func (x *EmatchFilter) GetParent() *TcHandle

func (*EmatchFilter) ProtoMessage

func (*EmatchFilter) ProtoMessage()

func (*EmatchFilter) ProtoReflect

func (x *EmatchFilter) ProtoReflect() protoreflect.Message

func (*EmatchFilter) Reset

func (x *EmatchFilter) Reset()

func (*EmatchFilter) String

func (x *EmatchFilter) String() string

type EmatchFilterRequest

type EmatchFilterRequest struct {
	Filter      *EmatchFilter `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"`
	ContainerId string        `protobuf:"bytes,2,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	// contains filtered or unexported fields
}

func (*EmatchFilterRequest) Descriptor deprecated

func (*EmatchFilterRequest) Descriptor() ([]byte, []int)

Deprecated: Use EmatchFilterRequest.ProtoReflect.Descriptor instead.

func (*EmatchFilterRequest) GetContainerId

func (x *EmatchFilterRequest) GetContainerId() string

func (*EmatchFilterRequest) GetFilter

func (x *EmatchFilterRequest) GetFilter() *EmatchFilter

func (*EmatchFilterRequest) ProtoMessage

func (*EmatchFilterRequest) ProtoMessage()

func (*EmatchFilterRequest) ProtoReflect

func (x *EmatchFilterRequest) ProtoReflect() protoreflect.Message

func (*EmatchFilterRequest) Reset

func (x *EmatchFilterRequest) Reset()

func (*EmatchFilterRequest) String

func (x *EmatchFilterRequest) String() string

type ExecStressRequest

type ExecStressRequest struct {
	Scope           ExecStressRequest_Scope `protobuf:"varint,1,opt,name=scope,proto3,enum=pb.ExecStressRequest_Scope" json:"scope,omitempty"`
	Target          string                  `protobuf:"bytes,2,opt,name=target,proto3" json:"target,omitempty"`
	CpuStressors    string                  `protobuf:"bytes,3,opt,name=cpuStressors,proto3" json:"cpuStressors,omitempty"`
	EnterNS         bool                    `protobuf:"varint,4,opt,name=enterNS,proto3" json:"enterNS,omitempty"`
	MemoryStressors string                  `protobuf:"bytes,5,opt,name=memoryStressors,proto3" json:"memoryStressors,omitempty"`
	OomScoreAdj     int32                   `protobuf:"varint,7,opt,name=oomScoreAdj,proto3" json:"oomScoreAdj,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecStressRequest) Descriptor deprecated

func (*ExecStressRequest) Descriptor() ([]byte, []int)

Deprecated: Use ExecStressRequest.ProtoReflect.Descriptor instead.

func (*ExecStressRequest) GetCpuStressors

func (x *ExecStressRequest) GetCpuStressors() string

func (*ExecStressRequest) GetEnterNS

func (x *ExecStressRequest) GetEnterNS() bool

func (*ExecStressRequest) GetMemoryStressors

func (x *ExecStressRequest) GetMemoryStressors() string

func (*ExecStressRequest) GetOomScoreAdj

func (x *ExecStressRequest) GetOomScoreAdj() int32

func (*ExecStressRequest) GetScope

func (*ExecStressRequest) GetTarget

func (x *ExecStressRequest) GetTarget() string

func (*ExecStressRequest) ProtoMessage

func (*ExecStressRequest) ProtoMessage()

func (*ExecStressRequest) ProtoReflect

func (x *ExecStressRequest) ProtoReflect() protoreflect.Message

func (*ExecStressRequest) Reset

func (x *ExecStressRequest) Reset()

func (*ExecStressRequest) String

func (x *ExecStressRequest) String() string

type ExecStressRequest_Scope

type ExecStressRequest_Scope int32
const (
	ExecStressRequest_CONTAINER ExecStressRequest_Scope = 0
	ExecStressRequest_POD       ExecStressRequest_Scope = 1
)

func (ExecStressRequest_Scope) Descriptor

func (ExecStressRequest_Scope) Enum

func (ExecStressRequest_Scope) EnumDescriptor deprecated

func (ExecStressRequest_Scope) EnumDescriptor() ([]byte, []int)

Deprecated: Use ExecStressRequest_Scope.Descriptor instead.

func (ExecStressRequest_Scope) Number

func (ExecStressRequest_Scope) String

func (x ExecStressRequest_Scope) String() string

func (ExecStressRequest_Scope) Type

type ExecStressResponse

type ExecStressResponse struct {
	CpuInstance       string `protobuf:"bytes,1,opt,name=cpuInstance,proto3" json:"cpuInstance,omitempty"`
	CpuStartTime      int64  `protobuf:"varint,2,opt,name=cpuStartTime,proto3" json:"cpuStartTime,omitempty"`
	MemoryInstance    string `protobuf:"bytes,3,opt,name=memoryInstance,proto3" json:"memoryInstance,omitempty"`
	MemoryStartTime   int64  `protobuf:"varint,4,opt,name=memoryStartTime,proto3" json:"memoryStartTime,omitempty"`
	CpuInstanceUid    string `protobuf:"bytes,5,opt,name=cpuInstanceUid,proto3" json:"cpuInstanceUid,omitempty"`
	MemoryInstanceUid string `protobuf:"bytes,6,opt,name=memoryInstanceUid,proto3" json:"memoryInstanceUid,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecStressResponse) Descriptor deprecated

func (*ExecStressResponse) Descriptor() ([]byte, []int)

Deprecated: Use ExecStressResponse.ProtoReflect.Descriptor instead.

func (*ExecStressResponse) GetCpuInstance

func (x *ExecStressResponse) GetCpuInstance() string

func (*ExecStressResponse) GetCpuInstanceUid

func (x *ExecStressResponse) GetCpuInstanceUid() string

func (*ExecStressResponse) GetCpuStartTime

func (x *ExecStressResponse) GetCpuStartTime() int64

func (*ExecStressResponse) GetMemoryInstance

func (x *ExecStressResponse) GetMemoryInstance() string

func (*ExecStressResponse) GetMemoryInstanceUid

func (x *ExecStressResponse) GetMemoryInstanceUid() string

func (*ExecStressResponse) GetMemoryStartTime

func (x *ExecStressResponse) GetMemoryStartTime() int64

func (*ExecStressResponse) ProtoMessage

func (*ExecStressResponse) ProtoMessage()

func (*ExecStressResponse) ProtoReflect

func (x *ExecStressResponse) ProtoReflect() protoreflect.Message

func (*ExecStressResponse) Reset

func (x *ExecStressResponse) Reset()

func (*ExecStressResponse) String

func (x *ExecStressResponse) String() string

type IPSet

type IPSet struct {
	Name         string         `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Cidrs        []string       `protobuf:"bytes,2,rep,name=cidrs,proto3" json:"cidrs,omitempty"`
	CidrAndPorts []*CidrAndPort `protobuf:"bytes,3,rep,name=cidr_and_ports,json=cidrAndPorts,proto3" json:"cidr_and_ports,omitempty"`
	SetNames     []string       `protobuf:"bytes,4,rep,name=set_names,json=setNames,proto3" json:"set_names,omitempty"`
	Type         string         `protobuf:"bytes,5,opt,name=type,proto3" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*IPSet) Descriptor deprecated

func (*IPSet) Descriptor() ([]byte, []int)

Deprecated: Use IPSet.ProtoReflect.Descriptor instead.

func (*IPSet) GetCidrAndPorts

func (x *IPSet) GetCidrAndPorts() []*CidrAndPort

func (*IPSet) GetCidrs

func (x *IPSet) GetCidrs() []string

func (*IPSet) GetName

func (x *IPSet) GetName() string

func (*IPSet) GetSetNames

func (x *IPSet) GetSetNames() []string

func (*IPSet) GetType

func (x *IPSet) GetType() string

func (*IPSet) ProtoMessage

func (*IPSet) ProtoMessage()

func (*IPSet) ProtoReflect

func (x *IPSet) ProtoReflect() protoreflect.Message

func (*IPSet) Reset

func (x *IPSet) Reset()

func (*IPSet) String

func (x *IPSet) String() string

type IPSetsRequest

type IPSetsRequest struct {
	Ipsets      []*IPSet `protobuf:"bytes,1,rep,name=ipsets,proto3" json:"ipsets,omitempty"`
	ContainerId string   `protobuf:"bytes,2,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	EnterNS     bool     `protobuf:"varint,3,opt,name=enterNS,proto3" json:"enterNS,omitempty"`
	// contains filtered or unexported fields
}

func (*IPSetsRequest) Descriptor deprecated

func (*IPSetsRequest) Descriptor() ([]byte, []int)

Deprecated: Use IPSetsRequest.ProtoReflect.Descriptor instead.

func (*IPSetsRequest) GetContainerId

func (x *IPSetsRequest) GetContainerId() string

func (*IPSetsRequest) GetEnterNS

func (x *IPSetsRequest) GetEnterNS() bool

func (*IPSetsRequest) GetIpsets

func (x *IPSetsRequest) GetIpsets() []*IPSet

func (*IPSetsRequest) ProtoMessage

func (*IPSetsRequest) ProtoMessage()

func (*IPSetsRequest) ProtoReflect

func (x *IPSetsRequest) ProtoReflect() protoreflect.Message

func (*IPSetsRequest) Reset

func (x *IPSetsRequest) Reset()

func (*IPSetsRequest) String

func (x *IPSetsRequest) String() string

type InstallJVMRulesRequest

type InstallJVMRulesRequest struct {
	ContainerId string `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	Rule        string `protobuf:"bytes,2,opt,name=rule,proto3" json:"rule,omitempty"`
	Port        int32  `protobuf:"varint,3,opt,name=port,proto3" json:"port,omitempty"`
	EnterNS     bool   `protobuf:"varint,4,opt,name=enterNS,proto3" json:"enterNS,omitempty"`
	// contains filtered or unexported fields
}

func (*InstallJVMRulesRequest) Descriptor deprecated

func (*InstallJVMRulesRequest) Descriptor() ([]byte, []int)

Deprecated: Use InstallJVMRulesRequest.ProtoReflect.Descriptor instead.

func (*InstallJVMRulesRequest) GetContainerId

func (x *InstallJVMRulesRequest) GetContainerId() string

func (*InstallJVMRulesRequest) GetEnterNS

func (x *InstallJVMRulesRequest) GetEnterNS() bool

func (*InstallJVMRulesRequest) GetPort

func (x *InstallJVMRulesRequest) GetPort() int32

func (*InstallJVMRulesRequest) GetRule

func (x *InstallJVMRulesRequest) GetRule() string

func (*InstallJVMRulesRequest) ProtoMessage

func (*InstallJVMRulesRequest) ProtoMessage()

func (*InstallJVMRulesRequest) ProtoReflect

func (x *InstallJVMRulesRequest) ProtoReflect() protoreflect.Message

func (*InstallJVMRulesRequest) Reset

func (x *InstallJVMRulesRequest) Reset()

func (*InstallJVMRulesRequest) String

func (x *InstallJVMRulesRequest) String() string

type IptablesChainsRequest

type IptablesChainsRequest struct {
	Chains      []*Chain `protobuf:"bytes,1,rep,name=chains,proto3" json:"chains,omitempty"`
	ContainerId string   `protobuf:"bytes,2,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	EnterNS     bool     `protobuf:"varint,3,opt,name=enterNS,proto3" json:"enterNS,omitempty"`
	// contains filtered or unexported fields
}

func (*IptablesChainsRequest) Descriptor deprecated

func (*IptablesChainsRequest) Descriptor() ([]byte, []int)

Deprecated: Use IptablesChainsRequest.ProtoReflect.Descriptor instead.

func (*IptablesChainsRequest) GetChains

func (x *IptablesChainsRequest) GetChains() []*Chain

func (*IptablesChainsRequest) GetContainerId

func (x *IptablesChainsRequest) GetContainerId() string

func (*IptablesChainsRequest) GetEnterNS

func (x *IptablesChainsRequest) GetEnterNS() bool

func (*IptablesChainsRequest) ProtoMessage

func (*IptablesChainsRequest) ProtoMessage()

func (*IptablesChainsRequest) ProtoReflect

func (x *IptablesChainsRequest) ProtoReflect() protoreflect.Message

func (*IptablesChainsRequest) Reset

func (x *IptablesChainsRequest) Reset()

func (*IptablesChainsRequest) String

func (x *IptablesChainsRequest) String() string

type Netem

type Netem struct {
	Time          uint32    `protobuf:"varint,1,opt,name=time,proto3" json:"time,omitempty"`
	Jitter        uint32    `protobuf:"varint,2,opt,name=jitter,proto3" json:"jitter,omitempty"`
	DelayCorr     float32   `protobuf:"fixed32,3,opt,name=delay_corr,json=delayCorr,proto3" json:"delay_corr,omitempty"`
	Limit         uint32    `protobuf:"varint,4,opt,name=limit,proto3" json:"limit,omitempty"`
	Loss          float32   `protobuf:"fixed32,5,opt,name=loss,proto3" json:"loss,omitempty"`
	LossCorr      float32   `protobuf:"fixed32,6,opt,name=loss_corr,json=lossCorr,proto3" json:"loss_corr,omitempty"`
	Gap           uint32    `protobuf:"varint,7,opt,name=gap,proto3" json:"gap,omitempty"`
	Duplicate     float32   `protobuf:"fixed32,8,opt,name=duplicate,proto3" json:"duplicate,omitempty"`
	DuplicateCorr float32   `protobuf:"fixed32,9,opt,name=duplicate_corr,json=duplicateCorr,proto3" json:"duplicate_corr,omitempty"`
	Reorder       float32   `protobuf:"fixed32,10,opt,name=reorder,proto3" json:"reorder,omitempty"`
	ReorderCorr   float32   `protobuf:"fixed32,11,opt,name=reorder_corr,json=reorderCorr,proto3" json:"reorder_corr,omitempty"`
	Corrupt       float32   `protobuf:"fixed32,12,opt,name=corrupt,proto3" json:"corrupt,omitempty"`
	CorruptCorr   float32   `protobuf:"fixed32,13,opt,name=corrupt_corr,json=corruptCorr,proto3" json:"corrupt_corr,omitempty"`
	Parent        *TcHandle `protobuf:"bytes,14,opt,name=parent,proto3" json:"parent,omitempty"`
	Handle        *TcHandle `protobuf:"bytes,15,opt,name=handle,proto3" json:"handle,omitempty"`
	// contains filtered or unexported fields
}

func (*Netem) Descriptor deprecated

func (*Netem) Descriptor() ([]byte, []int)

Deprecated: Use Netem.ProtoReflect.Descriptor instead.

func (*Netem) GetCorrupt

func (x *Netem) GetCorrupt() float32

func (*Netem) GetCorruptCorr

func (x *Netem) GetCorruptCorr() float32

func (*Netem) GetDelayCorr

func (x *Netem) GetDelayCorr() float32

func (*Netem) GetDuplicate

func (x *Netem) GetDuplicate() float32

func (*Netem) GetDuplicateCorr

func (x *Netem) GetDuplicateCorr() float32

func (*Netem) GetGap

func (x *Netem) GetGap() uint32

func (*Netem) GetHandle

func (x *Netem) GetHandle() *TcHandle

func (*Netem) GetJitter

func (x *Netem) GetJitter() uint32

func (*Netem) GetLimit

func (x *Netem) GetLimit() uint32

func (*Netem) GetLoss

func (x *Netem) GetLoss() float32

func (*Netem) GetLossCorr

func (x *Netem) GetLossCorr() float32

func (*Netem) GetParent

func (x *Netem) GetParent() *TcHandle

func (*Netem) GetReorder

func (x *Netem) GetReorder() float32

func (*Netem) GetReorderCorr

func (x *Netem) GetReorderCorr() float32

func (*Netem) GetTime

func (x *Netem) GetTime() uint32

func (*Netem) ProtoMessage

func (*Netem) ProtoMessage()

func (*Netem) ProtoReflect

func (x *Netem) ProtoReflect() protoreflect.Message

func (*Netem) Reset

func (x *Netem) Reset()

func (*Netem) String

func (x *Netem) String() string

type NetemRequest

type NetemRequest struct {
	Netem       *Netem    `protobuf:"bytes,1,opt,name=netem,proto3" json:"netem,omitempty"`
	ContainerId string    `protobuf:"bytes,2,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	Handle      *TcHandle `protobuf:"bytes,3,opt,name=handle,proto3" json:"handle,omitempty"`
	Parent      *TcHandle `protobuf:"bytes,4,opt,name=parent,proto3" json:"parent,omitempty"`
	// contains filtered or unexported fields
}

func (*NetemRequest) Descriptor deprecated

func (*NetemRequest) Descriptor() ([]byte, []int)

Deprecated: Use NetemRequest.ProtoReflect.Descriptor instead.

func (*NetemRequest) GetContainerId

func (x *NetemRequest) GetContainerId() string

func (*NetemRequest) GetHandle

func (x *NetemRequest) GetHandle() *TcHandle

func (*NetemRequest) GetNetem

func (x *NetemRequest) GetNetem() *Netem

func (*NetemRequest) GetParent

func (x *NetemRequest) GetParent() *TcHandle

func (*NetemRequest) ProtoMessage

func (*NetemRequest) ProtoMessage()

func (*NetemRequest) ProtoReflect

func (x *NetemRequest) ProtoReflect() protoreflect.Message

func (*NetemRequest) Reset

func (x *NetemRequest) Reset()

func (*NetemRequest) String

func (x *NetemRequest) String() string

type Qdisc

type Qdisc struct {
	Parent *TcHandle `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	Handle *TcHandle `protobuf:"bytes,2,opt,name=handle,proto3" json:"handle,omitempty"`
	Type   string    `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
	Args   []string  `protobuf:"bytes,4,rep,name=args,proto3" json:"args,omitempty"`
	// contains filtered or unexported fields
}

func (*Qdisc) Descriptor deprecated

func (*Qdisc) Descriptor() ([]byte, []int)

Deprecated: Use Qdisc.ProtoReflect.Descriptor instead.

func (*Qdisc) GetArgs

func (x *Qdisc) GetArgs() []string

func (*Qdisc) GetHandle

func (x *Qdisc) GetHandle() *TcHandle

func (*Qdisc) GetParent

func (x *Qdisc) GetParent() *TcHandle

func (*Qdisc) GetType

func (x *Qdisc) GetType() string

func (*Qdisc) ProtoMessage

func (*Qdisc) ProtoMessage()

func (*Qdisc) ProtoReflect

func (x *Qdisc) ProtoReflect() protoreflect.Message

func (*Qdisc) Reset

func (x *Qdisc) Reset()

func (*Qdisc) String

func (x *Qdisc) String() string

type QdiscRequest

type QdiscRequest struct {
	Qdisc       *Qdisc `protobuf:"bytes,1,opt,name=qdisc,proto3" json:"qdisc,omitempty"`
	ContainerId string `protobuf:"bytes,2,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	// contains filtered or unexported fields
}

func (*QdiscRequest) Descriptor deprecated

func (*QdiscRequest) Descriptor() ([]byte, []int)

Deprecated: Use QdiscRequest.ProtoReflect.Descriptor instead.

func (*QdiscRequest) GetContainerId

func (x *QdiscRequest) GetContainerId() string

func (*QdiscRequest) GetQdisc

func (x *QdiscRequest) GetQdisc() *Qdisc

func (*QdiscRequest) ProtoMessage

func (*QdiscRequest) ProtoMessage()

func (*QdiscRequest) ProtoReflect

func (x *QdiscRequest) ProtoReflect() protoreflect.Message

func (*QdiscRequest) Reset

func (x *QdiscRequest) Reset()

func (*QdiscRequest) String

func (x *QdiscRequest) String() string

type RecoverBlockChaosRequest

type RecoverBlockChaosRequest struct {
	InjectionId int32 `protobuf:"varint,1,opt,name=injection_id,json=injectionId,proto3" json:"injection_id,omitempty"`
	// contains filtered or unexported fields
}

func (*RecoverBlockChaosRequest) Descriptor deprecated

func (*RecoverBlockChaosRequest) Descriptor() ([]byte, []int)

Deprecated: Use RecoverBlockChaosRequest.ProtoReflect.Descriptor instead.

func (*RecoverBlockChaosRequest) GetInjectionId

func (x *RecoverBlockChaosRequest) GetInjectionId() int32

func (*RecoverBlockChaosRequest) ProtoMessage

func (*RecoverBlockChaosRequest) ProtoMessage()

func (*RecoverBlockChaosRequest) ProtoReflect

func (x *RecoverBlockChaosRequest) ProtoReflect() protoreflect.Message

func (*RecoverBlockChaosRequest) Reset

func (x *RecoverBlockChaosRequest) Reset()

func (*RecoverBlockChaosRequest) String

func (x *RecoverBlockChaosRequest) String() string

type SetDNSServerRequest

type SetDNSServerRequest struct {
	ContainerId string `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	DnsServer   string `protobuf:"bytes,2,opt,name=dns_server,json=dnsServer,proto3" json:"dns_server,omitempty"`
	Enable      bool   `protobuf:"varint,3,opt,name=enable,proto3" json:"enable,omitempty"`
	EnterNS     bool   `protobuf:"varint,4,opt,name=enterNS,proto3" json:"enterNS,omitempty"`
	// contains filtered or unexported fields
}

func (*SetDNSServerRequest) Descriptor deprecated

func (*SetDNSServerRequest) Descriptor() ([]byte, []int)

Deprecated: Use SetDNSServerRequest.ProtoReflect.Descriptor instead.

func (*SetDNSServerRequest) GetContainerId

func (x *SetDNSServerRequest) GetContainerId() string

func (*SetDNSServerRequest) GetDnsServer

func (x *SetDNSServerRequest) GetDnsServer() string

func (*SetDNSServerRequest) GetEnable

func (x *SetDNSServerRequest) GetEnable() bool

func (*SetDNSServerRequest) GetEnterNS

func (x *SetDNSServerRequest) GetEnterNS() bool

func (*SetDNSServerRequest) ProtoMessage

func (*SetDNSServerRequest) ProtoMessage()

func (*SetDNSServerRequest) ProtoReflect

func (x *SetDNSServerRequest) ProtoReflect() protoreflect.Message

func (*SetDNSServerRequest) Reset

func (x *SetDNSServerRequest) Reset()

func (*SetDNSServerRequest) String

func (x *SetDNSServerRequest) String() string

type Tbf

type Tbf struct {
	Rate     uint64 `protobuf:"varint,1,opt,name=rate,proto3" json:"rate,omitempty"`
	Limit    uint32 `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"`
	Buffer   uint32 `protobuf:"varint,3,opt,name=buffer,proto3" json:"buffer,omitempty"`
	PeakRate uint64 `protobuf:"varint,4,opt,name=peak_rate,json=peakRate,proto3" json:"peak_rate,omitempty"`
	MinBurst uint32 `protobuf:"varint,5,opt,name=min_burst,json=minBurst,proto3" json:"min_burst,omitempty"`
	// contains filtered or unexported fields
}

func (*Tbf) Descriptor deprecated

func (*Tbf) Descriptor() ([]byte, []int)

Deprecated: Use Tbf.ProtoReflect.Descriptor instead.

func (*Tbf) GetBuffer

func (x *Tbf) GetBuffer() uint32

func (*Tbf) GetLimit

func (x *Tbf) GetLimit() uint32

func (*Tbf) GetMinBurst

func (x *Tbf) GetMinBurst() uint32

func (*Tbf) GetPeakRate

func (x *Tbf) GetPeakRate() uint64

func (*Tbf) GetRate

func (x *Tbf) GetRate() uint64

func (*Tbf) ProtoMessage

func (*Tbf) ProtoMessage()

func (*Tbf) ProtoReflect

func (x *Tbf) ProtoReflect() protoreflect.Message

func (*Tbf) Reset

func (x *Tbf) Reset()

func (*Tbf) String

func (x *Tbf) String() string

type TbfRequest

type TbfRequest struct {
	Tbf         *Tbf   `protobuf:"bytes,1,opt,name=tbf,proto3" json:"tbf,omitempty"`
	ContainerId string `protobuf:"bytes,2,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	// contains filtered or unexported fields
}

func (*TbfRequest) Descriptor deprecated

func (*TbfRequest) Descriptor() ([]byte, []int)

Deprecated: Use TbfRequest.ProtoReflect.Descriptor instead.

func (*TbfRequest) GetContainerId

func (x *TbfRequest) GetContainerId() string

func (*TbfRequest) GetTbf

func (x *TbfRequest) GetTbf() *Tbf

func (*TbfRequest) ProtoMessage

func (*TbfRequest) ProtoMessage()

func (*TbfRequest) ProtoReflect

func (x *TbfRequest) ProtoReflect() protoreflect.Message

func (*TbfRequest) Reset

func (x *TbfRequest) Reset()

func (*TbfRequest) String

func (x *TbfRequest) String() string

type Tc

type Tc struct {
	Type       Tc_Type `protobuf:"varint,1,opt,name=type,proto3,enum=pb.Tc_Type" json:"type,omitempty"`
	Netem      *Netem  `protobuf:"bytes,2,opt,name=netem,proto3" json:"netem,omitempty"`
	Tbf        *Tbf    `protobuf:"bytes,3,opt,name=tbf,proto3" json:"tbf,omitempty"`
	Ipset      string  `protobuf:"bytes,4,opt,name=ipset,proto3" json:"ipset,omitempty"`
	Protocol   string  `protobuf:"bytes,5,opt,name=protocol,proto3" json:"protocol,omitempty"`
	SourcePort string  `protobuf:"bytes,6,opt,name=source_port,json=sourcePort,proto3" json:"source_port,omitempty"`
	EgressPort string  `protobuf:"bytes,7,opt,name=egress_port,json=egressPort,proto3" json:"egress_port,omitempty"`
	Device     string  `protobuf:"bytes,9,opt,name=device,proto3" json:"device,omitempty"`
	// contains filtered or unexported fields
}

func (*Tc) Descriptor deprecated

func (*Tc) Descriptor() ([]byte, []int)

Deprecated: Use Tc.ProtoReflect.Descriptor instead.

func (*Tc) GetDevice

func (x *Tc) GetDevice() string

func (*Tc) GetEgressPort

func (x *Tc) GetEgressPort() string

func (*Tc) GetIpset

func (x *Tc) GetIpset() string

func (*Tc) GetNetem

func (x *Tc) GetNetem() *Netem

func (*Tc) GetProtocol

func (x *Tc) GetProtocol() string

func (*Tc) GetSourcePort

func (x *Tc) GetSourcePort() string

func (*Tc) GetTbf

func (x *Tc) GetTbf() *Tbf

func (*Tc) GetType

func (x *Tc) GetType() Tc_Type

func (*Tc) ProtoMessage

func (*Tc) ProtoMessage()

func (*Tc) ProtoReflect

func (x *Tc) ProtoReflect() protoreflect.Message

func (*Tc) Reset

func (x *Tc) Reset()

func (*Tc) String

func (x *Tc) String() string

type TcFilter

type TcFilter struct {
	Parent *TcHandle `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// contains filtered or unexported fields
}

func (*TcFilter) Descriptor deprecated

func (*TcFilter) Descriptor() ([]byte, []int)

Deprecated: Use TcFilter.ProtoReflect.Descriptor instead.

func (*TcFilter) GetParent

func (x *TcFilter) GetParent() *TcHandle

func (*TcFilter) ProtoMessage

func (*TcFilter) ProtoMessage()

func (*TcFilter) ProtoReflect

func (x *TcFilter) ProtoReflect() protoreflect.Message

func (*TcFilter) Reset

func (x *TcFilter) Reset()

func (*TcFilter) String

func (x *TcFilter) String() string

type TcFilterRequest

type TcFilterRequest struct {
	Filter      *TcFilter `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"`
	ContainerId string    `protobuf:"bytes,2,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	// contains filtered or unexported fields
}

func (*TcFilterRequest) Descriptor deprecated

func (*TcFilterRequest) Descriptor() ([]byte, []int)

Deprecated: Use TcFilterRequest.ProtoReflect.Descriptor instead.

func (*TcFilterRequest) GetContainerId

func (x *TcFilterRequest) GetContainerId() string

func (*TcFilterRequest) GetFilter

func (x *TcFilterRequest) GetFilter() *TcFilter

func (*TcFilterRequest) ProtoMessage

func (*TcFilterRequest) ProtoMessage()

func (*TcFilterRequest) ProtoReflect

func (x *TcFilterRequest) ProtoReflect() protoreflect.Message

func (*TcFilterRequest) Reset

func (x *TcFilterRequest) Reset()

func (*TcFilterRequest) String

func (x *TcFilterRequest) String() string

type TcHandle

type TcHandle struct {
	Major uint32 `protobuf:"varint,1,opt,name=major,proto3" json:"major,omitempty"`
	Minor uint32 `protobuf:"varint,2,opt,name=minor,proto3" json:"minor,omitempty"`
	// contains filtered or unexported fields
}

func (*TcHandle) Descriptor deprecated

func (*TcHandle) Descriptor() ([]byte, []int)

Deprecated: Use TcHandle.ProtoReflect.Descriptor instead.

func (*TcHandle) GetMajor

func (x *TcHandle) GetMajor() uint32

func (*TcHandle) GetMinor

func (x *TcHandle) GetMinor() uint32

func (*TcHandle) ProtoMessage

func (*TcHandle) ProtoMessage()

func (*TcHandle) ProtoReflect

func (x *TcHandle) ProtoReflect() protoreflect.Message

func (*TcHandle) Reset

func (x *TcHandle) Reset()

func (*TcHandle) String

func (x *TcHandle) String() string

type Tc_Type

type Tc_Type int32
const (
	Tc_NETEM     Tc_Type = 0
	Tc_BANDWIDTH Tc_Type = 1
)

func (Tc_Type) Descriptor

func (Tc_Type) Descriptor() protoreflect.EnumDescriptor

func (Tc_Type) Enum

func (x Tc_Type) Enum() *Tc_Type

func (Tc_Type) EnumDescriptor deprecated

func (Tc_Type) EnumDescriptor() ([]byte, []int)

Deprecated: Use Tc_Type.Descriptor instead.

func (Tc_Type) Number

func (x Tc_Type) Number() protoreflect.EnumNumber

func (Tc_Type) String

func (x Tc_Type) String() string

func (Tc_Type) Type

func (Tc_Type) Type() protoreflect.EnumType

type TcsRequest

type TcsRequest struct {
	Tcs         []*Tc  `protobuf:"bytes,1,rep,name=tcs,proto3" json:"tcs,omitempty"`
	ContainerId string `protobuf:"bytes,2,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	EnterNS     bool   `protobuf:"varint,4,opt,name=enterNS,proto3" json:"enterNS,omitempty"`
	// contains filtered or unexported fields
}

func (*TcsRequest) Descriptor deprecated

func (*TcsRequest) Descriptor() ([]byte, []int)

Deprecated: Use TcsRequest.ProtoReflect.Descriptor instead.

func (*TcsRequest) GetContainerId

func (x *TcsRequest) GetContainerId() string

func (*TcsRequest) GetEnterNS

func (x *TcsRequest) GetEnterNS() bool

func (*TcsRequest) GetTcs

func (x *TcsRequest) GetTcs() []*Tc

func (*TcsRequest) ProtoMessage

func (*TcsRequest) ProtoMessage()

func (*TcsRequest) ProtoReflect

func (x *TcsRequest) ProtoReflect() protoreflect.Message

func (*TcsRequest) Reset

func (x *TcsRequest) Reset()

func (*TcsRequest) String

func (x *TcsRequest) String() string

type TimeRequest

type TimeRequest struct {
	ContainerId      string `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	Sec              int64  `protobuf:"varint,2,opt,name=sec,proto3" json:"sec,omitempty"`
	Nsec             int64  `protobuf:"varint,3,opt,name=nsec,proto3" json:"nsec,omitempty"`
	ClkIdsMask       uint64 `protobuf:"varint,4,opt,name=clk_ids_mask,json=clkIdsMask,proto3" json:"clk_ids_mask,omitempty"`
	Uid              string `protobuf:"bytes,5,opt,name=uid,proto3" json:"uid,omitempty"`
	PodContainerName string `protobuf:"bytes,6,opt,name=pod_container_name,json=podContainerName,proto3" json:"pod_container_name,omitempty"`
	// contains filtered or unexported fields
}

func (*TimeRequest) Descriptor deprecated

func (*TimeRequest) Descriptor() ([]byte, []int)

Deprecated: Use TimeRequest.ProtoReflect.Descriptor instead.

func (*TimeRequest) GetClkIdsMask

func (x *TimeRequest) GetClkIdsMask() uint64

func (*TimeRequest) GetContainerId

func (x *TimeRequest) GetContainerId() string

func (*TimeRequest) GetNsec

func (x *TimeRequest) GetNsec() int64

func (*TimeRequest) GetPodContainerName

func (x *TimeRequest) GetPodContainerName() string

func (*TimeRequest) GetSec

func (x *TimeRequest) GetSec() int64

func (*TimeRequest) GetUid

func (x *TimeRequest) GetUid() string

func (*TimeRequest) ProtoMessage

func (*TimeRequest) ProtoMessage()

func (*TimeRequest) ProtoReflect

func (x *TimeRequest) ProtoReflect() protoreflect.Message

func (*TimeRequest) Reset

func (x *TimeRequest) Reset()

func (*TimeRequest) String

func (x *TimeRequest) String() string

type UnimplementedChaosDaemonServer

type UnimplementedChaosDaemonServer struct {
}

UnimplementedChaosDaemonServer can be embedded to have forward compatible implementations.

func (*UnimplementedChaosDaemonServer) ApplyBlockChaos

func (*UnimplementedChaosDaemonServer) ApplyHttpChaos

func (*UnimplementedChaosDaemonServer) ApplyIOChaos

func (*UnimplementedChaosDaemonServer) CancelStressors

func (*UnimplementedChaosDaemonServer) ContainerGetPid

func (*UnimplementedChaosDaemonServer) ContainerKill

func (*UnimplementedChaosDaemonServer) ExecStressors

func (*UnimplementedChaosDaemonServer) FlushIPSets

func (*UnimplementedChaosDaemonServer) InstallJVMRules

func (*UnimplementedChaosDaemonServer) RecoverBlockChaos

func (*UnimplementedChaosDaemonServer) RecoverTimeOffset

func (*UnimplementedChaosDaemonServer) SetDNSServer

func (*UnimplementedChaosDaemonServer) SetIptablesChains

func (*UnimplementedChaosDaemonServer) SetTcs

func (*UnimplementedChaosDaemonServer) SetTimeOffset

func (*UnimplementedChaosDaemonServer) UninstallJVMRules

type UninstallJVMRulesRequest

type UninstallJVMRulesRequest struct {
	ContainerId string `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	Rule        string `protobuf:"bytes,2,opt,name=rule,proto3" json:"rule,omitempty"`
	Port        int32  `protobuf:"varint,3,opt,name=port,proto3" json:"port,omitempty"`
	EnterNS     bool   `protobuf:"varint,4,opt,name=enterNS,proto3" json:"enterNS,omitempty"`
	// contains filtered or unexported fields
}

func (*UninstallJVMRulesRequest) Descriptor deprecated

func (*UninstallJVMRulesRequest) Descriptor() ([]byte, []int)

Deprecated: Use UninstallJVMRulesRequest.ProtoReflect.Descriptor instead.

func (*UninstallJVMRulesRequest) GetContainerId

func (x *UninstallJVMRulesRequest) GetContainerId() string

func (*UninstallJVMRulesRequest) GetEnterNS

func (x *UninstallJVMRulesRequest) GetEnterNS() bool

func (*UninstallJVMRulesRequest) GetPort

func (x *UninstallJVMRulesRequest) GetPort() int32

func (*UninstallJVMRulesRequest) GetRule

func (x *UninstallJVMRulesRequest) GetRule() string

func (*UninstallJVMRulesRequest) ProtoMessage

func (*UninstallJVMRulesRequest) ProtoMessage()

func (*UninstallJVMRulesRequest) ProtoReflect

func (x *UninstallJVMRulesRequest) ProtoReflect() protoreflect.Message

func (*UninstallJVMRulesRequest) Reset

func (x *UninstallJVMRulesRequest) Reset()

func (*UninstallJVMRulesRequest) String

func (x *UninstallJVMRulesRequest) String() string

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL