▽

Package bpfki

Variables

Enum value maps for FailKernRequest_FAILTYPE.

var (
    FailKernRequest_FAILTYPE_name = map[int32]string{
        0: "SLAB",
        1: "PAGE",
        2: "BIO",
    }
    FailKernRequest_FAILTYPE_value = map[string]int32{
        "SLAB": 0,
        "PAGE": 1,
        "BIO":  2,
    }
)

var File_bpfki_proto protoreflect.FileDescriptor

func RegisterBPFKIServiceServer ¶

func RegisterBPFKIServiceServer(s *grpc.Server, srv BPFKIServiceServer)

type BPFKIServiceClient ¶

BPFKIServiceClient is the client API for BPFKIService service.

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

type BPFKIServiceClient interface {
    SetTimeVal(ctx context.Context, in *BumpTimeRequest, opts ...grpc.CallOption) (*StatusResponse, error)
    RecoverTimeVal(ctx context.Context, in *BumpTimeRequest, opts ...grpc.CallOption) (*StatusResponse, error)
    SetTimeSpec(ctx context.Context, in *BumpTimeRequest, opts ...grpc.CallOption) (*StatusResponse, error)
    RecoverTimeSpec(ctx context.Context, in *BumpTimeRequest, opts ...grpc.CallOption) (*StatusResponse, error)
    FailMMOrBIO(ctx context.Context, in *FailKernRequest, opts ...grpc.CallOption) (*StatusResponse, error)
    RecoverMMOrBIO(ctx context.Context, in *FailKernRequest, opts ...grpc.CallOption) (*StatusResponse, error)
    FailSyscall(ctx context.Context, in *FailSyscallRequest, opts ...grpc.CallOption) (*StatusResponse, error)
    RecoverSyscall(ctx context.Context, in *FailSyscallRequest, opts ...grpc.CallOption) (*StatusResponse, error)
}

func NewBPFKIServiceClient ¶

func NewBPFKIServiceClient(cc grpc.ClientConnInterface) BPFKIServiceClient

type BPFKIServiceServer ¶

BPFKIServiceServer is the server API for BPFKIService service.

type BPFKIServiceServer interface {
    SetTimeVal(context.Context, *BumpTimeRequest) (*StatusResponse, error)
    RecoverTimeVal(context.Context, *BumpTimeRequest) (*StatusResponse, error)
    SetTimeSpec(context.Context, *BumpTimeRequest) (*StatusResponse, error)
    RecoverTimeSpec(context.Context, *BumpTimeRequest) (*StatusResponse, error)
    FailMMOrBIO(context.Context, *FailKernRequest) (*StatusResponse, error)
    RecoverMMOrBIO(context.Context, *FailKernRequest) (*StatusResponse, error)
    FailSyscall(context.Context, *FailSyscallRequest) (*StatusResponse, error)
    RecoverSyscall(context.Context, *FailSyscallRequest) (*StatusResponse, error)
}

type BumpTimeRequest ¶

type BumpTimeRequest struct {
    Pid         uint32  `protobuf:"varint,1,opt,name=pid,proto3" json:"pid,omitempty"`
    Tid         uint32  `protobuf:"varint,2,opt,name=tid,proto3" json:"tid,omitempty"`
    Second      int32   `protobuf:"varint,3,opt,name=second,proto3" json:"second,omitempty"`
    Subsecond   int32   `protobuf:"varint,4,opt,name=subsecond,proto3" json:"subsecond,omitempty"`
    Probability float32 `protobuf:"fixed32,5,opt,name=probability,proto3" json:"probability,omitempty"`
    // contains filtered or unexported fields
}

func (*BumpTimeRequest) Descriptor ¶

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

Deprecated: Use BumpTimeRequest.ProtoReflect.Descriptor instead.

func (*BumpTimeRequest) GetPid ¶

func (x *BumpTimeRequest) GetPid() uint32

func (*BumpTimeRequest) GetProbability ¶

func (x *BumpTimeRequest) GetProbability() float32

func (*BumpTimeRequest) GetSecond ¶

func (x *BumpTimeRequest) GetSecond() int32

func (*BumpTimeRequest) GetSubsecond ¶

func (x *BumpTimeRequest) GetSubsecond() int32

func (*BumpTimeRequest) GetTid ¶

func (x *BumpTimeRequest) GetTid() uint32

func (*BumpTimeRequest) ProtoMessage ¶

func (*BumpTimeRequest) ProtoMessage()

func (*BumpTimeRequest) ProtoReflect ¶

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

func (*BumpTimeRequest) Reset ¶

func (x *BumpTimeRequest) Reset()

func (*BumpTimeRequest) String ¶

func (x *BumpTimeRequest) String() string

type FailKernRequest ¶

