Documentation ¶
Index ¶
- Variables
- func RegisterChaosDaemonServer(s *grpc.Server, srv ChaosDaemonServer)
- type CancelStressRequest
- func (*CancelStressRequest) Descriptor() ([]byte, []int)
- func (m *CancelStressRequest) GetInstance() string
- func (m *CancelStressRequest) GetStartTime() int64
- func (*CancelStressRequest) ProtoMessage()
- func (m *CancelStressRequest) Reset()
- func (m *CancelStressRequest) String() string
- func (m *CancelStressRequest) XXX_DiscardUnknown()
- func (m *CancelStressRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CancelStressRequest) XXX_Merge(src proto.Message)
- func (m *CancelStressRequest) XXX_Size() int
- func (m *CancelStressRequest) XXX_Unmarshal(b []byte) error
- type ChaosDaemonClient
- type ChaosDaemonServer
- type ContainerAction
- func (*ContainerAction) Descriptor() ([]byte, []int)
- func (m *ContainerAction) GetAction() ContainerAction_Action
- func (*ContainerAction) ProtoMessage()
- func (m *ContainerAction) Reset()
- func (m *ContainerAction) String() string
- func (m *ContainerAction) XXX_DiscardUnknown()
- func (m *ContainerAction) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ContainerAction) XXX_Merge(src proto.Message)
- func (m *ContainerAction) XXX_Size() int
- func (m *ContainerAction) XXX_Unmarshal(b []byte) error
- type ContainerAction_Action
- type ContainerRequest
- func (*ContainerRequest) Descriptor() ([]byte, []int)
- func (m *ContainerRequest) GetAction() *ContainerAction
- func (m *ContainerRequest) GetContainerId() string
- func (*ContainerRequest) ProtoMessage()
- func (m *ContainerRequest) Reset()
- func (m *ContainerRequest) String() string
- func (m *ContainerRequest) XXX_DiscardUnknown()
- func (m *ContainerRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ContainerRequest) XXX_Merge(src proto.Message)
- func (m *ContainerRequest) XXX_Size() int
- func (m *ContainerRequest) XXX_Unmarshal(b []byte) error
- type ContainerResponse
- func (*ContainerResponse) Descriptor() ([]byte, []int)
- func (m *ContainerResponse) GetPid() uint32
- func (*ContainerResponse) ProtoMessage()
- func (m *ContainerResponse) Reset()
- func (m *ContainerResponse) String() string
- func (m *ContainerResponse) XXX_DiscardUnknown()
- func (m *ContainerResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ContainerResponse) XXX_Merge(src proto.Message)
- func (m *ContainerResponse) XXX_Size() int
- func (m *ContainerResponse) XXX_Unmarshal(b []byte) error
- type EmatchFilter
- func (*EmatchFilter) Descriptor() ([]byte, []int)
- func (m *EmatchFilter) GetClassid() *TcHandle
- func (m *EmatchFilter) GetMatch() string
- func (m *EmatchFilter) GetParent() *TcHandle
- func (*EmatchFilter) ProtoMessage()
- func (m *EmatchFilter) Reset()
- func (m *EmatchFilter) String() string
- func (m *EmatchFilter) XXX_DiscardUnknown()
- func (m *EmatchFilter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *EmatchFilter) XXX_Merge(src proto.Message)
- func (m *EmatchFilter) XXX_Size() int
- func (m *EmatchFilter) XXX_Unmarshal(b []byte) error
- type EmatchFilterRequest
- func (*EmatchFilterRequest) Descriptor() ([]byte, []int)
- func (m *EmatchFilterRequest) GetContainerId() string
- func (m *EmatchFilterRequest) GetFilter() *EmatchFilter
- func (*EmatchFilterRequest) ProtoMessage()
- func (m *EmatchFilterRequest) Reset()
- func (m *EmatchFilterRequest) String() string
- func (m *EmatchFilterRequest) XXX_DiscardUnknown()
- func (m *EmatchFilterRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *EmatchFilterRequest) XXX_Merge(src proto.Message)
- func (m *EmatchFilterRequest) XXX_Size() int
- func (m *EmatchFilterRequest) XXX_Unmarshal(b []byte) error
- type ExecStressRequest
- func (*ExecStressRequest) Descriptor() ([]byte, []int)
- func (m *ExecStressRequest) GetScope() ExecStressRequest_Scope
- func (m *ExecStressRequest) GetStressors() string
- func (m *ExecStressRequest) GetTarget() string
- func (*ExecStressRequest) ProtoMessage()
- func (m *ExecStressRequest) Reset()
- func (m *ExecStressRequest) String() string
- func (m *ExecStressRequest) XXX_DiscardUnknown()
- func (m *ExecStressRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ExecStressRequest) XXX_Merge(src proto.Message)
- func (m *ExecStressRequest) XXX_Size() int
- func (m *ExecStressRequest) XXX_Unmarshal(b []byte) error
- type ExecStressRequest_Scope
- type ExecStressResponse
- func (*ExecStressResponse) Descriptor() ([]byte, []int)
- func (m *ExecStressResponse) GetInstance() string
- func (m *ExecStressResponse) GetStartTime() int64
- func (*ExecStressResponse) ProtoMessage()
- func (m *ExecStressResponse) Reset()
- func (m *ExecStressResponse) String() string
- func (m *ExecStressResponse) XXX_DiscardUnknown()
- func (m *ExecStressResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ExecStressResponse) XXX_Merge(src proto.Message)
- func (m *ExecStressResponse) XXX_Size() int
- func (m *ExecStressResponse) XXX_Unmarshal(b []byte) error
- type IpSet
- func (*IpSet) Descriptor() ([]byte, []int)
- func (m *IpSet) GetIps() []string
- func (m *IpSet) GetName() string
- func (*IpSet) ProtoMessage()
- func (m *IpSet) Reset()
- func (m *IpSet) String() string
- func (m *IpSet) XXX_DiscardUnknown()
- func (m *IpSet) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *IpSet) XXX_Merge(src proto.Message)
- func (m *IpSet) XXX_Size() int
- func (m *IpSet) XXX_Unmarshal(b []byte) error
- type IpSetRequest
- func (*IpSetRequest) Descriptor() ([]byte, []int)
- func (m *IpSetRequest) GetContainerId() string
- func (m *IpSetRequest) GetIpset() *IpSet
- func (*IpSetRequest) ProtoMessage()
- func (m *IpSetRequest) Reset()
- func (m *IpSetRequest) String() string
- func (m *IpSetRequest) XXX_DiscardUnknown()
- func (m *IpSetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *IpSetRequest) XXX_Merge(src proto.Message)
- func (m *IpSetRequest) XXX_Size() int
- func (m *IpSetRequest) XXX_Unmarshal(b []byte) error
- type IpTablesRequest
- func (*IpTablesRequest) Descriptor() ([]byte, []int)
- func (m *IpTablesRequest) GetContainerId() string
- func (m *IpTablesRequest) GetRule() *Rule
- func (*IpTablesRequest) ProtoMessage()
- func (m *IpTablesRequest) Reset()
- func (m *IpTablesRequest) String() string
- func (m *IpTablesRequest) XXX_DiscardUnknown()
- func (m *IpTablesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *IpTablesRequest) XXX_Merge(src proto.Message)
- func (m *IpTablesRequest) XXX_Size() int
- func (m *IpTablesRequest) XXX_Unmarshal(b []byte) error
- type Netem
- func (*Netem) Descriptor() ([]byte, []int)
- func (m *Netem) GetCorrupt() float32
- func (m *Netem) GetCorruptCorr() float32
- func (m *Netem) GetDelayCorr() float32
- func (m *Netem) GetDuplicate() float32
- func (m *Netem) GetDuplicateCorr() float32
- func (m *Netem) GetGap() uint32
- func (m *Netem) GetHandle() *TcHandle
- func (m *Netem) GetJitter() uint32
- func (m *Netem) GetLimit() uint32
- func (m *Netem) GetLoss() float32
- func (m *Netem) GetLossCorr() float32
- func (m *Netem) GetParent() *TcHandle
- func (m *Netem) GetReorder() float32
- func (m *Netem) GetReorderCorr() float32
- func (m *Netem) GetTime() uint32
- func (*Netem) ProtoMessage()
- func (m *Netem) Reset()
- func (m *Netem) String() string
- func (m *Netem) XXX_DiscardUnknown()
- func (m *Netem) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Netem) XXX_Merge(src proto.Message)
- func (m *Netem) XXX_Size() int
- func (m *Netem) XXX_Unmarshal(b []byte) error
- type NetemRequest
- func (*NetemRequest) Descriptor() ([]byte, []int)
- func (m *NetemRequest) GetContainerId() string
- func (m *NetemRequest) GetHandle() *TcHandle
- func (m *NetemRequest) GetNetem() *Netem
- func (m *NetemRequest) GetParent() *TcHandle
- func (*NetemRequest) ProtoMessage()
- func (m *NetemRequest) Reset()
- func (m *NetemRequest) String() string
- func (m *NetemRequest) XXX_DiscardUnknown()
- func (m *NetemRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *NetemRequest) XXX_Merge(src proto.Message)
- func (m *NetemRequest) XXX_Size() int
- func (m *NetemRequest) XXX_Unmarshal(b []byte) error
- type Qdisc
- func (*Qdisc) Descriptor() ([]byte, []int)
- func (m *Qdisc) GetArgs() []string
- func (m *Qdisc) GetHandle() *TcHandle
- func (m *Qdisc) GetParent() *TcHandle
- func (m *Qdisc) GetType() string
- func (*Qdisc) ProtoMessage()
- func (m *Qdisc) Reset()
- func (m *Qdisc) String() string
- func (m *Qdisc) XXX_DiscardUnknown()
- func (m *Qdisc) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Qdisc) XXX_Merge(src proto.Message)
- func (m *Qdisc) XXX_Size() int
- func (m *Qdisc) XXX_Unmarshal(b []byte) error
- type QdiscRequest
- func (*QdiscRequest) Descriptor() ([]byte, []int)
- func (m *QdiscRequest) GetContainerId() string
- func (m *QdiscRequest) GetQdisc() *Qdisc
- func (*QdiscRequest) ProtoMessage()
- func (m *QdiscRequest) Reset()
- func (m *QdiscRequest) String() string
- func (m *QdiscRequest) XXX_DiscardUnknown()
- func (m *QdiscRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QdiscRequest) XXX_Merge(src proto.Message)
- func (m *QdiscRequest) XXX_Size() int
- func (m *QdiscRequest) XXX_Unmarshal(b []byte) error
- type Rule
- func (*Rule) Descriptor() ([]byte, []int)
- func (m *Rule) GetAction() Rule_Action
- func (m *Rule) GetDirection() Rule_Direction
- func (m *Rule) GetSet() string
- func (*Rule) ProtoMessage()
- func (m *Rule) Reset()
- func (m *Rule) String() string
- func (m *Rule) XXX_DiscardUnknown()
- func (m *Rule) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Rule) XXX_Merge(src proto.Message)
- func (m *Rule) XXX_Size() int
- func (m *Rule) XXX_Unmarshal(b []byte) error
- type Rule_Action
- type Rule_Direction
- type Tbf
- func (*Tbf) Descriptor() ([]byte, []int)
- func (m *Tbf) GetBuffer() uint32
- func (m *Tbf) GetLimit() uint32
- func (m *Tbf) GetMinBurst() uint32
- func (m *Tbf) GetPeakRate() uint64
- func (m *Tbf) GetRate() uint64
- func (*Tbf) ProtoMessage()
- func (m *Tbf) Reset()
- func (m *Tbf) String() string
- func (m *Tbf) XXX_DiscardUnknown()
- func (m *Tbf) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Tbf) XXX_Merge(src proto.Message)
- func (m *Tbf) XXX_Size() int
- func (m *Tbf) XXX_Unmarshal(b []byte) error
- type TbfRequest
- func (*TbfRequest) Descriptor() ([]byte, []int)
- func (m *TbfRequest) GetContainerId() string
- func (m *TbfRequest) GetTbf() *Tbf
- func (*TbfRequest) ProtoMessage()
- func (m *TbfRequest) Reset()
- func (m *TbfRequest) String() string
- func (m *TbfRequest) XXX_DiscardUnknown()
- func (m *TbfRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TbfRequest) XXX_Merge(src proto.Message)
- func (m *TbfRequest) XXX_Size() int
- func (m *TbfRequest) XXX_Unmarshal(b []byte) error
- type TcFilter
- func (*TcFilter) Descriptor() ([]byte, []int)
- func (m *TcFilter) GetParent() *TcHandle
- func (*TcFilter) ProtoMessage()
- func (m *TcFilter) Reset()
- func (m *TcFilter) String() string
- func (m *TcFilter) XXX_DiscardUnknown()
- func (m *TcFilter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TcFilter) XXX_Merge(src proto.Message)
- func (m *TcFilter) XXX_Size() int
- func (m *TcFilter) XXX_Unmarshal(b []byte) error
- type TcFilterRequest
- func (*TcFilterRequest) Descriptor() ([]byte, []int)
- func (m *TcFilterRequest) GetContainerId() string
- func (m *TcFilterRequest) GetFilter() *TcFilter
- func (*TcFilterRequest) ProtoMessage()
- func (m *TcFilterRequest) Reset()
- func (m *TcFilterRequest) String() string
- func (m *TcFilterRequest) XXX_DiscardUnknown()
- func (m *TcFilterRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TcFilterRequest) XXX_Merge(src proto.Message)
- func (m *TcFilterRequest) XXX_Size() int
- func (m *TcFilterRequest) XXX_Unmarshal(b []byte) error
- type TcHandle
- func (*TcHandle) Descriptor() ([]byte, []int)
- func (m *TcHandle) GetMajor() uint32
- func (m *TcHandle) GetMinor() uint32
- func (*TcHandle) ProtoMessage()
- func (m *TcHandle) Reset()
- func (m *TcHandle) String() string
- func (m *TcHandle) XXX_DiscardUnknown()
- func (m *TcHandle) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TcHandle) XXX_Merge(src proto.Message)
- func (m *TcHandle) XXX_Size() int
- func (m *TcHandle) XXX_Unmarshal(b []byte) error
- type TimeRequest
- func (*TimeRequest) Descriptor() ([]byte, []int)
- func (m *TimeRequest) GetClkIdsMask() uint64
- func (m *TimeRequest) GetContainerId() string
- func (m *TimeRequest) GetNsec() int64
- func (m *TimeRequest) GetSec() int64
- func (*TimeRequest) ProtoMessage()
- func (m *TimeRequest) Reset()
- func (m *TimeRequest) String() string
- func (m *TimeRequest) XXX_DiscardUnknown()
- func (m *TimeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TimeRequest) XXX_Merge(src proto.Message)
- func (m *TimeRequest) XXX_Size() int
- func (m *TimeRequest) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
View Source
var ContainerAction_Action_name = map[int32]string{
0: "KILL",
1: "GETPID",
}
View Source
var ContainerAction_Action_value = map[string]int32{
"KILL": 0,
"GETPID": 1,
}
View Source
var ExecStressRequest_Scope_name = map[int32]string{
0: "CONTAINER",
1: "POD",
}
View Source
var ExecStressRequest_Scope_value = map[string]int32{
"CONTAINER": 0,
"POD": 1,
}
View Source
var Rule_Action_name = map[int32]string{
0: "ADD",
1: "DELETE",
}
View Source
var Rule_Action_value = map[string]int32{
"ADD": 0,
"DELETE": 1,
}
View Source
var Rule_Direction_name = map[int32]string{
0: "INPUT",
1: "OUTPUT",
}
View Source
var Rule_Direction_value = map[string]int32{
"INPUT": 0,
"OUTPUT": 1,
}
Functions ¶
func RegisterChaosDaemonServer ¶
func RegisterChaosDaemonServer(s *grpc.Server, srv ChaosDaemonServer)
Types ¶
type CancelStressRequest ¶
type CancelStressRequest struct { Instance string `protobuf:"bytes,1,opt,name=instance,proto3" json:"instance,omitempty"` StartTime int64 `protobuf:"varint,2,opt,name=startTime,proto3" json:"startTime,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*CancelStressRequest) Descriptor ¶
func (*CancelStressRequest) Descriptor() ([]byte, []int)
func (*CancelStressRequest) GetInstance ¶
func (m *CancelStressRequest) GetInstance() string
func (*CancelStressRequest) GetStartTime ¶
func (m *CancelStressRequest) GetStartTime() int64
func (*CancelStressRequest) ProtoMessage ¶
func (*CancelStressRequest) ProtoMessage()
func (*CancelStressRequest) Reset ¶
func (m *CancelStressRequest) Reset()
func (*CancelStressRequest) String ¶
func (m *CancelStressRequest) String() string
func (*CancelStressRequest) XXX_DiscardUnknown ¶
func (m *CancelStressRequest) XXX_DiscardUnknown()
func (*CancelStressRequest) XXX_Marshal ¶
func (m *CancelStressRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CancelStressRequest) XXX_Merge ¶
func (m *CancelStressRequest) XXX_Merge(src proto.Message)
func (*CancelStressRequest) XXX_Size ¶
func (m *CancelStressRequest) XXX_Size() int
func (*CancelStressRequest) XXX_Unmarshal ¶
func (m *CancelStressRequest) XXX_Unmarshal(b []byte) error
type ChaosDaemonClient ¶
type ChaosDaemonClient interface { SetNetem(ctx context.Context, in *NetemRequest, opts ...grpc.CallOption) (*empty.Empty, error) DeleteNetem(ctx context.Context, in *NetemRequest, opts ...grpc.CallOption) (*empty.Empty, error) SetTbf(ctx context.Context, in *TbfRequest, opts ...grpc.CallOption) (*empty.Empty, error) DeleteTbf(ctx context.Context, in *TbfRequest, opts ...grpc.CallOption) (*empty.Empty, error) AddQdisc(ctx context.Context, in *QdiscRequest, opts ...grpc.CallOption) (*empty.Empty, error) DelQdisc(ctx context.Context, in *QdiscRequest, opts ...grpc.CallOption) (*empty.Empty, error) AddEmatchFilter(ctx context.Context, in *EmatchFilterRequest, opts ...grpc.CallOption) (*empty.Empty, error) // generic tc filter del command DelTcFilter(ctx context.Context, in *TcFilterRequest, opts ...grpc.CallOption) (*empty.Empty, error) FlushIpSet(ctx context.Context, in *IpSetRequest, opts ...grpc.CallOption) (*empty.Empty, error) FlushIptables(ctx context.Context, in *IpTablesRequest, 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) }
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.
func NewChaosDaemonClient ¶
func NewChaosDaemonClient(cc *grpc.ClientConn) ChaosDaemonClient
type ChaosDaemonServer ¶
type ChaosDaemonServer interface { SetNetem(context.Context, *NetemRequest) (*empty.Empty, error) DeleteNetem(context.Context, *NetemRequest) (*empty.Empty, error) SetTbf(context.Context, *TbfRequest) (*empty.Empty, error) DeleteTbf(context.Context, *TbfRequest) (*empty.Empty, error) AddQdisc(context.Context, *QdiscRequest) (*empty.Empty, error) DelQdisc(context.Context, *QdiscRequest) (*empty.Empty, error) AddEmatchFilter(context.Context, *EmatchFilterRequest) (*empty.Empty, error) // generic tc filter del command DelTcFilter(context.Context, *TcFilterRequest) (*empty.Empty, error) FlushIpSet(context.Context, *IpSetRequest) (*empty.Empty, error) FlushIptables(context.Context, *IpTablesRequest) (*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) }
ChaosDaemonServer is the server API for ChaosDaemon service.
type ContainerAction ¶
type ContainerAction struct { Action ContainerAction_Action `protobuf:"varint,1,opt,name=action,proto3,enum=chaosdaemon.ContainerAction_Action" json:"action,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ContainerAction) Descriptor ¶
func (*ContainerAction) Descriptor() ([]byte, []int)
func (*ContainerAction) GetAction ¶
func (m *ContainerAction) GetAction() ContainerAction_Action
func (*ContainerAction) ProtoMessage ¶
func (*ContainerAction) ProtoMessage()
func (*ContainerAction) Reset ¶
func (m *ContainerAction) Reset()
func (*ContainerAction) String ¶
func (m *ContainerAction) String() string
func (*ContainerAction) XXX_DiscardUnknown ¶
func (m *ContainerAction) XXX_DiscardUnknown()
func (*ContainerAction) XXX_Marshal ¶
func (m *ContainerAction) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ContainerAction) XXX_Merge ¶
func (m *ContainerAction) XXX_Merge(src proto.Message)
func (*ContainerAction) XXX_Size ¶
func (m *ContainerAction) XXX_Size() int
func (*ContainerAction) XXX_Unmarshal ¶
func (m *ContainerAction) XXX_Unmarshal(b []byte) error
type ContainerAction_Action ¶
type ContainerAction_Action int32
const ( ContainerAction_KILL ContainerAction_Action = 0 ContainerAction_GETPID ContainerAction_Action = 1 )
func (ContainerAction_Action) EnumDescriptor ¶
func (ContainerAction_Action) EnumDescriptor() ([]byte, []int)
func (ContainerAction_Action) String ¶
func (x ContainerAction_Action) String() string
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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ContainerRequest) Descriptor ¶
func (*ContainerRequest) Descriptor() ([]byte, []int)
func (*ContainerRequest) GetAction ¶
func (m *ContainerRequest) GetAction() *ContainerAction
func (*ContainerRequest) GetContainerId ¶
func (m *ContainerRequest) GetContainerId() string
func (*ContainerRequest) ProtoMessage ¶
func (*ContainerRequest) ProtoMessage()
func (*ContainerRequest) Reset ¶
func (m *ContainerRequest) Reset()
func (*ContainerRequest) String ¶
func (m *ContainerRequest) String() string
func (*ContainerRequest) XXX_DiscardUnknown ¶
func (m *ContainerRequest) XXX_DiscardUnknown()
func (*ContainerRequest) XXX_Marshal ¶
func (m *ContainerRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ContainerRequest) XXX_Merge ¶
func (m *ContainerRequest) XXX_Merge(src proto.Message)
func (*ContainerRequest) XXX_Size ¶
func (m *ContainerRequest) XXX_Size() int
func (*ContainerRequest) XXX_Unmarshal ¶
func (m *ContainerRequest) XXX_Unmarshal(b []byte) error
type ContainerResponse ¶
type ContainerResponse struct { Pid uint32 `protobuf:"varint,1,opt,name=pid,proto3" json:"pid,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ContainerResponse) Descriptor ¶
func (*ContainerResponse) Descriptor() ([]byte, []int)
func (*ContainerResponse) GetPid ¶
func (m *ContainerResponse) GetPid() uint32
func (*ContainerResponse) ProtoMessage ¶
func (*ContainerResponse) ProtoMessage()
func (*ContainerResponse) Reset ¶
func (m *ContainerResponse) Reset()
func (*ContainerResponse) String ¶
func (m *ContainerResponse) String() string
func (*ContainerResponse) XXX_DiscardUnknown ¶
func (m *ContainerResponse) XXX_DiscardUnknown()
func (*ContainerResponse) XXX_Marshal ¶
func (m *ContainerResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ContainerResponse) XXX_Merge ¶
func (m *ContainerResponse) XXX_Merge(src proto.Message)
func (*ContainerResponse) XXX_Size ¶
func (m *ContainerResponse) XXX_Size() int
func (*ContainerResponse) XXX_Unmarshal ¶
func (m *ContainerResponse) XXX_Unmarshal(b []byte) error
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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*EmatchFilter) Descriptor ¶
func (*EmatchFilter) Descriptor() ([]byte, []int)
func (*EmatchFilter) GetClassid ¶
func (m *EmatchFilter) GetClassid() *TcHandle
func (*EmatchFilter) GetMatch ¶
func (m *EmatchFilter) GetMatch() string
func (*EmatchFilter) GetParent ¶
func (m *EmatchFilter) GetParent() *TcHandle
func (*EmatchFilter) ProtoMessage ¶
func (*EmatchFilter) ProtoMessage()
func (*EmatchFilter) Reset ¶
func (m *EmatchFilter) Reset()
func (*EmatchFilter) String ¶
func (m *EmatchFilter) String() string
func (*EmatchFilter) XXX_DiscardUnknown ¶
func (m *EmatchFilter) XXX_DiscardUnknown()
func (*EmatchFilter) XXX_Marshal ¶
func (m *EmatchFilter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*EmatchFilter) XXX_Merge ¶
func (m *EmatchFilter) XXX_Merge(src proto.Message)
func (*EmatchFilter) XXX_Size ¶
func (m *EmatchFilter) XXX_Size() int
func (*EmatchFilter) XXX_Unmarshal ¶
func (m *EmatchFilter) XXX_Unmarshal(b []byte) error
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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*EmatchFilterRequest) Descriptor ¶
func (*EmatchFilterRequest) Descriptor() ([]byte, []int)
func (*EmatchFilterRequest) GetContainerId ¶
func (m *EmatchFilterRequest) GetContainerId() string
func (*EmatchFilterRequest) GetFilter ¶
func (m *EmatchFilterRequest) GetFilter() *EmatchFilter
func (*EmatchFilterRequest) ProtoMessage ¶
func (*EmatchFilterRequest) ProtoMessage()
func (*EmatchFilterRequest) Reset ¶
func (m *EmatchFilterRequest) Reset()
func (*EmatchFilterRequest) String ¶
func (m *EmatchFilterRequest) String() string
func (*EmatchFilterRequest) XXX_DiscardUnknown ¶
func (m *EmatchFilterRequest) XXX_DiscardUnknown()
func (*EmatchFilterRequest) XXX_Marshal ¶
func (m *EmatchFilterRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*EmatchFilterRequest) XXX_Merge ¶
func (m *EmatchFilterRequest) XXX_Merge(src proto.Message)
func (*EmatchFilterRequest) XXX_Size ¶
func (m *EmatchFilterRequest) XXX_Size() int
func (*EmatchFilterRequest) XXX_Unmarshal ¶
func (m *EmatchFilterRequest) XXX_Unmarshal(b []byte) error
type ExecStressRequest ¶
type ExecStressRequest struct { Scope ExecStressRequest_Scope `protobuf:"varint,1,opt,name=scope,proto3,enum=chaosdaemon.ExecStressRequest_Scope" json:"scope,omitempty"` Target string `protobuf:"bytes,2,opt,name=target,proto3" json:"target,omitempty"` Stressors string `protobuf:"bytes,3,opt,name=stressors,proto3" json:"stressors,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ExecStressRequest) Descriptor ¶
func (*ExecStressRequest) Descriptor() ([]byte, []int)
func (*ExecStressRequest) GetScope ¶
func (m *ExecStressRequest) GetScope() ExecStressRequest_Scope
func (*ExecStressRequest) GetStressors ¶
func (m *ExecStressRequest) GetStressors() string
func (*ExecStressRequest) GetTarget ¶
func (m *ExecStressRequest) GetTarget() string
func (*ExecStressRequest) ProtoMessage ¶
func (*ExecStressRequest) ProtoMessage()
func (*ExecStressRequest) Reset ¶
func (m *ExecStressRequest) Reset()
func (*ExecStressRequest) String ¶
func (m *ExecStressRequest) String() string
func (*ExecStressRequest) XXX_DiscardUnknown ¶
func (m *ExecStressRequest) XXX_DiscardUnknown()
func (*ExecStressRequest) XXX_Marshal ¶
func (m *ExecStressRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ExecStressRequest) XXX_Merge ¶
func (m *ExecStressRequest) XXX_Merge(src proto.Message)
func (*ExecStressRequest) XXX_Size ¶
func (m *ExecStressRequest) XXX_Size() int
func (*ExecStressRequest) XXX_Unmarshal ¶
func (m *ExecStressRequest) XXX_Unmarshal(b []byte) error
type ExecStressRequest_Scope ¶
type ExecStressRequest_Scope int32
const ( ExecStressRequest_CONTAINER ExecStressRequest_Scope = 0 ExecStressRequest_POD ExecStressRequest_Scope = 1 )
func (ExecStressRequest_Scope) EnumDescriptor ¶
func (ExecStressRequest_Scope) EnumDescriptor() ([]byte, []int)
func (ExecStressRequest_Scope) String ¶
func (x ExecStressRequest_Scope) String() string
type ExecStressResponse ¶
type ExecStressResponse struct { Instance string `protobuf:"bytes,1,opt,name=instance,proto3" json:"instance,omitempty"` StartTime int64 `protobuf:"varint,2,opt,name=startTime,proto3" json:"startTime,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ExecStressResponse) Descriptor ¶
func (*ExecStressResponse) Descriptor() ([]byte, []int)
func (*ExecStressResponse) GetInstance ¶
func (m *ExecStressResponse) GetInstance() string
func (*ExecStressResponse) GetStartTime ¶
func (m *ExecStressResponse) GetStartTime() int64
func (*ExecStressResponse) ProtoMessage ¶
func (*ExecStressResponse) ProtoMessage()
func (*ExecStressResponse) Reset ¶
func (m *ExecStressResponse) Reset()
func (*ExecStressResponse) String ¶
func (m *ExecStressResponse) String() string
func (*ExecStressResponse) XXX_DiscardUnknown ¶
func (m *ExecStressResponse) XXX_DiscardUnknown()
func (*ExecStressResponse) XXX_Marshal ¶
func (m *ExecStressResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ExecStressResponse) XXX_Merge ¶
func (m *ExecStressResponse) XXX_Merge(src proto.Message)
func (*ExecStressResponse) XXX_Size ¶
func (m *ExecStressResponse) XXX_Size() int
func (*ExecStressResponse) XXX_Unmarshal ¶
func (m *ExecStressResponse) XXX_Unmarshal(b []byte) error
type IpSet ¶
type IpSet struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Ips []string `protobuf:"bytes,2,rep,name=ips,proto3" json:"ips,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*IpSet) Descriptor ¶
func (*IpSet) ProtoMessage ¶
func (*IpSet) ProtoMessage()
func (*IpSet) XXX_DiscardUnknown ¶
func (m *IpSet) XXX_DiscardUnknown()
func (*IpSet) XXX_Marshal ¶
func (*IpSet) XXX_Unmarshal ¶
type IpSetRequest ¶
type IpSetRequest struct { Ipset *IpSet `protobuf:"bytes,1,opt,name=ipset,proto3" json:"ipset,omitempty"` ContainerId string `protobuf:"bytes,2,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*IpSetRequest) Descriptor ¶
func (*IpSetRequest) Descriptor() ([]byte, []int)
func (*IpSetRequest) GetContainerId ¶
func (m *IpSetRequest) GetContainerId() string
func (*IpSetRequest) GetIpset ¶
func (m *IpSetRequest) GetIpset() *IpSet
func (*IpSetRequest) ProtoMessage ¶
func (*IpSetRequest) ProtoMessage()
func (*IpSetRequest) Reset ¶
func (m *IpSetRequest) Reset()
func (*IpSetRequest) String ¶
func (m *IpSetRequest) String() string
func (*IpSetRequest) XXX_DiscardUnknown ¶
func (m *IpSetRequest) XXX_DiscardUnknown()
func (*IpSetRequest) XXX_Marshal ¶
func (m *IpSetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*IpSetRequest) XXX_Merge ¶
func (m *IpSetRequest) XXX_Merge(src proto.Message)
func (*IpSetRequest) XXX_Size ¶
func (m *IpSetRequest) XXX_Size() int
func (*IpSetRequest) XXX_Unmarshal ¶
func (m *IpSetRequest) XXX_Unmarshal(b []byte) error
type IpTablesRequest ¶
type IpTablesRequest struct { Rule *Rule `protobuf:"bytes,1,opt,name=rule,proto3" json:"rule,omitempty"` ContainerId string `protobuf:"bytes,2,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*IpTablesRequest) Descriptor ¶
func (*IpTablesRequest) Descriptor() ([]byte, []int)
func (*IpTablesRequest) GetContainerId ¶
func (m *IpTablesRequest) GetContainerId() string
func (*IpTablesRequest) GetRule ¶
func (m *IpTablesRequest) GetRule() *Rule
func (*IpTablesRequest) ProtoMessage ¶
func (*IpTablesRequest) ProtoMessage()
func (*IpTablesRequest) Reset ¶
func (m *IpTablesRequest) Reset()
func (*IpTablesRequest) String ¶
func (m *IpTablesRequest) String() string
func (*IpTablesRequest) XXX_DiscardUnknown ¶
func (m *IpTablesRequest) XXX_DiscardUnknown()
func (*IpTablesRequest) XXX_Marshal ¶
func (m *IpTablesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*IpTablesRequest) XXX_Merge ¶
func (m *IpTablesRequest) XXX_Merge(src proto.Message)
func (*IpTablesRequest) XXX_Size ¶
func (m *IpTablesRequest) XXX_Size() int
func (*IpTablesRequest) XXX_Unmarshal ¶
func (m *IpTablesRequest) XXX_Unmarshal(b []byte) error
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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Netem) Descriptor ¶
func (*Netem) GetCorrupt ¶
func (*Netem) GetCorruptCorr ¶
func (*Netem) GetDelayCorr ¶
func (*Netem) GetDuplicate ¶
func (*Netem) GetDuplicateCorr ¶
func (*Netem) GetLossCorr ¶
func (*Netem) GetReorder ¶
func (*Netem) GetReorderCorr ¶
func (*Netem) ProtoMessage ¶
func (*Netem) ProtoMessage()
func (*Netem) XXX_DiscardUnknown ¶
func (m *Netem) XXX_DiscardUnknown()
func (*Netem) XXX_Marshal ¶
func (*Netem) XXX_Unmarshal ¶
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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*NetemRequest) Descriptor ¶
func (*NetemRequest) Descriptor() ([]byte, []int)
func (*NetemRequest) GetContainerId ¶
func (m *NetemRequest) GetContainerId() string
func (*NetemRequest) GetHandle ¶
func (m *NetemRequest) GetHandle() *TcHandle
func (*NetemRequest) GetNetem ¶
func (m *NetemRequest) GetNetem() *Netem
func (*NetemRequest) GetParent ¶
func (m *NetemRequest) GetParent() *TcHandle
func (*NetemRequest) ProtoMessage ¶
func (*NetemRequest) ProtoMessage()
func (*NetemRequest) Reset ¶
func (m *NetemRequest) Reset()
func (*NetemRequest) String ¶
func (m *NetemRequest) String() string
func (*NetemRequest) XXX_DiscardUnknown ¶
func (m *NetemRequest) XXX_DiscardUnknown()
func (*NetemRequest) XXX_Marshal ¶
func (m *NetemRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*NetemRequest) XXX_Merge ¶
func (m *NetemRequest) XXX_Merge(src proto.Message)
func (*NetemRequest) XXX_Size ¶
func (m *NetemRequest) XXX_Size() int
func (*NetemRequest) XXX_Unmarshal ¶
func (m *NetemRequest) XXX_Unmarshal(b []byte) error
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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Qdisc) Descriptor ¶
func (*Qdisc) ProtoMessage ¶
func (*Qdisc) ProtoMessage()
func (*Qdisc) XXX_DiscardUnknown ¶
func (m *Qdisc) XXX_DiscardUnknown()
func (*Qdisc) XXX_Marshal ¶
func (*Qdisc) XXX_Unmarshal ¶
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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*QdiscRequest) Descriptor ¶
func (*QdiscRequest) Descriptor() ([]byte, []int)
func (*QdiscRequest) GetContainerId ¶
func (m *QdiscRequest) GetContainerId() string
func (*QdiscRequest) GetQdisc ¶
func (m *QdiscRequest) GetQdisc() *Qdisc
func (*QdiscRequest) ProtoMessage ¶
func (*QdiscRequest) ProtoMessage()
func (*QdiscRequest) Reset ¶
func (m *QdiscRequest) Reset()
func (*QdiscRequest) String ¶
func (m *QdiscRequest) String() string
func (*QdiscRequest) XXX_DiscardUnknown ¶
func (m *QdiscRequest) XXX_DiscardUnknown()
func (*QdiscRequest) XXX_Marshal ¶
func (m *QdiscRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QdiscRequest) XXX_Merge ¶
func (m *QdiscRequest) XXX_Merge(src proto.Message)
func (*QdiscRequest) XXX_Size ¶
func (m *QdiscRequest) XXX_Size() int
func (*QdiscRequest) XXX_Unmarshal ¶
func (m *QdiscRequest) XXX_Unmarshal(b []byte) error
type Rule ¶
type Rule struct { Action Rule_Action `protobuf:"varint,1,opt,name=action,proto3,enum=chaosdaemon.Rule_Action" json:"action,omitempty"` Direction Rule_Direction `protobuf:"varint,2,opt,name=direction,proto3,enum=chaosdaemon.Rule_Direction" json:"direction,omitempty"` Set string `protobuf:"bytes,3,opt,name=set,proto3" json:"set,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Rule) Descriptor ¶
func (*Rule) GetAction ¶
func (m *Rule) GetAction() Rule_Action
func (*Rule) GetDirection ¶
func (m *Rule) GetDirection() Rule_Direction
func (*Rule) ProtoMessage ¶
func (*Rule) ProtoMessage()
func (*Rule) XXX_DiscardUnknown ¶
func (m *Rule) XXX_DiscardUnknown()
func (*Rule) XXX_Unmarshal ¶
type Rule_Action ¶
type Rule_Action int32
const ( Rule_ADD Rule_Action = 0 Rule_DELETE Rule_Action = 1 )
func (Rule_Action) EnumDescriptor ¶
func (Rule_Action) EnumDescriptor() ([]byte, []int)
func (Rule_Action) String ¶
func (x Rule_Action) String() string
type Rule_Direction ¶
type Rule_Direction int32
const ( Rule_INPUT Rule_Direction = 0 Rule_OUTPUT Rule_Direction = 1 )
func (Rule_Direction) EnumDescriptor ¶
func (Rule_Direction) EnumDescriptor() ([]byte, []int)
func (Rule_Direction) String ¶
func (x Rule_Direction) 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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Tbf) Descriptor ¶
func (*Tbf) GetMinBurst ¶
func (*Tbf) GetPeakRate ¶
func (*Tbf) ProtoMessage ¶
func (*Tbf) ProtoMessage()
func (*Tbf) XXX_DiscardUnknown ¶
func (m *Tbf) XXX_DiscardUnknown()
func (*Tbf) XXX_Unmarshal ¶
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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*TbfRequest) Descriptor ¶
func (*TbfRequest) Descriptor() ([]byte, []int)
func (*TbfRequest) GetContainerId ¶
func (m *TbfRequest) GetContainerId() string
func (*TbfRequest) GetTbf ¶
func (m *TbfRequest) GetTbf() *Tbf
func (*TbfRequest) ProtoMessage ¶
func (*TbfRequest) ProtoMessage()
func (*TbfRequest) Reset ¶
func (m *TbfRequest) Reset()
func (*TbfRequest) String ¶
func (m *TbfRequest) String() string
func (*TbfRequest) XXX_DiscardUnknown ¶
func (m *TbfRequest) XXX_DiscardUnknown()
func (*TbfRequest) XXX_Marshal ¶
func (m *TbfRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TbfRequest) XXX_Merge ¶
func (m *TbfRequest) XXX_Merge(src proto.Message)
func (*TbfRequest) XXX_Size ¶
func (m *TbfRequest) XXX_Size() int
func (*TbfRequest) XXX_Unmarshal ¶
func (m *TbfRequest) XXX_Unmarshal(b []byte) error
type TcFilter ¶
type TcFilter struct { Parent *TcHandle `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*TcFilter) Descriptor ¶
func (*TcFilter) ProtoMessage ¶
func (*TcFilter) ProtoMessage()
func (*TcFilter) XXX_DiscardUnknown ¶
func (m *TcFilter) XXX_DiscardUnknown()
func (*TcFilter) XXX_Marshal ¶
func (*TcFilter) XXX_Unmarshal ¶
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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*TcFilterRequest) Descriptor ¶
func (*TcFilterRequest) Descriptor() ([]byte, []int)
func (*TcFilterRequest) GetContainerId ¶
func (m *TcFilterRequest) GetContainerId() string
func (*TcFilterRequest) GetFilter ¶
func (m *TcFilterRequest) GetFilter() *TcFilter
func (*TcFilterRequest) ProtoMessage ¶
func (*TcFilterRequest) ProtoMessage()
func (*TcFilterRequest) Reset ¶
func (m *TcFilterRequest) Reset()
func (*TcFilterRequest) String ¶
func (m *TcFilterRequest) String() string
func (*TcFilterRequest) XXX_DiscardUnknown ¶
func (m *TcFilterRequest) XXX_DiscardUnknown()
func (*TcFilterRequest) XXX_Marshal ¶
func (m *TcFilterRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TcFilterRequest) XXX_Merge ¶
func (m *TcFilterRequest) XXX_Merge(src proto.Message)
func (*TcFilterRequest) XXX_Size ¶
func (m *TcFilterRequest) XXX_Size() int
func (*TcFilterRequest) XXX_Unmarshal ¶
func (m *TcFilterRequest) XXX_Unmarshal(b []byte) error
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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*TcHandle) Descriptor ¶
func (*TcHandle) ProtoMessage ¶
func (*TcHandle) ProtoMessage()
func (*TcHandle) XXX_DiscardUnknown ¶
func (m *TcHandle) XXX_DiscardUnknown()
func (*TcHandle) XXX_Marshal ¶
func (*TcHandle) XXX_Unmarshal ¶
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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*TimeRequest) Descriptor ¶
func (*TimeRequest) Descriptor() ([]byte, []int)
func (*TimeRequest) GetClkIdsMask ¶
func (m *TimeRequest) GetClkIdsMask() uint64
func (*TimeRequest) GetContainerId ¶
func (m *TimeRequest) GetContainerId() string
func (*TimeRequest) GetNsec ¶
func (m *TimeRequest) GetNsec() int64
func (*TimeRequest) GetSec ¶
func (m *TimeRequest) GetSec() int64
func (*TimeRequest) ProtoMessage ¶
func (*TimeRequest) ProtoMessage()
func (*TimeRequest) Reset ¶
func (m *TimeRequest) Reset()
func (*TimeRequest) String ¶
func (m *TimeRequest) String() string
func (*TimeRequest) XXX_DiscardUnknown ¶
func (m *TimeRequest) XXX_DiscardUnknown()
func (*TimeRequest) XXX_Marshal ¶
func (m *TimeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TimeRequest) XXX_Merge ¶
func (m *TimeRequest) XXX_Merge(src proto.Message)
func (*TimeRequest) XXX_Size ¶
func (m *TimeRequest) XXX_Size() int
func (*TimeRequest) XXX_Unmarshal ¶
func (m *TimeRequest) XXX_Unmarshal(b []byte) error
Click to show internal directories.
Click to hide internal directories.