pb

package
v1.1.2 Latest Latest
Warning

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

 Go to latest Published: Mar 12, 2021 License: Apache-2.0 Imports: 6 Imported by: 42

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var Chain_Direction_name = map[int32]string{
	0: "INPUT",
	1: "OUTPUT",
}
View Source 
var Chain_Direction_value = map[string]int32{
	"INPUT":  0,
	"OUTPUT": 1,
}
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 Tc_Type_name = map[int32]string{
	0: "NETEM",
	1: "BANDWIDTH",
}
View Source 
var Tc_Type_value = map[string]int32{
	"NETEM":     0,
	"BANDWIDTH": 1,
}

Functions

func RegisterChaosDaemonServer 

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

Types

type ApplyIoChaosRequest added in v1.0.0 

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ApplyIoChaosRequest) Descriptor added in v1.0.0 

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

func (*ApplyIoChaosRequest) GetActions added in v1.0.0 

func (m *ApplyIoChaosRequest) GetActions() string

func (*ApplyIoChaosRequest) GetContainerId added in v1.0.0 

func (m *ApplyIoChaosRequest) GetContainerId() string

func (*ApplyIoChaosRequest) GetEnterNS added in v1.1.0 

func (m *ApplyIoChaosRequest) GetEnterNS() bool

func (*ApplyIoChaosRequest) GetInstance added in v1.0.0 

func (m *ApplyIoChaosRequest) GetInstance() int64

func (*ApplyIoChaosRequest) GetStartTime added in v1.0.0 

func (m *ApplyIoChaosRequest) GetStartTime() int64

func (*ApplyIoChaosRequest) GetVolume added in v1.0.0 

func (m *ApplyIoChaosRequest) GetVolume() string

func (*ApplyIoChaosRequest) ProtoMessage added in v1.0.0 

func (*ApplyIoChaosRequest) ProtoMessage()

func (*ApplyIoChaosRequest) Reset added in v1.0.0 

func (m *ApplyIoChaosRequest) Reset()

func (*ApplyIoChaosRequest) String added in v1.0.0 

func (m *ApplyIoChaosRequest) String() string

func (*ApplyIoChaosRequest) XXX_DiscardUnknown added in v1.0.0 

func (m *ApplyIoChaosRequest) XXX_DiscardUnknown()

func (*ApplyIoChaosRequest) XXX_Marshal added in v1.0.0 

func (m *ApplyIoChaosRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ApplyIoChaosRequest) XXX_Merge added in v1.0.0 

func (dst *ApplyIoChaosRequest) XXX_Merge(src proto.Message)

func (*ApplyIoChaosRequest) XXX_Size added in v1.0.0 

func (m *ApplyIoChaosRequest) XXX_Size() int

func (*ApplyIoChaosRequest) XXX_Unmarshal added in v1.0.0 

func (m *ApplyIoChaosRequest) XXX_Unmarshal(b []byte) error

type ApplyIoChaosResponse added in v1.0.0 

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ApplyIoChaosResponse) Descriptor added in v1.0.0 

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

func (*ApplyIoChaosResponse) GetInstance added in v1.0.0 

func (m *ApplyIoChaosResponse) GetInstance() int64

func (*ApplyIoChaosResponse) GetStartTime added in v1.0.0 

func (m *ApplyIoChaosResponse) GetStartTime() int64

func (*ApplyIoChaosResponse) ProtoMessage added in v1.0.0 

func (*ApplyIoChaosResponse) ProtoMessage()

func (*ApplyIoChaosResponse) Reset added in v1.0.0 

func (m *ApplyIoChaosResponse) Reset()

func (*ApplyIoChaosResponse) String added in v1.0.0 

func (m *ApplyIoChaosResponse) String() string

func (*ApplyIoChaosResponse) XXX_DiscardUnknown added in v1.0.0 

func (m *ApplyIoChaosResponse) XXX_DiscardUnknown()

func (*ApplyIoChaosResponse) XXX_Marshal added in v1.0.0 

func (m *ApplyIoChaosResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ApplyIoChaosResponse) XXX_Merge added in v1.0.0 

func (dst *ApplyIoChaosResponse) XXX_Merge(src proto.Message)