type FailKernRequest struct {
    Pid         uint32                   `protobuf:"varint,1,opt,name=pid,proto3" json:"pid,omitempty"`
    Tid         uint32                   `protobuf:"varint,2,opt,name=tid,proto3" json:"tid,omitempty"`
    Ftype       FailKernRequest_FAILTYPE `protobuf:"varint,3,opt,name=ftype,proto3,enum=bpfki.FailKernRequest_FAILTYPE" json:"ftype,omitempty"`
    Headers     []string                 `protobuf:"bytes,4,rep,name=headers,proto3" json:"headers,omitempty"`
    Callchain   []*FailKernRequestFrame  `protobuf:"bytes,5,rep,name=callchain,proto3" json:"callchain,omitempty"`
    Probability float32                  `protobuf:"fixed32,6,opt,name=probability,proto3" json:"probability,omitempty"`
    Times       uint32                   `protobuf:"varint,7,opt,name=times,proto3" json:"times,omitempty"`
    // contains filtered or unexported fields
}

func (*FailKernRequest) Descriptor ¶

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

Deprecated: Use FailKernRequest.ProtoReflect.Descriptor instead.

func (*FailKernRequest) GetCallchain ¶

func (x *FailKernRequest) GetCallchain() []*FailKernRequestFrame

func (*FailKernRequest) GetFtype ¶

func (x *FailKernRequest) GetFtype() FailKernRequest_FAILTYPE

func (*FailKernRequest) GetHeaders ¶

func (x *FailKernRequest) GetHeaders() []string

func (*FailKernRequest) GetPid ¶

func (x *FailKernRequest) GetPid() uint32

func (*FailKernRequest) GetProbability ¶

func (x *FailKernRequest) GetProbability() float32

func (*FailKernRequest) GetTid ¶

func (x *FailKernRequest) GetTid() uint32

func (*FailKernRequest) GetTimes ¶

func (x *FailKernRequest) GetTimes() uint32

func (*FailKernRequest) ProtoMessage ¶

func (*FailKernRequest) ProtoMessage()

func (*FailKernRequest) ProtoReflect ¶

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

func (*FailKernRequest) Reset ¶

func (x *FailKernRequest) Reset()

func (*FailKernRequest) String ¶

func (x *FailKernRequest) String() string

type FailKernRequestFrame ¶

type FailKernRequestFrame struct {
    Funcname   string `protobuf:"bytes,1,opt,name=funcname,proto3" json:"funcname,omitempty"`
    Parameters string `protobuf:"bytes,2,opt,name=parameters,proto3" json:"parameters,omitempty"`
    Predicate  string `protobuf:"bytes,3,opt,name=predicate,proto3" json:"predicate,omitempty"`
    // contains filtered or unexported fields
}

func (*FailKernRequestFrame) Descriptor ¶

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

Deprecated: Use FailKernRequestFrame.ProtoReflect.Descriptor instead.

func (*FailKernRequestFrame) GetFuncname ¶

func (x *FailKernRequestFrame) GetFuncname() string

func (*FailKernRequestFrame) GetParameters ¶

func (x *FailKernRequestFrame) GetParameters() string

func (*FailKernRequestFrame) GetPredicate ¶

func (x *FailKernRequestFrame) GetPredicate() string

func (*FailKernRequestFrame) ProtoMessage ¶

func (*FailKernRequestFrame) ProtoMessage()

func (*FailKernRequestFrame) ProtoReflect ¶

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

func (*FailKernRequestFrame) Reset ¶

func (x *FailKernRequestFrame) Reset()

func (*FailKernRequestFrame) String ¶

func (x *FailKernRequestFrame) String() string

type FailKernRequest_FAILTYPE ¶

type FailKernRequest_FAILTYPE int32

const (
    FailKernRequest_SLAB FailKernRequest_FAILTYPE = 0
    FailKernRequest_PAGE FailKernRequest_FAILTYPE = 1
    FailKernRequest_BIO  FailKernRequest_FAILTYPE = 2
)

func (FailKernRequest_FAILTYPE) Descriptor ¶

func (FailKernRequest_FAILTYPE) Descriptor() protoreflect.EnumDescriptor

func (FailKernRequest_FAILTYPE) Enum ¶

func (x FailKernRequest_FAILTYPE) Enum() *FailKernRequest_FAILTYPE

func (FailKernRequest_FAILTYPE) EnumDescriptor ¶

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

Deprecated: Use FailKernRequest_FAILTYPE.Descriptor instead.

func (FailKernRequest_FAILTYPE) Number ¶

func (x FailKernRequest_FAILTYPE) Number() protoreflect.EnumNumber

func (FailKernRequest_FAILTYPE) String ¶

func (x FailKernRequest_FAILTYPE) String() string

