bpfki

package
v1.2.3 Latest Latest
Warning

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

 Go to latest Published: Jul 28, 2021 License: Apache-2.0 Imports: 7 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

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

Functions

func RegisterBPFKIServiceServer 

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

Types

type BPFKIServiceClient 

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)
}

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.

func NewBPFKIServiceClient 

func NewBPFKIServiceClient(cc *grpc.ClientConn) BPFKIServiceClient

type BPFKIServiceServer 

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)
}

BPFKIServiceServer is the server API for BPFKIService service.

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

func (*BumpTimeRequest) Descriptor 

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

func (*BumpTimeRequest) GetPid 

func (m *BumpTimeRequest) GetPid() uint32

func (*BumpTimeRequest) GetProbability 

func (m *BumpTimeRequest) GetProbability() float32

func (*BumpTimeRequest) GetSecond 

func (m *BumpTimeRequest) GetSecond() int32

func (*BumpTimeRequest) GetSubsecond 

func (m *BumpTimeRequest) GetSubsecond() int32

func (*BumpTimeRequest) GetTid 

func (m *BumpTimeRequest) GetTid() uint32

func (*BumpTimeRequest) ProtoMessage 

func (*BumpTimeRequest) ProtoMessage()

func (*BumpTimeRequest) Reset 

func (m *BumpTimeRequest) Reset()

func (*BumpTimeRequest) String 

func (m *BumpTimeRequest) String() string

func (*BumpTimeRequest) XXX_DiscardUnknown 

func (m *BumpTimeRequest) XXX_DiscardUnknown()

func (*BumpTimeRequest) XXX_Marshal 

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

func (*BumpTimeRequest) XXX_Merge 

func (m *BumpTimeRequest) XXX_Merge(src proto.Message)

func (*BumpTimeRequest) XXX_Size 

func (m *BumpTimeRequest) XXX_Size() int

func (*BumpTimeRequest) XXX_Unmarshal 

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

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

func (*FailKernRequest) Descriptor 

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

func (*FailKernRequest) GetCallchain 

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

func (*FailKernRequest) GetFtype 

func (m *FailKernRequest) GetFtype() FailKernRequest_FAILTYPE

func (*FailKernRequest) GetHeaders 

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

func (*FailKernRequest) GetPid 

func (m *FailKernRequest) GetPid() uint32

func (*FailKernRequest) GetProbability 

func (m *FailKernRequest) GetProbability() float32

func (*FailKernRequest) GetTid 

func (m *FailKernRequest) GetTid() uint32

func (*FailKernRequest) GetTimes 

func (m *FailKernRequest) GetTimes() uint32

func (*FailKernRequest) ProtoMessage 

func (*FailKernRequest) ProtoMessage()

func (*FailKernRequest) Reset 

func (m *FailKernRequest) Reset()

func (*FailKernRequest) String 

func (m *FailKernRequest) String() string

func (*FailKernRequest) XXX_DiscardUnknown 

func (m *FailKernRequest) XXX_DiscardUnknown()

func (*FailKernRequest) XXX_Marshal 

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

func (*FailKernRequest) XXX_Merge 

func (m *FailKernRequest) XXX_Merge(src proto.Message)

func (*FailKernRequest) XXX_Size 

func (m *FailKernRequest) XXX_Size() int

func (*FailKernRequest) XXX_Unmarshal 

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

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

func (*FailKernRequestFrame) Descriptor 

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

func (*FailKernRequestFrame) GetFuncname 

func (m *FailKernRequestFrame) GetFuncname() string

func (*FailKernRequestFrame) GetParameters 

func (m *FailKernRequestFrame) GetParameters() string

func (*FailKernRequestFrame) GetPredicate 

func (m *FailKernRequestFrame) GetPredicate() string

func (*FailKernRequestFrame) ProtoMessage 

func (*FailKernRequestFrame) ProtoMessage()

func (*FailKernRequestFrame) Reset 

func (m *FailKernRequestFrame) Reset()