func (*ApplyIoChaosResponse) XXX_Size added in v1.0.0 

func (m *ApplyIoChaosResponse) XXX_Size() int

func (*ApplyIoChaosResponse) XXX_Unmarshal added in v1.0.0 

func (m *ApplyIoChaosResponse) XXX_Unmarshal(b []byte) error

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 (dst *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 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"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*Chain) Descriptor 

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

func (*Chain) GetDestinationPorts added in v1.1.0 

func (m *Chain) GetDestinationPorts() string

func (*Chain) GetDirection 

func (m *Chain) GetDirection() Chain_Direction

func (*Chain) GetIpsets 

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

func (*Chain) GetName 

func (m *Chain) GetName() string

func (*Chain) GetProtocol added in v1.1.0 

func (m *Chain) GetProtocol() string

func (*Chain) GetSourcePorts added in v1.1.0 

func (m *Chain) GetSourcePorts() string

func (*Chain) GetTarget added in v1.0.1 

func (m *Chain) GetTarget() string

func (*Chain) ProtoMessage 

func (*Chain) ProtoMessage()

func (*Chain) Reset 

func (m *Chain) Reset()

func (*Chain) String 

func (m *Chain) String() string

func (*Chain) XXX_DiscardUnknown 

func (m *Chain) XXX_DiscardUnknown()

func (*Chain) XXX_Marshal 

func (m *Chain) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Chain) XXX_Merge 

func (dst *Chain) XXX_Merge(src proto.Message)

func (*Chain) XXX_Size 

func (m *Chain) XXX_Size() int

func (*Chain) XXX_Unmarshal 

func (m *Chain) XXX_Unmarshal(b []byte) error

type Chain_Direction 

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

func (Chain_Direction) EnumDescriptor 

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

func (Chain_Direction) String 

