Enum value maps for Chain_Direction.
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 ContainerAction_Action.
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 ExecStressRequest_Scope.
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 Tc_Type.
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 ApplyBlockChaosRequest_Action.
var (
ApplyBlockChaosRequest_Action_name = map[int32]string{
0: "Delay",
}
ApplyBlockChaosRequest_Action_value = map[string]int32{
"Delay": 0,
}
)
var File_chaosdaemon_proto protoreflect.FileDescriptor
func RegisterChaosDaemonServer(s *grpc.Server, srv ChaosDaemonServer)
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() ([]byte, []int)
Deprecated: Use ApplyBlockChaosRequest.ProtoReflect.Descriptor instead.
func (x *ApplyBlockChaosRequest) GetAction() ApplyBlockChaosRequest_Action
func (x *ApplyBlockChaosRequest) GetContainerId() string
func (x *ApplyBlockChaosRequest) GetDelay() *BlockDelaySpec
func (x *ApplyBlockChaosRequest) GetEnterNS() bool
func (x *ApplyBlockChaosRequest) GetVolumePath() string
func (*ApplyBlockChaosRequest) ProtoMessage()
func (x *ApplyBlockChaosRequest) ProtoReflect() protoreflect.Message
func (x *ApplyBlockChaosRequest) Reset()
func (x *ApplyBlockChaosRequest) String() string
type ApplyBlockChaosRequest_Action int32
const (
ApplyBlockChaosRequest_Delay ApplyBlockChaosRequest_Action = 0
)
func (ApplyBlockChaosRequest_Action) Descriptor() protoreflect.EnumDescriptor
func (x ApplyBlockChaosRequest_Action) Enum() *ApplyBlockChaosRequest_Action
func (ApplyBlockChaosRequest_Action) EnumDescriptor() ([]byte, []int)
Deprecated: Use ApplyBlockChaosRequest_Action.Descriptor instead.
func (x ApplyBlockChaosRequest_Action) Number() protoreflect.EnumNumber
func (x ApplyBlockChaosRequest_Action) String() string
func (ApplyBlockChaosRequest_Action) Type() protoreflect.EnumType
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() ([]byte, []int)
Deprecated: Use ApplyBlockChaosResponse.ProtoReflect.Descriptor instead.
func (x *ApplyBlockChaosResponse) GetInjectionId() int32
func (*ApplyBlockChaosResponse) ProtoMessage()
func (x *ApplyBlockChaosResponse) ProtoReflect() protoreflect.Message
func (x *ApplyBlockChaosResponse) Reset()
func (x *ApplyBlockChaosResponse) String() string
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() ([]byte, []int)
Deprecated: Use ApplyHttpChaosRequest.ProtoReflect.Descriptor instead.
func (x *ApplyHttpChaosRequest) GetContainerId() string
func (x *ApplyHttpChaosRequest) GetEnterNS() bool
func (x *ApplyHttpChaosRequest) GetInstance() int64
func (x *ApplyHttpChaosRequest) GetInstanceUid() string
func (x *ApplyHttpChaosRequest) GetProxyPorts() []uint32
func (x *ApplyHttpChaosRequest) GetRules() string
func (x *ApplyHttpChaosRequest) GetStartTime() int64
func (x *ApplyHttpChaosRequest) GetTls() string
func (*ApplyHttpChaosRequest) ProtoMessage()
func (x *ApplyHttpChaosRequest) ProtoReflect() protoreflect.Message
func (x *ApplyHttpChaosRequest) Reset()
func (x *ApplyHttpChaosRequest) String() string
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() ([]byte, []int)
Deprecated: Use ApplyHttpChaosResponse.ProtoReflect.Descriptor instead.
func (x *ApplyHttpChaosResponse) GetError() string
func (x *ApplyHttpChaosResponse) GetInstance() int64
func (x *ApplyHttpChaosResponse) GetInstanceUid() string
func (x *ApplyHttpChaosResponse) GetStartTime() int64
func (x *ApplyHttpChaosResponse) GetStatusCode() int32
func (*ApplyHttpChaosResponse) ProtoMessage()
func (x *ApplyHttpChaosResponse) ProtoReflect() protoreflect.Message
func (x *ApplyHttpChaosResponse) Reset()
func (x *ApplyHttpChaosResponse) String() string
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() ([]byte, []int)
Deprecated: Use ApplyIOChaosRequest.ProtoReflect.Descriptor instead.
func (x *ApplyIOChaosRequest) GetActions() string
func (x *ApplyIOChaosRequest) GetContainerId() string
func (x *ApplyIOChaosRequest) GetEnterNS() bool
func (x *ApplyIOChaosRequest) GetInstance() int64
func (x *ApplyIOChaosRequest) GetInstanceUid() string
func (x *ApplyIOChaosRequest) GetStartTime() int64
func (x *ApplyIOChaosRequest) GetVolume() string
func (*ApplyIOChaosRequest) ProtoMessage()
func (x *ApplyIOChaosRequest) ProtoReflect() protoreflect.Message
func (x *ApplyIOChaosRequest) Reset()
func (x *ApplyIOChaosRequest) String() string
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() ([]byte, []int)
Deprecated: Use ApplyIOChaosResponse.ProtoReflect.Descriptor instead.
func (x *ApplyIOChaosResponse) GetInstance() int64
func (x *ApplyIOChaosResponse) GetInstanceUid() string
func (x *ApplyIOChaosResponse) GetStartTime() int64
func (*ApplyIOChaosResponse) ProtoMessage()
func (x *ApplyIOChaosResponse) ProtoReflect() protoreflect.Message
func (x *ApplyIOChaosResponse) Reset()
func (x *ApplyIOChaosResponse) String() string
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() ([]byte, []int)
Deprecated: Use BlockDelaySpec.ProtoReflect.Descriptor instead.
func (x *BlockDelaySpec) GetCorrelation() float64
func (x *BlockDelaySpec) GetDelay() int64
func (x *BlockDelaySpec) GetJitter() int64
func (*BlockDelaySpec) ProtoMessage()
func (x *BlockDelaySpec) ProtoReflect() protoreflect.Message
func (x *BlockDelaySpec) Reset()
func (x *BlockDelaySpec) String() string
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() ([]byte, []int)
Deprecated: Use BlockLimitSpec.ProtoReflect.Descriptor instead.
func (x *BlockLimitSpec) GetPeriodUs() uint64
func (x *BlockLimitSpec) GetQuota() uint64
func (*BlockLimitSpec) ProtoMessage()
func (x *BlockLimitSpec) ProtoReflect() protoreflect.Message
func (x *BlockLimitSpec) Reset()
func (x *BlockLimitSpec) String() string
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() ([]byte, []int)
Deprecated: Use CancelStressRequest.ProtoReflect.Descriptor instead.
func (x *CancelStressRequest) GetCpuInstance() string
func (x *CancelStressRequest) GetCpuInstanceUid() string
func (x *CancelStressRequest) GetCpuStartTime() int64
func (x *CancelStressRequest) GetMemoryInstance() string
func (x *CancelStressRequest) GetMemoryInstanceUid() string
func (x *CancelStressRequest) GetMemoryStartTime() int64
func (*CancelStressRequest) ProtoMessage()
func (x *CancelStressRequest) ProtoReflect() protoreflect.Message
func (x *CancelStressRequest) Reset()
func (x *CancelStressRequest) String() string
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() ([]byte, []int)
Deprecated: Use Chain.ProtoReflect.Descriptor instead.
func (x *Chain) GetDestinationPorts() string
func (x *Chain) GetDevice() string
func (x *Chain) GetDirection() Chain_Direction
func (x *Chain) GetIpsets() []string
func (x *Chain) GetName() string
func (x *Chain) GetProtocol() string
func (x *Chain) GetSourcePorts() string
func (x *Chain) GetTarget() string
func (x *Chain) GetTcpFlags() string
func (*Chain) ProtoMessage()
func (x *Chain) ProtoReflect() protoreflect.Message
func (x *Chain) Reset()
func (x *Chain) String() string
type Chain_Direction int32
const (
Chain_INPUT Chain_Direction = 0
Chain_OUTPUT Chain_Direction = 1
)
func (Chain_Direction) Descriptor() protoreflect.EnumDescriptor
func (x Chain_Direction) Enum() *Chain_Direction
func (Chain_Direction) EnumDescriptor() ([]byte, []int)
Deprecated: Use Chain_Direction.Descriptor instead.
func (x Chain_Direction) Number() protoreflect.EnumNumber
func (x Chain_Direction) String() string
func (Chain_Direction) Type() protoreflect.EnumType
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 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)
}
func NewChaosDaemonClient(cc grpc.ClientConnInterface) ChaosDaemonClient
ChaosDaemonServer is the server API for ChaosDaemon service.
type ChaosDaemonServer interface {
SetTcs(context.Context, *TcsRequest) (*empty.Empty, error)
FlushIPSets(context.Context, *IPSetsRequest) (*empty.Empty, error)
SetIptablesChains(context.Context, *IptablesChainsRequest) (*empty.Empty, error)
SetTimeOffset(context.Context, *TimeRequest) (*empty.Empty, error)
RecoverTimeOffset(context.Context, *TimeRequest) (*empty.Empty, error)
ContainerKill(context.Context, *ContainerRequest) (*empty.Empty, error)
ContainerGetPid(context.Context, *ContainerRequest) (*ContainerResponse, error)
ExecStressors(context.Context, *ExecStressRequest) (*ExecStressResponse, error)
CancelStressors(context.Context, *CancelStressRequest) (*empty.Empty, error)
ApplyIOChaos(context.Context, *ApplyIOChaosRequest) (*ApplyIOChaosResponse, error)
ApplyHttpChaos(context.Context, *ApplyHttpChaosRequest) (*ApplyHttpChaosResponse, error)
ApplyBlockChaos(context.Context, *ApplyBlockChaosRequest) (*ApplyBlockChaosResponse, error)
RecoverBlockChaos(context.Context, *RecoverBlockChaosRequest) (*empty.Empty, error)
SetDNSServer(context.Context, *SetDNSServerRequest) (*empty.Empty, error)
InstallJVMRules(context.Context, *InstallJVMRulesRequest) (*empty.Empty, error)
UninstallJVMRules(context.Context, *UninstallJVMRulesRequest) (*empty.Empty, error)
}
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() ([]byte, []int)
Deprecated: Use CidrAndPort.ProtoReflect.Descriptor instead.
func (x *CidrAndPort) GetCidr() string
func (x *CidrAndPort) GetPort() uint32
func (*CidrAndPort) ProtoMessage()
func (x *CidrAndPort) ProtoReflect() protoreflect.Message
func (x *CidrAndPort) Reset()
func (x *CidrAndPort) String() string
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() ([]byte, []int)
Deprecated: Use ContainerAction.ProtoReflect.Descriptor instead.
func (x *ContainerAction) GetAction() ContainerAction_Action
func (*ContainerAction) ProtoMessage()
func (x *ContainerAction) ProtoReflect() protoreflect.Message
func (x *ContainerAction) Reset()
func (x *ContainerAction) String() string
type ContainerAction_Action int32
const (
ContainerAction_KILL ContainerAction_Action = 0
ContainerAction_GETPID ContainerAction_Action = 1
)
func (ContainerAction_Action) Descriptor() protoreflect.EnumDescriptor
func (x ContainerAction_Action) Enum() *ContainerAction_Action
func (ContainerAction_Action) EnumDescriptor() ([]byte, []int)
Deprecated: Use ContainerAction_Action.Descriptor instead.
func (x ContainerAction_Action) Number() protoreflect.EnumNumber
func (x ContainerAction_Action) String() string
func (ContainerAction_Action) Type() protoreflect.EnumType
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() ([]byte, []int)
Deprecated: Use ContainerRequest.ProtoReflect.Descriptor instead.
func (x *ContainerRequest) GetAction() *ContainerAction
func (x *ContainerRequest) GetContainerId() string
func (*ContainerRequest) ProtoMessage()
func (x *ContainerRequest) ProtoReflect() protoreflect.Message
func (x *ContainerRequest) Reset()
func (x *ContainerRequest) String() string
type ContainerResponse struct {
Pid uint32 `protobuf:"varint,1,opt,name=pid,proto3" json:"pid,omitempty"`
// contains filtered or unexported fields
}
func (*ContainerResponse) Descriptor() ([]byte, []int)
Deprecated: Use ContainerResponse.ProtoReflect.Descriptor instead.
func (x *ContainerResponse) GetPid() uint32
func (*ContainerResponse) ProtoMessage()
func (x *ContainerResponse) ProtoReflect() protoreflect.Message
func (x *ContainerResponse) Reset()
func (x *ContainerResponse) String() string
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() ([]byte, []int)
Deprecated: Use EmatchFilter.ProtoReflect.Descriptor instead.
func (x *EmatchFilter) GetClassid() *TcHandle
func (x *EmatchFilter) GetMatch() string
func (x *EmatchFilter) GetParent() *TcHandle
func (*EmatchFilter) ProtoMessage()
func (x *EmatchFilter) ProtoReflect() protoreflect.Message
func (x *EmatchFilter) Reset()
func (x *EmatchFilter) String() string
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() ([]byte, []int)
Deprecated: Use EmatchFilterRequest.ProtoReflect.Descriptor instead.
func (x *EmatchFilterRequest) GetContainerId() string
func (x *EmatchFilterRequest) GetFilter() *EmatchFilter
func (*EmatchFilterRequest) ProtoMessage()
func (x *EmatchFilterRequest) ProtoReflect() protoreflect.Message
func (x *EmatchFilterRequest) Reset()
func (x *EmatchFilterRequest) String() string
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() ([]byte, []int)
Deprecated: Use ExecStressRequest.ProtoReflect.Descriptor instead.
func (x *ExecStressRequest) GetCpuStressors() string
func (x *ExecStressRequest) GetEnterNS() bool
func (x *ExecStressRequest) GetMemoryStressors() string
func (x *ExecStressRequest) GetOomScoreAdj() int32
func (x *ExecStressRequest) GetScope() ExecStressRequest_Scope
func (x *ExecStressRequest) GetTarget() string
func (*ExecStressRequest) ProtoMessage()
func (x *ExecStressRequest) ProtoReflect() protoreflect.Message
func (x *ExecStressRequest) Reset()
func (x *ExecStressRequest) String() string
type ExecStressRequest_Scope int32
const (
ExecStressRequest_CONTAINER ExecStressRequest_Scope = 0
ExecStressRequest_POD ExecStressRequest_Scope = 1
)
func (ExecStressRequest_Scope) Descriptor() protoreflect.EnumDescriptor
func (x ExecStressRequest_Scope) Enum() *ExecStressRequest_Scope
func (ExecStressRequest_Scope) EnumDescriptor() ([]byte, []int)
Deprecated: Use ExecStressRequest_Scope.Descriptor instead.
func (x ExecStressRequest_Scope) Number() protoreflect.EnumNumber
func (x ExecStressRequest_Scope) String() string
func (ExecStressRequest_Scope) Type() protoreflect.EnumType
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() ([]byte, []int)
Deprecated: Use ExecStressResponse.ProtoReflect.Descriptor instead.
func (x *ExecStressResponse) GetCpuInstance() string
func (x *ExecStressResponse) GetCpuInstanceUid() string
func (x *ExecStressResponse) GetCpuStartTime() int64
func (x *ExecStressResponse) GetMemoryInstance() string
func (x *ExecStressResponse) GetMemoryInstanceUid() string
func (x *ExecStressResponse) GetMemoryStartTime() int64
func (*ExecStressResponse) ProtoMessage()
func (x *ExecStressResponse) ProtoReflect() protoreflect.Message
func (x *ExecStressResponse) Reset()
func (x *ExecStressResponse) String() string
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() ([]byte, []int)
Deprecated: Use IPSet.ProtoReflect.Descriptor instead.
func (x *IPSet) GetCidrAndPorts() []*CidrAndPort
func (x *IPSet) GetCidrs() []string
func (x *IPSet) GetName() string
func (x *IPSet) GetSetNames() []string
func (x *IPSet) GetType() string
func (*IPSet) ProtoMessage()
func (x *IPSet) ProtoReflect() protoreflect.Message
func (x *IPSet) Reset()
func (x *IPSet) String() string
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() ([]byte, []int)
Deprecated: Use IPSetsRequest.ProtoReflect.Descriptor instead.
func (x *IPSetsRequest) GetContainerId() string
func (x *IPSetsRequest) GetEnterNS() bool
func (x *IPSetsRequest) GetIpsets() []*IPSet
func (*IPSetsRequest) ProtoMessage()
func (x *IPSetsRequest) ProtoReflect() protoreflect.Message
func (x *IPSetsRequest) Reset()
func (x *IPSetsRequest) String() string
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() ([]byte, []int)
Deprecated: Use InstallJVMRulesRequest.ProtoReflect.Descriptor instead.
func (x *InstallJVMRulesRequest) GetContainerId() string
func (x *InstallJVMRulesRequest) GetEnterNS() bool
func (x *InstallJVMRulesRequest) GetPort() int32
func (x *InstallJVMRulesRequest) GetRule() string
func (*InstallJVMRulesRequest) ProtoMessage()
func (x *InstallJVMRulesRequest) ProtoReflect() protoreflect.Message
func (x *InstallJVMRulesRequest) Reset()
func (x *InstallJVMRulesRequest) String() string
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() ([]byte, []int)
Deprecated: Use IptablesChainsRequest.ProtoReflect.Descriptor instead.
func (x *IptablesChainsRequest) GetChains() []*Chain
func (x *IptablesChainsRequest) GetContainerId() string
func (x *IptablesChainsRequest) GetEnterNS() bool
func (*IptablesChainsRequest) ProtoMessage()
func (x *IptablesChainsRequest) ProtoReflect() protoreflect.Message
func (x *IptablesChainsRequest) Reset()
func (x *IptablesChainsRequest) String() string
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"`
Rate string `protobuf:"bytes,16,opt,name=rate,proto3" json:"rate,omitempty"`
// contains filtered or unexported fields
}
func (*Netem) Descriptor() ([]byte, []int)
Deprecated: Use Netem.ProtoReflect.Descriptor instead.
func (x *Netem) GetCorrupt() float32
func (x *Netem) GetCorruptCorr() float32
func (x *Netem) GetDelayCorr() float32
func (x *Netem) GetDuplicate() float32
func (x *Netem) GetDuplicateCorr() float32
func (x *Netem) GetGap() uint32
func (x *Netem) GetHandle() *TcHandle
func (x *Netem) GetJitter() uint32
func (x *Netem) GetLimit() uint32
func (x *Netem) GetLoss() float32
func (x *Netem) GetLossCorr() float32
func (x *Netem) GetParent() *TcHandle
func (x *Netem) GetRate() string
func (x *Netem) GetReorder() float32
func (x *Netem) GetReorderCorr() float32
func (x *Netem) GetTime() uint32
func (*Netem) ProtoMessage()
func (x *Netem) ProtoReflect() protoreflect.Message
func (x *Netem) Reset()
func (x *Netem) String() string
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() ([]byte, []int)
Deprecated: Use NetemRequest.ProtoReflect.Descriptor instead.
func (x *NetemRequest) GetContainerId() string
func (x *NetemRequest) GetHandle() *TcHandle
func (x *NetemRequest) GetNetem() *Netem
func (x *NetemRequest) GetParent() *TcHandle
func (*NetemRequest) ProtoMessage()
func (x *NetemRequest) ProtoReflect() protoreflect.Message
func (x *NetemRequest) Reset()
func (x *NetemRequest) String() string
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() ([]byte, []int)
Deprecated: Use Qdisc.ProtoReflect.Descriptor instead.
func (x *Qdisc) GetArgs() []string
func (x *Qdisc) GetHandle() *TcHandle
func (x *Qdisc) GetParent() *TcHandle
func (x *Qdisc) GetType() string
func (*Qdisc) ProtoMessage()
func (x *Qdisc) ProtoReflect() protoreflect.Message
func (x *Qdisc) Reset()
func (x *Qdisc) String() string
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() ([]byte, []int)
Deprecated: Use QdiscRequest.ProtoReflect.Descriptor instead.
func (x *QdiscRequest) GetContainerId() string
func (x *QdiscRequest) GetQdisc() *Qdisc
func (*QdiscRequest) ProtoMessage()
func (x *QdiscRequest) ProtoReflect() protoreflect.Message
func (x *QdiscRequest) Reset()
func (x *QdiscRequest) String() string
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() ([]byte, []int)
Deprecated: Use RecoverBlockChaosRequest.ProtoReflect.Descriptor instead.
func (x *RecoverBlockChaosRequest) GetInjectionId() int32
func (*RecoverBlockChaosRequest) ProtoMessage()
func (x *RecoverBlockChaosRequest) ProtoReflect() protoreflect.Message
func (x *RecoverBlockChaosRequest) Reset()
func (x *RecoverBlockChaosRequest) String() string
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() ([]byte, []int)
Deprecated: Use SetDNSServerRequest.ProtoReflect.Descriptor instead.
func (x *SetDNSServerRequest) GetContainerId() string
func (x *SetDNSServerRequest) GetDnsServer() string
func (x *SetDNSServerRequest) GetEnable() bool
func (x *SetDNSServerRequest) GetEnterNS() bool
func (*SetDNSServerRequest) ProtoMessage()
func (x *SetDNSServerRequest) ProtoReflect() protoreflect.Message
func (x *SetDNSServerRequest) Reset()
func (x *SetDNSServerRequest) String() string
type Tbf struct {
Rate string `protobuf:"bytes,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() ([]byte, []int)
Deprecated: Use Tbf.ProtoReflect.Descriptor instead.
func (x *Tbf) GetBuffer() uint32
func (x *Tbf) GetLimit() uint32
func (x *Tbf) GetMinBurst() uint32
func (x *Tbf) GetPeakRate() uint64
func (x *Tbf) GetRate() string
func (*Tbf) ProtoMessage()
func (x *Tbf) ProtoReflect() protoreflect.Message
func (x *Tbf) Reset()
func (x *Tbf) String() string
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() ([]byte, []int)
Deprecated: Use TbfRequest.ProtoReflect.Descriptor instead.
func (x *TbfRequest) GetContainerId() string
func (x *TbfRequest) GetTbf() *Tbf
func (*TbfRequest) ProtoMessage()
func (x *TbfRequest) ProtoReflect() protoreflect.Message
func (x *TbfRequest) Reset()
func (x *TbfRequest) String() string
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() ([]byte, []int)
Deprecated: Use Tc.ProtoReflect.Descriptor instead.
func (x *Tc) GetDevice() string
func (x *Tc) GetEgressPort() string
func (x *Tc) GetIpset() string
func (x *Tc) GetNetem() *Netem
func (x *Tc) GetProtocol() string
func (x *Tc) GetSourcePort() string
func (x *Tc) GetTbf() *Tbf
func (x *Tc) GetType() Tc_Type
func (*Tc) ProtoMessage()
func (x *Tc) ProtoReflect() protoreflect.Message
func (x *Tc) Reset()
func (x *Tc) String() string
type TcFilter struct {
Parent *TcHandle `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
// contains filtered or unexported fields
}
func (*TcFilter) Descriptor() ([]byte, []int)
Deprecated: Use TcFilter.ProtoReflect.Descriptor instead.
func (x *TcFilter) GetParent() *TcHandle
func (*TcFilter) ProtoMessage()
func (x *TcFilter) ProtoReflect() protoreflect.Message
func (x *TcFilter) Reset()
func (x *TcFilter) String() string
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() ([]byte, []int)
Deprecated: Use TcFilterRequest.ProtoReflect.Descriptor instead.
func (x *TcFilterRequest) GetContainerId() string
func (x *TcFilterRequest) GetFilter() *TcFilter
func (*TcFilterRequest) ProtoMessage()
func (x *TcFilterRequest) ProtoReflect() protoreflect.Message
func (x *TcFilterRequest) Reset()
func (x *TcFilterRequest) String() string
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() ([]byte, []int)
Deprecated: Use TcHandle.ProtoReflect.Descriptor instead.
func (x *TcHandle) GetMajor() uint32
func (x *TcHandle) GetMinor() uint32
func (*TcHandle) ProtoMessage()
func (x *TcHandle) ProtoReflect() protoreflect.Message
func (x *TcHandle) Reset()
func (x *TcHandle) String() string
type Tc_Type int32
const (
Tc_NETEM Tc_Type = 0
Tc_BANDWIDTH Tc_Type = 1
)
func (Tc_Type) Descriptor() protoreflect.EnumDescriptor
func (x Tc_Type) Enum() *Tc_Type
func (Tc_Type) EnumDescriptor() ([]byte, []int)
Deprecated: Use Tc_Type.Descriptor instead.
func (x Tc_Type) Number() protoreflect.EnumNumber
func (x Tc_Type) String() string
func (Tc_Type) Type() protoreflect.EnumType
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() ([]byte, []int)
Deprecated: Use TcsRequest.ProtoReflect.Descriptor instead.
func (x *TcsRequest) GetContainerId() string
func (x *TcsRequest) GetEnterNS() bool
func (x *TcsRequest) GetTcs() []*Tc
func (*TcsRequest) ProtoMessage()
func (x *TcsRequest) ProtoReflect() protoreflect.Message
func (x *TcsRequest) Reset()
func (x *TcsRequest) String() string
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() ([]byte, []int)
Deprecated: Use TimeRequest.ProtoReflect.Descriptor instead.
func (x *TimeRequest) GetClkIdsMask() uint64
func (x *TimeRequest) GetContainerId() string
func (x *TimeRequest) GetNsec() int64
func (x *TimeRequest) GetPodContainerName() string
func (x *TimeRequest) GetSec() int64
func (x *TimeRequest) GetUid() string
func (*TimeRequest) ProtoMessage()
func (x *TimeRequest) ProtoReflect() protoreflect.Message
func (x *TimeRequest) Reset()
func (x *TimeRequest) String() string
UnimplementedChaosDaemonServer can be embedded to have forward compatible implementations.
type UnimplementedChaosDaemonServer struct {
}
func (*UnimplementedChaosDaemonServer) ApplyBlockChaos(context.Context, *ApplyBlockChaosRequest) (*ApplyBlockChaosResponse, error)
func (*UnimplementedChaosDaemonServer) ApplyHttpChaos(context.Context, *ApplyHttpChaosRequest) (*ApplyHttpChaosResponse, error)
func (*UnimplementedChaosDaemonServer) ApplyIOChaos(context.Context, *ApplyIOChaosRequest) (*ApplyIOChaosResponse, error)
func (*UnimplementedChaosDaemonServer) CancelStressors(context.Context, *CancelStressRequest) (*empty.Empty, error)
func (*UnimplementedChaosDaemonServer) ContainerGetPid(context.Context, *ContainerRequest) (*ContainerResponse, error)
func (*UnimplementedChaosDaemonServer) ContainerKill(context.Context, *ContainerRequest) (*empty.Empty, error)
func (*UnimplementedChaosDaemonServer) ExecStressors(context.Context, *ExecStressRequest) (*ExecStressResponse, error)
func (*UnimplementedChaosDaemonServer) FlushIPSets(context.Context, *IPSetsRequest) (*empty.Empty, error)
func (*UnimplementedChaosDaemonServer) InstallJVMRules(context.Context, *InstallJVMRulesRequest) (*empty.Empty, error)
func (*UnimplementedChaosDaemonServer) RecoverBlockChaos(context.Context, *RecoverBlockChaosRequest) (*empty.Empty, error)
func (*UnimplementedChaosDaemonServer) RecoverTimeOffset(context.Context, *TimeRequest) (*empty.Empty, error)
func (*UnimplementedChaosDaemonServer) SetDNSServer(context.Context, *SetDNSServerRequest) (*empty.Empty, error)
func (*UnimplementedChaosDaemonServer) SetIptablesChains(context.Context, *IptablesChainsRequest) (*empty.Empty, error)
func (*UnimplementedChaosDaemonServer) SetTcs(context.Context, *TcsRequest) (*empty.Empty, error)
func (*UnimplementedChaosDaemonServer) SetTimeOffset(context.Context, *TimeRequest) (*empty.Empty, error)
func (*UnimplementedChaosDaemonServer) UninstallJVMRules(context.Context, *UninstallJVMRulesRequest) (*empty.Empty, error)
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() ([]byte, []int)
Deprecated: Use UninstallJVMRulesRequest.ProtoReflect.Descriptor instead.
func (x *UninstallJVMRulesRequest) GetContainerId() string
func (x *UninstallJVMRulesRequest) GetEnterNS() bool
func (x *UninstallJVMRulesRequest) GetPort() int32
func (x *UninstallJVMRulesRequest) GetRule() string
func (*UninstallJVMRulesRequest) ProtoMessage()
func (x *UninstallJVMRulesRequest) ProtoReflect() protoreflect.Message
func (x *UninstallJVMRulesRequest) Reset()
func (x *UninstallJVMRulesRequest) String() string