func (*FailKernRequestFrame) String 

func (m *FailKernRequestFrame) String() string

func (*FailKernRequestFrame) XXX_DiscardUnknown 

func (m *FailKernRequestFrame) XXX_DiscardUnknown()

func (*FailKernRequestFrame) XXX_Marshal 

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

func (*FailKernRequestFrame) XXX_Merge 

func (m *FailKernRequestFrame) XXX_Merge(src proto.Message)

func (*FailKernRequestFrame) XXX_Size 

func (m *FailKernRequestFrame) XXX_Size() int

func (*FailKernRequestFrame) XXX_Unmarshal 

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

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) EnumDescriptor 

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

func (FailKernRequest_FAILTYPE) String 

func (x FailKernRequest_FAILTYPE) String() string

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

func (*FailSyscallRequest) Descriptor 

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

func (*FailSyscallRequest) GetErr 

func (m *FailSyscallRequest) GetErr() uint32

func (*FailSyscallRequest) GetMethods 

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

func (*FailSyscallRequest) GetPid 

func (m *FailSyscallRequest) GetPid() uint32

func (*FailSyscallRequest) GetProbability 

func (m *FailSyscallRequest) GetProbability() float32

func (*FailSyscallRequest) GetTid 

func (m *FailSyscallRequest) GetTid() uint32

func (*FailSyscallRequest) ProtoMessage 

func (*FailSyscallRequest) ProtoMessage()

func (*FailSyscallRequest) Reset 

func (m *FailSyscallRequest) Reset()

func (*FailSyscallRequest) String 

func (m *FailSyscallRequest) String() string

func (*FailSyscallRequest) XXX_DiscardUnknown 

func (m *FailSyscallRequest) XXX_DiscardUnknown()

func (*FailSyscallRequest) XXX_Marshal 

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

func (*FailSyscallRequest) XXX_Merge 

func (m *FailSyscallRequest) XXX_Merge(src proto.Message)

func (*FailSyscallRequest) XXX_Size 

func (m *FailSyscallRequest) XXX_Size() int

func (*FailSyscallRequest) XXX_Unmarshal 

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

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

func (*StatusResponse) Descriptor 

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

func (*StatusResponse) GetMsg 

func (m *StatusResponse) GetMsg() string

func (*StatusResponse) GetRet 

func (m *StatusResponse) GetRet() int32

func (*StatusResponse) ProtoMessage 

func (*StatusResponse) ProtoMessage()

func (*StatusResponse) Reset 

func (m *StatusResponse) Reset()

func (*StatusResponse) String 

func (m *StatusResponse) String() string

func (*StatusResponse) XXX_DiscardUnknown 

func (m *StatusResponse) XXX_DiscardUnknown()

func (*StatusResponse) XXX_Marshal 

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

func (*StatusResponse) XXX_Merge 

func (m *StatusResponse) XXX_Merge(src proto.Message)

func (*StatusResponse) XXX_Size 

func (m *StatusResponse) XXX_Size() int

func (*StatusResponse) XXX_Unmarshal 

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

type UnimplementedBPFKIServiceServer 

type UnimplementedBPFKIServiceServer struct {
}

UnimplementedBPFKIServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedBPFKIServiceServer) FailMMOrBIO 

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

func (*UnimplementedBPFKIServiceServer) FailSyscall 

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

func (*UnimplementedBPFKIServiceServer) RecoverMMOrBIO 

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

func (*UnimplementedBPFKIServiceServer) RecoverSyscall 

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

func (*UnimplementedBPFKIServiceServer) RecoverTimeSpec 

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

func (*UnimplementedBPFKIServiceServer) RecoverTimeVal 

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

func (*UnimplementedBPFKIServiceServer) SetTimeSpec 

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

func (*UnimplementedBPFKIServiceServer) SetTimeVal 

func (*UnimplementedBPFKIServiceServer) SetTimeVal(ctx context.Context, req *BumpTimeRequest) (*StatusResponse, 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.