func (FailKernRequest_FAILTYPE) Type ¶

func (FailKernRequest_FAILTYPE) Type() protoreflect.EnumType

type FailSyscallRequest ¶

type FailSyscallRequest struct {
    Pid         uint32   `protobuf:"varint,1,opt,name=pid,proto3" json:"pid,omitempty"`
    Tid         uint32   `protobuf:"varint,2,opt,name=tid,proto3" json:"tid,omitempty"`
    Methods     []string `protobuf:"bytes,3,rep,name=methods,proto3" json:"methods,omitempty"`
    Err         uint32   `protobuf:"varint,4,opt,name=err,proto3" json:"err,omitempty"`
    Probability float32  `protobuf:"fixed32,5,opt,name=probability,proto3" json:"probability,omitempty"`
    // contains filtered or unexported fields
}

func (*FailSyscallRequest) Descriptor ¶

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

Deprecated: Use FailSyscallRequest.ProtoReflect.Descriptor instead.

func (*FailSyscallRequest) GetErr ¶

func (x *FailSyscallRequest) GetErr() uint32

func (*FailSyscallRequest) GetMethods ¶

func (x *FailSyscallRequest) GetMethods() []string

func (*FailSyscallRequest) GetPid ¶

func (x *FailSyscallRequest) GetPid() uint32

func (*FailSyscallRequest) GetProbability ¶

func (x *FailSyscallRequest) GetProbability() float32

func (*FailSyscallRequest) GetTid ¶

func (x *FailSyscallRequest) GetTid() uint32

func (*FailSyscallRequest) ProtoMessage ¶

func (*FailSyscallRequest) ProtoMessage()

func (*FailSyscallRequest) ProtoReflect ¶

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

func (*FailSyscallRequest) Reset ¶

func (x *FailSyscallRequest) Reset()

func (*FailSyscallRequest) String ¶

func (x *FailSyscallRequest) String() string

type StatusResponse ¶

type StatusResponse struct {
    Ret int32  `protobuf:"varint,1,opt,name=ret,proto3" json:"ret,omitempty"`
    Msg string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
    // contains filtered or unexported fields
}

func (*StatusResponse) Descriptor ¶

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

Deprecated: Use StatusResponse.ProtoReflect.Descriptor instead.

func (*StatusResponse) GetMsg ¶

func (x *StatusResponse) GetMsg() string

func (*StatusResponse) GetRet ¶

func (x *StatusResponse) GetRet() int32

func (*StatusResponse) ProtoMessage ¶

func (*StatusResponse) ProtoMessage()

func (*StatusResponse) ProtoReflect ¶

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

func (*StatusResponse) Reset ¶

func (x *StatusResponse) Reset()

func (*StatusResponse) String ¶

func (x *StatusResponse) String() string

type UnimplementedBPFKIServiceServer ¶

UnimplementedBPFKIServiceServer can be embedded to have forward compatible implementations.

type UnimplementedBPFKIServiceServer struct {
}

func (*UnimplementedBPFKIServiceServer) FailMMOrBIO ¶

func (*UnimplementedBPFKIServiceServer) FailMMOrBIO(context.Context, *FailKernRequest) (*StatusResponse, error)

func (*UnimplementedBPFKIServiceServer) FailSyscall ¶

func (*UnimplementedBPFKIServiceServer) FailSyscall(context.Context, *FailSyscallRequest) (*StatusResponse, error)

func (*UnimplementedBPFKIServiceServer) RecoverMMOrBIO ¶

func (*UnimplementedBPFKIServiceServer) RecoverMMOrBIO(context.Context, *FailKernRequest) (*StatusResponse, error)

func (*UnimplementedBPFKIServiceServer) RecoverSyscall ¶

func (*UnimplementedBPFKIServiceServer) RecoverSyscall(context.Context, *FailSyscallRequest) (*StatusResponse, error)

func (*UnimplementedBPFKIServiceServer) RecoverTimeSpec ¶

func (*UnimplementedBPFKIServiceServer) RecoverTimeSpec(context.Context, *BumpTimeRequest) (*StatusResponse, error)

func (*UnimplementedBPFKIServiceServer) RecoverTimeVal ¶

func (*UnimplementedBPFKIServiceServer) RecoverTimeVal(context.Context, *BumpTimeRequest) (*StatusResponse, error)

func (*UnimplementedBPFKIServiceServer) SetTimeSpec ¶

func (*UnimplementedBPFKIServiceServer) SetTimeSpec(context.Context, *BumpTimeRequest) (*StatusResponse, error)

func (*UnimplementedBPFKIServiceServer) SetTimeVal ¶

func (*UnimplementedBPFKIServiceServer) SetTimeVal(context.Context, *BumpTimeRequest) (*StatusResponse, error)