Documentation ¶
Index ¶
- Variables
- func RegisterKernelServer(s grpc.ServiceRegistrar, srv KernelServer)
- type CacheRequest
- func (*CacheRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CacheRequest) GetKey() string
- func (x *CacheRequest) GetWrite() string
- func (*CacheRequest) ProtoMessage()
- func (x *CacheRequest) ProtoReflect() protoreflect.Message
- func (x *CacheRequest) Reset()
- func (x *CacheRequest) String() string
- type CacheResponse
- type CancelEvaluate
- type Content
- type EvaluateError
- func (*EvaluateError) Descriptor() ([]byte, []int)deprecated
- func (x *EvaluateError) GetMessage() string
- func (x *EvaluateError) GetPosition() *LineAndColumn
- func (x *EvaluateError) GetStack() string
- func (*EvaluateError) ProtoMessage()
- func (x *EvaluateError) ProtoReflect() protoreflect.Message
- func (x *EvaluateError) Reset()
- func (x *EvaluateError) String() string
- type EvaluateRequest
- type EvaluateResponse
- func (*EvaluateResponse) Descriptor() ([]byte, []int)deprecated
- func (x *EvaluateResponse) GetDuration() *durationpb.Duration
- func (x *EvaluateResponse) GetErrors() []*EvaluateError
- func (*EvaluateResponse) ProtoMessage()
- func (x *EvaluateResponse) ProtoReflect() protoreflect.Message
- func (x *EvaluateResponse) Reset()
- func (x *EvaluateResponse) String() string
- type KernelClient
- type KernelServer
- type Kernel_SessionClient
- type Kernel_SessionServer
- type LineAndColumn
- func (*LineAndColumn) Descriptor() ([]byte, []int)deprecated
- func (x *LineAndColumn) GetColumn() int32
- func (x *LineAndColumn) GetLine() int32
- func (*LineAndColumn) ProtoMessage()
- func (x *LineAndColumn) ProtoReflect() protoreflect.Message
- func (x *LineAndColumn) Reset()
- func (x *LineAndColumn) String() string
- type Output
- type PackageExports
- type PromptRequest
- func (*PromptRequest) Descriptor() ([]byte, []int)deprecated
- func (x *PromptRequest) GetPassword() bool
- func (x *PromptRequest) GetPlaceholder() string
- func (x *PromptRequest) GetPrompt() string
- func (*PromptRequest) ProtoMessage()
- func (x *PromptRequest) ProtoReflect() protoreflect.Message
- func (x *PromptRequest) Reset()
- func (x *PromptRequest) String() string
- type PromptResponse
- type Session
- func (s *Session) Context() context.Context
- func (s *Session) Err() error
- func (s *Session) EvalWithIO(ctx context.Context, code string)
- func (s *Session) Interpreter() *interp.Interpreter
- func (s *Session) Recv() (interface{}, bool)
- func (s *Session) Send(v interface{})
- func (s *Session) UseNotebookAPI()
- type ToClient
- func (*ToClient) Descriptor() ([]byte, []int)deprecated
- func (x *ToClient) GetCache() *CacheRequest
- func (x *ToClient) GetEvaluate() *EvaluateResponse
- func (m *ToClient) GetKind() isToClient_Kind
- func (x *ToClient) GetOutput() *Output
- func (x *ToClient) GetPrompt() *PromptRequest
- func (*ToClient) ProtoMessage()
- func (x *ToClient) ProtoReflect() protoreflect.Message
- func (x *ToClient) Reset()
- func (x *ToClient) String() string
- type ToClient_Cache
- type ToClient_Evaluate
- type ToClient_Output
- type ToClient_Prompt
- type ToServer
- func (*ToServer) Descriptor() ([]byte, []int)deprecated
- func (x *ToServer) GetCache() *CacheResponse
- func (x *ToServer) GetCancel() *CancelEvaluate
- func (x *ToServer) GetEvaluate() *EvaluateRequest
- func (m *ToServer) GetKind() isToServer_Kind
- func (x *ToServer) GetPrompt() *PromptResponse
- func (*ToServer) ProtoMessage()
- func (x *ToServer) ProtoReflect() protoreflect.Message
- func (x *ToServer) Reset()
- func (x *ToServer) String() string
- type ToServer_Cache
- type ToServer_Cancel
- type ToServer_Evaluate
- type ToServer_Prompt
- type UnimplementedKernelServer
- type UnsafeKernelServer
Constants ¶
This section is empty.
Variables ¶
var File_kernel_proto protoreflect.FileDescriptor
var Kernel_ServiceDesc = grpc.ServiceDesc{ ServiceName: "Kernel", HandlerType: (*KernelServer)(nil), Methods: []grpc.MethodDesc{}, Streams: []grpc.StreamDesc{ { StreamName: "Session", Handler: _Kernel_Session_Handler, ServerStreams: true, ClientStreams: true, }, }, Metadata: "kernel.proto", }
Kernel_ServiceDesc is the grpc.ServiceDesc for Kernel service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterKernelServer ¶
func RegisterKernelServer(s grpc.ServiceRegistrar, srv KernelServer)
Types ¶
type CacheRequest ¶
type CacheRequest struct { Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` Write *string `protobuf:"bytes,2,opt,name=write,proto3,oneof" json:"write,omitempty"` // contains filtered or unexported fields }
func (*CacheRequest) Descriptor
deprecated
func (*CacheRequest) Descriptor() ([]byte, []int)
Deprecated: Use CacheRequest.ProtoReflect.Descriptor instead.
func (*CacheRequest) GetKey ¶
func (x *CacheRequest) GetKey() string
func (*CacheRequest) GetWrite ¶
func (x *CacheRequest) GetWrite() string
func (*CacheRequest) ProtoMessage ¶
func (*CacheRequest) ProtoMessage()
func (*CacheRequest) ProtoReflect ¶
func (x *CacheRequest) ProtoReflect() protoreflect.Message
func (*CacheRequest) Reset ¶
func (x *CacheRequest) Reset()
func (*CacheRequest) String ¶
func (x *CacheRequest) String() string
type CacheResponse ¶
type CacheResponse struct { Value *string `protobuf:"bytes,1,opt,name=value,proto3,oneof" json:"value,omitempty"` // contains filtered or unexported fields }
func (*CacheResponse) Descriptor
deprecated
func (*CacheResponse) Descriptor() ([]byte, []int)
Deprecated: Use CacheResponse.ProtoReflect.Descriptor instead.
func (*CacheResponse) GetValue ¶
func (x *CacheResponse) GetValue() string
func (*CacheResponse) ProtoMessage ¶
func (*CacheResponse) ProtoMessage()
func (*CacheResponse) ProtoReflect ¶
func (x *CacheResponse) ProtoReflect() protoreflect.Message
func (*CacheResponse) Reset ¶
func (x *CacheResponse) Reset()
func (*CacheResponse) String ¶
func (x *CacheResponse) String() string
type CancelEvaluate ¶
type CancelEvaluate struct {
// contains filtered or unexported fields
}
func (*CancelEvaluate) Descriptor
deprecated
func (*CancelEvaluate) Descriptor() ([]byte, []int)
Deprecated: Use CancelEvaluate.ProtoReflect.Descriptor instead.
func (*CancelEvaluate) ProtoMessage ¶
func (*CancelEvaluate) ProtoMessage()
func (*CancelEvaluate) ProtoReflect ¶
func (x *CancelEvaluate) ProtoReflect() protoreflect.Message
func (*CancelEvaluate) Reset ¶
func (x *CancelEvaluate) Reset()
func (*CancelEvaluate) String ¶
func (x *CancelEvaluate) String() string
type Content ¶
type Content struct { Mime string `protobuf:"bytes,1,opt,name=mime,proto3" json:"mime,omitempty"` Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
func (*Content) Descriptor
deprecated
func (*Content) ProtoMessage ¶
func (*Content) ProtoMessage()
func (*Content) ProtoReflect ¶
func (x *Content) ProtoReflect() protoreflect.Message
type EvaluateError ¶
type EvaluateError struct { Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"` Stack *string `protobuf:"bytes,2,opt,name=stack,proto3,oneof" json:"stack,omitempty"` Position *LineAndColumn `protobuf:"bytes,3,opt,name=position,proto3,oneof" json:"position,omitempty"` // contains filtered or unexported fields }
func (*EvaluateError) Descriptor
deprecated
func (*EvaluateError) Descriptor() ([]byte, []int)
Deprecated: Use EvaluateError.ProtoReflect.Descriptor instead.
func (*EvaluateError) GetMessage ¶
func (x *EvaluateError) GetMessage() string
func (*EvaluateError) GetPosition ¶
func (x *EvaluateError) GetPosition() *LineAndColumn
func (*EvaluateError) GetStack ¶
func (x *EvaluateError) GetStack() string
func (*EvaluateError) ProtoMessage ¶
func (*EvaluateError) ProtoMessage()
func (*EvaluateError) ProtoReflect ¶
func (x *EvaluateError) ProtoReflect() protoreflect.Message
func (*EvaluateError) Reset ¶
func (x *EvaluateError) Reset()
func (*EvaluateError) String ¶
func (x *EvaluateError) String() string
type EvaluateRequest ¶
type EvaluateRequest struct { Code string `protobuf:"bytes,1,opt,name=code,proto3" json:"code,omitempty"` // contains filtered or unexported fields }
func (*EvaluateRequest) Descriptor
deprecated
func (*EvaluateRequest) Descriptor() ([]byte, []int)
Deprecated: Use EvaluateRequest.ProtoReflect.Descriptor instead.
func (*EvaluateRequest) GetCode ¶
func (x *EvaluateRequest) GetCode() string
func (*EvaluateRequest) ProtoMessage ¶
func (*EvaluateRequest) ProtoMessage()
func (*EvaluateRequest) ProtoReflect ¶
func (x *EvaluateRequest) ProtoReflect() protoreflect.Message
func (*EvaluateRequest) Reset ¶
func (x *EvaluateRequest) Reset()
func (*EvaluateRequest) String ¶
func (x *EvaluateRequest) String() string
type EvaluateResponse ¶
type EvaluateResponse struct { Duration *durationpb.Duration `protobuf:"bytes,1,opt,name=duration,proto3" json:"duration,omitempty"` Errors []*EvaluateError `protobuf:"bytes,2,rep,name=errors,proto3" json:"errors,omitempty"` // contains filtered or unexported fields }
func (*EvaluateResponse) Descriptor
deprecated
func (*EvaluateResponse) Descriptor() ([]byte, []int)
Deprecated: Use EvaluateResponse.ProtoReflect.Descriptor instead.
func (*EvaluateResponse) GetDuration ¶
func (x *EvaluateResponse) GetDuration() *durationpb.Duration
func (*EvaluateResponse) GetErrors ¶
func (x *EvaluateResponse) GetErrors() []*EvaluateError
func (*EvaluateResponse) ProtoMessage ¶
func (*EvaluateResponse) ProtoMessage()
func (*EvaluateResponse) ProtoReflect ¶
func (x *EvaluateResponse) ProtoReflect() protoreflect.Message
func (*EvaluateResponse) Reset ¶
func (x *EvaluateResponse) Reset()
func (*EvaluateResponse) String ¶
func (x *EvaluateResponse) String() string
type KernelClient ¶
type KernelClient interface {
Session(ctx context.Context, opts ...grpc.CallOption) (Kernel_SessionClient, error)
}
KernelClient is the client API for Kernel service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewKernelClient ¶
func NewKernelClient(cc grpc.ClientConnInterface) KernelClient
type KernelServer ¶
type KernelServer interface { Session(Kernel_SessionServer) error // contains filtered or unexported methods }
KernelServer is the server API for Kernel service. All implementations must embed UnimplementedKernelServer for forward compatibility
type Kernel_SessionClient ¶
type Kernel_SessionServer ¶
type LineAndColumn ¶
type LineAndColumn struct { Line int32 `protobuf:"varint,1,opt,name=line,proto3" json:"line,omitempty"` Column int32 `protobuf:"varint,2,opt,name=column,proto3" json:"column,omitempty"` // contains filtered or unexported fields }
func (*LineAndColumn) Descriptor
deprecated
func (*LineAndColumn) Descriptor() ([]byte, []int)
Deprecated: Use LineAndColumn.ProtoReflect.Descriptor instead.
func (*LineAndColumn) GetColumn ¶
func (x *LineAndColumn) GetColumn() int32
func (*LineAndColumn) GetLine ¶
func (x *LineAndColumn) GetLine() int32
func (*LineAndColumn) ProtoMessage ¶
func (*LineAndColumn) ProtoMessage()
func (*LineAndColumn) ProtoReflect ¶
func (x *LineAndColumn) ProtoReflect() protoreflect.Message
func (*LineAndColumn) Reset ¶
func (x *LineAndColumn) Reset()
func (*LineAndColumn) String ¶
func (x *LineAndColumn) String() string
type Output ¶
type Output struct { Content []*Content `protobuf:"bytes,1,rep,name=content,proto3" json:"content,omitempty"` // contains filtered or unexported fields }
func (*Output) Descriptor
deprecated
func (*Output) GetContent ¶
func (*Output) ProtoMessage ¶
func (*Output) ProtoMessage()
func (*Output) ProtoReflect ¶
func (x *Output) ProtoReflect() protoreflect.Message
type PackageExports ¶
func (PackageExports) Add ¶
func (ex PackageExports) Add(name string, value interface{}) PackageExports
type PromptRequest ¶
type PromptRequest struct { Prompt *string `protobuf:"bytes,1,opt,name=prompt,proto3,oneof" json:"prompt,omitempty"` Placeholder *string `protobuf:"bytes,2,opt,name=placeholder,proto3,oneof" json:"placeholder,omitempty"` Password bool `protobuf:"varint,3,opt,name=password,proto3" json:"password,omitempty"` // contains filtered or unexported fields }
func (*PromptRequest) Descriptor
deprecated
func (*PromptRequest) Descriptor() ([]byte, []int)
Deprecated: Use PromptRequest.ProtoReflect.Descriptor instead.
func (*PromptRequest) GetPassword ¶
func (x *PromptRequest) GetPassword() bool
func (*PromptRequest) GetPlaceholder ¶
func (x *PromptRequest) GetPlaceholder() string
func (*PromptRequest) GetPrompt ¶
func (x *PromptRequest) GetPrompt() string
func (*PromptRequest) ProtoMessage ¶
func (*PromptRequest) ProtoMessage()
func (*PromptRequest) ProtoReflect ¶
func (x *PromptRequest) ProtoReflect() protoreflect.Message
func (*PromptRequest) Reset ¶
func (x *PromptRequest) Reset()
func (*PromptRequest) String ¶
func (x *PromptRequest) String() string
type PromptResponse ¶
type PromptResponse struct { Value *string `protobuf:"bytes,1,opt,name=value,proto3,oneof" json:"value,omitempty"` // contains filtered or unexported fields }
func (*PromptResponse) Descriptor
deprecated
func (*PromptResponse) Descriptor() ([]byte, []int)
Deprecated: Use PromptResponse.ProtoReflect.Descriptor instead.
func (*PromptResponse) GetValue ¶
func (x *PromptResponse) GetValue() string
func (*PromptResponse) ProtoMessage ¶
func (*PromptResponse) ProtoMessage()
func (*PromptResponse) ProtoReflect ¶
func (x *PromptResponse) ProtoReflect() protoreflect.Message
func (*PromptResponse) Reset ¶
func (x *PromptResponse) Reset()
func (*PromptResponse) String ¶
func (x *PromptResponse) String() string
type Session ¶
type Session struct {
// contains filtered or unexported fields
}
func StartSession ¶
func StartSession(stream Kernel_SessionServer) *Session
func (*Session) Interpreter ¶
func (s *Session) Interpreter() *interp.Interpreter
func (*Session) UseNotebookAPI ¶
func (s *Session) UseNotebookAPI()
type ToClient ¶
type ToClient struct { // Types that are assignable to Kind: // *ToClient_Output // *ToClient_Evaluate // *ToClient_Prompt // *ToClient_Cache Kind isToClient_Kind `protobuf_oneof:"kind"` // contains filtered or unexported fields }
func (*ToClient) Descriptor
deprecated
func (*ToClient) GetCache ¶
func (x *ToClient) GetCache() *CacheRequest
func (*ToClient) GetEvaluate ¶
func (x *ToClient) GetEvaluate() *EvaluateResponse
func (*ToClient) GetPrompt ¶
func (x *ToClient) GetPrompt() *PromptRequest
func (*ToClient) ProtoMessage ¶
func (*ToClient) ProtoMessage()
func (*ToClient) ProtoReflect ¶
func (x *ToClient) ProtoReflect() protoreflect.Message
type ToClient_Cache ¶
type ToClient_Cache struct {
Cache *CacheRequest `protobuf:"bytes,4,opt,name=cache,proto3,oneof"`
}
type ToClient_Evaluate ¶
type ToClient_Evaluate struct {
Evaluate *EvaluateResponse `protobuf:"bytes,2,opt,name=evaluate,proto3,oneof"`
}
type ToClient_Output ¶
type ToClient_Output struct {
Output *Output `protobuf:"bytes,1,opt,name=output,proto3,oneof"`
}
type ToClient_Prompt ¶
type ToClient_Prompt struct {
Prompt *PromptRequest `protobuf:"bytes,3,opt,name=prompt,proto3,oneof"`
}
type ToServer ¶
type ToServer struct { // Types that are assignable to Kind: // *ToServer_Evaluate // *ToServer_Prompt // *ToServer_Cache // *ToServer_Cancel Kind isToServer_Kind `protobuf_oneof:"kind"` // contains filtered or unexported fields }
func (*ToServer) Descriptor
deprecated
func (*ToServer) GetCache ¶
func (x *ToServer) GetCache() *CacheResponse
func (*ToServer) GetCancel ¶
func (x *ToServer) GetCancel() *CancelEvaluate
func (*ToServer) GetEvaluate ¶
func (x *ToServer) GetEvaluate() *EvaluateRequest
func (*ToServer) GetPrompt ¶
func (x *ToServer) GetPrompt() *PromptResponse
func (*ToServer) ProtoMessage ¶
func (*ToServer) ProtoMessage()
func (*ToServer) ProtoReflect ¶
func (x *ToServer) ProtoReflect() protoreflect.Message
type ToServer_Cache ¶
type ToServer_Cache struct {
Cache *CacheResponse `protobuf:"bytes,3,opt,name=cache,proto3,oneof"`
}
type ToServer_Cancel ¶
type ToServer_Cancel struct {
Cancel *CancelEvaluate `protobuf:"bytes,4,opt,name=cancel,proto3,oneof"`
}
type ToServer_Evaluate ¶
type ToServer_Evaluate struct {
Evaluate *EvaluateRequest `protobuf:"bytes,1,opt,name=evaluate,proto3,oneof"`
}
type ToServer_Prompt ¶
type ToServer_Prompt struct {
Prompt *PromptResponse `protobuf:"bytes,2,opt,name=prompt,proto3,oneof"`
}
type UnimplementedKernelServer ¶
type UnimplementedKernelServer struct { }
UnimplementedKernelServer must be embedded to have forward compatible implementations.
func (UnimplementedKernelServer) Session ¶
func (UnimplementedKernelServer) Session(Kernel_SessionServer) error
type UnsafeKernelServer ¶
type UnsafeKernelServer interface {
// contains filtered or unexported methods
}
UnsafeKernelServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to KernelServer will result in compilation errors.