func (x Chain_Direction) String() string

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)
	SetDNSServer(ctx context.Context, in *SetDNSServerRequest, 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 {
	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)
	SetDNSServer(context.Context, *SetDNSServerRequest) (*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=pb.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 (dst *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 (dst *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 (dst *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 (dst *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 (dst *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=pb.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"`
	EnterNS              bool                    `protobuf:"varint,4,opt,name=enterNS,proto3" json:"enterNS,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

func (*ExecStressRequest) Descriptor 

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

func (*ExecStressRequest) GetEnterNS added in v1.1.0 

func (m *ExecStressRequest) GetEnterNS() bool

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 (dst *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 (dst *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"`
	Cidrs                []string `protobuf:"bytes,2,rep,name=cidrs,proto3" json:"cidrs,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*IPSet) Descriptor 

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

func (*IPSet) GetCidrs 

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

func (*IPSet) GetName 

func (m *IPSet) GetName() string

func (*IPSet) ProtoMessage 

func (*IPSet) ProtoMessage()

func (*IPSet) Reset 

func (m *IPSet) Reset()

func (*IPSet) String 

func (m *IPSet) String() string

func (*IPSet) XXX_DiscardUnknown 

func (m *IPSet) XXX_DiscardUnknown()

func (*IPSet) XXX_Marshal 

func (m *IPSet) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*IPSet) XXX_Merge 

func (dst *IPSet) XXX_Merge(src proto.Message)

func (*IPSet) XXX_Size 

func (m *IPSet) XXX_Size() int

func (*IPSet) XXX_Unmarshal 

func (m *IPSet) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*IPSetsRequest) Descriptor 

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

func (*IPSetsRequest) GetContainerId 

func (m *IPSetsRequest) GetContainerId() string

func (*IPSetsRequest) GetEnterNS added in v1.1.0 

func (m *IPSetsRequest) GetEnterNS() bool

func (*IPSetsRequest) GetIpsets 

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

func (*IPSetsRequest) ProtoMessage 

func (*IPSetsRequest) ProtoMessage()

func (*IPSetsRequest) Reset 

func (m *IPSetsRequest) Reset()

func (*IPSetsRequest) String 

func (m *IPSetsRequest) String() string

func (*IPSetsRequest) XXX_DiscardUnknown 

func (m *IPSetsRequest) XXX_DiscardUnknown()

func (*IPSetsRequest) XXX_Marshal 

func (m *IPSetsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*IPSetsRequest) XXX_Merge 

func (dst *IPSetsRequest) XXX_Merge(src proto.Message)

func (*IPSetsRequest) XXX_Size 

func (m *IPSetsRequest) XXX_Size() int

func (*IPSetsRequest) XXX_Unmarshal 

func (m *IPSetsRequest) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*IptablesChainsRequest) Descriptor 

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

func (*IptablesChainsRequest) GetChains 

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

func (*IptablesChainsRequest) GetContainerId 

func (m *IptablesChainsRequest) GetContainerId() string

func (*IptablesChainsRequest) GetEnterNS added in v1.1.0 

func (m *IptablesChainsRequest) GetEnterNS() bool

func (*IptablesChainsRequest) ProtoMessage 

func (*IptablesChainsRequest) ProtoMessage()

func (*IptablesChainsRequest) Reset 

func (m *IptablesChainsRequest) Reset()

func (*IptablesChainsRequest) String 

func (m *IptablesChainsRequest) String() string

func (*IptablesChainsRequest) XXX_DiscardUnknown 

func (m *IptablesChainsRequest) XXX_DiscardUnknown()

func (*IptablesChainsRequest) XXX_Marshal 

func (m *IptablesChainsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*IptablesChainsRequest) XXX_Merge 

func (dst *IptablesChainsRequest) XXX_Merge(src proto.Message)

func (*IptablesChainsRequest) XXX_Size 

func (m *IptablesChainsRequest) XXX_Size() int

func (*IptablesChainsRequest) XXX_Unmarshal 

func (m *IptablesChainsRequest) 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) Descriptor() ([]byte, []int)

func (*Netem) GetCorrupt 

func (m *Netem) GetCorrupt() float32

func (*Netem) GetCorruptCorr 

func (m *Netem) GetCorruptCorr() float32

func (*Netem) GetDelayCorr 

func (m *Netem) GetDelayCorr() float32

func (*Netem) GetDuplicate 

func (m *Netem) GetDuplicate() float32

func (*Netem) GetDuplicateCorr 

func (m *Netem) GetDuplicateCorr() float32

func (*Netem) GetGap 

func (m *Netem) GetGap() uint32

func (*Netem) GetHandle 

func (m *Netem) GetHandle() *TcHandle

func (*Netem) GetJitter 

func (m *Netem) GetJitter() uint32

func (*Netem) GetLimit 

func (m *Netem) GetLimit() uint32

func (*Netem) GetLoss 

func (m *Netem) GetLoss() float32

func (*Netem) GetLossCorr 

func (m *Netem) GetLossCorr() float32

func (*Netem) GetParent 

func (m *Netem) GetParent() *TcHandle

func (*Netem) GetReorder 

func (m *Netem) GetReorder() float32

func (*Netem) GetReorderCorr 

func (m *Netem) GetReorderCorr() float32

func (*Netem) GetTime 

func (m *Netem) GetTime() uint32

func (*Netem) ProtoMessage 

func (*Netem) ProtoMessage()

func (*Netem) Reset 

func (m *Netem) Reset()

func (*Netem) String 

func (m *Netem) String() string

func (*Netem) XXX_DiscardUnknown 

func (m *Netem) XXX_DiscardUnknown()

func (*Netem) XXX_Marshal 

func (m *Netem) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Netem) XXX_Merge 

func (dst *Netem) XXX_Merge(src proto.Message)

func (*Netem) XXX_Size 

func (m *Netem) XXX_Size() int

func (*Netem) XXX_Unmarshal 

func (m *Netem) XXX_Unmarshal(b []byte) error

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 (dst *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) Descriptor() ([]byte, []int)

func (*Qdisc) GetArgs 

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

func (*Qdisc) GetHandle 

func (m *Qdisc) GetHandle() *TcHandle

func (*Qdisc) GetParent 

func (m *Qdisc) GetParent() *TcHandle

func (*Qdisc) GetType 

func (m *Qdisc) GetType() string

func (*Qdisc) ProtoMessage 

func (*Qdisc) ProtoMessage()

func (*Qdisc) Reset 

func (m *Qdisc) Reset()

func (*Qdisc) String 

func (m *Qdisc) String() string

func (*Qdisc) XXX_DiscardUnknown 

func (m *Qdisc) XXX_DiscardUnknown()

func (*Qdisc) XXX_Marshal 

func (m *Qdisc) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Qdisc) XXX_Merge 

func (dst *Qdisc) XXX_Merge(src proto.Message)

func (*Qdisc) XXX_Size 

func (m *Qdisc) XXX_Size() int

func (*Qdisc) XXX_Unmarshal 

func (m *Qdisc) XXX_Unmarshal(b []byte) error

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 (dst *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 SetDNSServerRequest added in v1.1.0 

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SetDNSServerRequest) Descriptor added in v1.1.0 

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

func (*SetDNSServerRequest) GetContainerId added in v1.1.0 

func (m *SetDNSServerRequest) GetContainerId() string

func (*SetDNSServerRequest) GetDnsServer added in v1.1.0 

func (m *SetDNSServerRequest) GetDnsServer() string

func (*SetDNSServerRequest) GetEnable added in v1.1.0 

func (m *SetDNSServerRequest) GetEnable() bool

func (*SetDNSServerRequest) GetEnterNS added in v1.1.0 

func (m *SetDNSServerRequest) GetEnterNS() bool

func (*SetDNSServerRequest) ProtoMessage added in v1.1.0 

func (*SetDNSServerRequest) ProtoMessage()

func (*SetDNSServerRequest) Reset added in v1.1.0 

func (m *SetDNSServerRequest) Reset()

func (*SetDNSServerRequest) String added in v1.1.0 

func (m *SetDNSServerRequest) String() string

func (*SetDNSServerRequest) XXX_DiscardUnknown added in v1.1.0 

func (m *SetDNSServerRequest) XXX_DiscardUnknown()

func (*SetDNSServerRequest) XXX_Marshal added in v1.1.0 

func (m *SetDNSServerRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SetDNSServerRequest) XXX_Merge added in v1.1.0 

func (dst *SetDNSServerRequest) XXX_Merge(src proto.Message)

func (*SetDNSServerRequest) XXX_Size added in v1.1.0 

func (m *SetDNSServerRequest) XXX_Size() int

func (*SetDNSServerRequest) XXX_Unmarshal added in v1.1.0 

func (m *SetDNSServerRequest) XXX_Unmarshal(b []byte) error

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) Descriptor() ([]byte, []int)

func (*Tbf) GetBuffer 

func (m *Tbf) GetBuffer() uint32

func (*Tbf) GetLimit 

func (m *Tbf) GetLimit() uint32

func (*Tbf) GetMinBurst 

func (m *Tbf) GetMinBurst() uint32

func (*Tbf) GetPeakRate 

func (m *Tbf) GetPeakRate() uint64

func (*Tbf) GetRate 

func (m *Tbf) GetRate() uint64

func (*Tbf) ProtoMessage 

func (*Tbf) ProtoMessage()

func (*Tbf) Reset 

func (m *Tbf) Reset()

func (*Tbf) String 

func (m *Tbf) String() string

func (*Tbf) XXX_DiscardUnknown 

func (m *Tbf) XXX_DiscardUnknown()

func (*Tbf) XXX_Marshal 

func (m *Tbf) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Tbf) XXX_Merge 

func (dst *Tbf) XXX_Merge(src proto.Message)

func (*Tbf) XXX_Size 

func (m *Tbf) XXX_Size() int

func (*Tbf) XXX_Unmarshal 

func (m *Tbf) XXX_Unmarshal(b []byte) error

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 (dst *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 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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Tc) Descriptor 

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

func (*Tc) GetEgressPort added in v1.1.0 

func (m *Tc) GetEgressPort() string

func (*Tc) GetIpset 

func (m *Tc) GetIpset() string

func (*Tc) GetNetem 

func (m *Tc) GetNetem() *Netem

func (*Tc) GetProtocol added in v1.1.0 

func (m *Tc) GetProtocol() string

func (*Tc) GetSourcePort added in v1.1.0 

func (m *Tc) GetSourcePort() string

func (*Tc) GetTbf 

func (m *Tc) GetTbf() *Tbf

func (*Tc) GetType 

func (m *Tc) GetType() Tc_Type

func (*Tc) ProtoMessage 

func (*Tc) ProtoMessage()

func (*Tc) Reset 

func (m *Tc) Reset()

func (*Tc) String 

func (m *Tc) String() string

func (*Tc) XXX_DiscardUnknown 

func (m *Tc) XXX_DiscardUnknown()

func (*Tc) XXX_Marshal 

func (m *Tc) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Tc) XXX_Merge 

func (dst *Tc) XXX_Merge(src proto.Message)

func (*Tc) XXX_Size 

func (m *Tc) XXX_Size() int

func (*Tc) XXX_Unmarshal 

func (m *Tc) 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) Descriptor() ([]byte, []int)

func (*TcFilter) GetParent 

func (m *TcFilter) GetParent() *TcHandle

func (*TcFilter) ProtoMessage 

func (*TcFilter) ProtoMessage()

func (*TcFilter) Reset 

func (m *TcFilter) Reset()

func (*TcFilter) String 

func (m *TcFilter) String() string

func (*TcFilter) XXX_DiscardUnknown 

func (m *TcFilter) XXX_DiscardUnknown()

func (*TcFilter) XXX_Marshal 

func (m *TcFilter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TcFilter) XXX_Merge 

func (dst *TcFilter) XXX_Merge(src proto.Message)

func (*TcFilter) XXX_Size 

func (m *TcFilter) XXX_Size() int

func (*TcFilter) XXX_Unmarshal 

func (m *TcFilter) XXX_Unmarshal(b []byte) error

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 (dst *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) Descriptor() ([]byte, []int)

func (*TcHandle) GetMajor 

func (m *TcHandle) GetMajor() uint32

func (*TcHandle) GetMinor 

func (m *TcHandle) GetMinor() uint32

func (*TcHandle) ProtoMessage 

func (*TcHandle) ProtoMessage()

func (*TcHandle) Reset 

func (m *TcHandle) Reset()

func (*TcHandle) String 

func (m *TcHandle) String() string

func (*TcHandle) XXX_DiscardUnknown 

func (m *TcHandle) XXX_DiscardUnknown()

func (*TcHandle) XXX_Marshal 

func (m *TcHandle) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TcHandle) XXX_Merge 

func (dst *TcHandle) XXX_Merge(src proto.Message)

func (*TcHandle) XXX_Size 

func (m *TcHandle) XXX_Size() int

func (*TcHandle) XXX_Unmarshal 

func (m *TcHandle) XXX_Unmarshal(b []byte) error

type Tc_Type 

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

func (Tc_Type) EnumDescriptor 

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

func (Tc_Type) String 

func (x Tc_Type) String() string

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"`
	Device               string   `protobuf:"bytes,3,opt,name=device,proto3" json:"device,omitempty"`
	EnterNS              bool     `protobuf:"varint,4,opt,name=enterNS,proto3" json:"enterNS,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TcsRequest) Descriptor 

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

func (*TcsRequest) GetContainerId 

func (m *TcsRequest) GetContainerId() string

func (*TcsRequest) GetDevice added in v1.1.0 

func (m *TcsRequest) GetDevice() string

func (*TcsRequest) GetEnterNS added in v1.1.0 

func (m *TcsRequest) GetEnterNS() bool

func (*TcsRequest) GetTcs 

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

func (*TcsRequest) ProtoMessage 

func (*TcsRequest) ProtoMessage()

func (*TcsRequest) Reset 

func (m *TcsRequest) Reset()

func (*TcsRequest) String 

func (m *TcsRequest) String() string

func (*TcsRequest) XXX_DiscardUnknown 

func (m *TcsRequest) XXX_DiscardUnknown()

func (*TcsRequest) XXX_Marshal 

func (m *TcsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TcsRequest) XXX_Merge 

func (dst *TcsRequest) XXX_Merge(src proto.Message)

func (*TcsRequest) XXX_Size 

func (m *TcsRequest) XXX_Size() int

func (*TcsRequest) XXX_Unmarshal 

func (m *TcsRequest) XXX_Unmarshal(b []byte) error

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 (dst *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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.