fault

type FaultInjectClient interface {
	Intercept(ctx context.Context, opts ...grpc.CallOption) (FaultInject_InterceptClient, error)
}

type FaultInjectServer interface {
	Intercept(FaultInject_InterceptServer) error
}

type FaultInject_InterceptClient interface {
	Send(*InterceptRequest) error
	Recv() (*InterceptResponse, error)
	grpc.ClientStream
}

type FaultInject_InterceptServer interface {
	Send(*InterceptResponse) error
	Recv() (*InterceptRequest, error)
	grpc.ServerStream
}

type FaultMessage struct {
	MsgId  string         `protobuf:"bytes,1,opt,name=msg_id,json=msgId,proto3" json:"msg_id,omitempty"`
	Msg    *anypb.Any     `protobuf:"bytes,3,opt,name=msg,proto3" json:"msg,omitempty"`
	Status *status.Status `protobuf:"bytes,4,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

type InterceptRequest struct {

	// Types that are valid to be assigned to Msg:
	//
	//	*InterceptRequest_IntSub
	//	*InterceptRequest_FaultMsg
	Msg isInterceptRequest_Msg `protobuf_oneof:"msg"`
	// contains filtered or unexported fields
}

type InterceptRequest_FaultMsg struct {
	FaultMsg *FaultMessage `protobuf:"bytes,2,opt,name=fault_msg,json=faultMsg,proto3,oneof"`
}

type InterceptRequest_IntSub struct {
	IntSub *InterceptSubRequest `protobuf:"bytes,1,opt,name=int_sub,json=intSub,proto3,oneof"`
}

type InterceptResponse struct {
	OriginalMsg *ServerMessage `protobuf:"bytes,1,opt,name=original_msg,json=originalMsg,proto3" json:"original_msg,omitempty"`
	// contains filtered or unexported fields
}

type InterceptSubRequest struct {
	Method string `protobuf:"bytes,1,opt,name=method,proto3" json:"method,omitempty"`
	// contains filtered or unexported fields
}

type MessageType int32

type ServerMessage struct {
	RpcId   string         `protobuf:"bytes,1,opt,name=rpc_id,json=rpcId,proto3" json:"rpc_id,omitempty"`
	MsgId   string         `protobuf:"bytes,2,opt,name=msg_id,json=msgId,proto3" json:"msg_id,omitempty"`
	MsgType MessageType    `protobuf:"varint,3,opt,name=msg_type,json=msgType,proto3,enum=lemming.fault.MessageType" json:"msg_type,omitempty"`
	Msg     *anypb.Any     `protobuf:"bytes,4,opt,name=msg,proto3" json:"msg,omitempty"`
	Status  *status.Status `protobuf:"bytes,5,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedFaultInjectServer struct {
}