Documentation ¶
Index ¶
- Variables
- func RegisterKernelServer(s grpc.ServiceRegistrar, srv KernelServer)
- func String(v string) *string
- type Content
- type Error
- func (*Error) Descriptor() ([]byte, []int)deprecated
- func (x *Error) GetMessage() string
- func (x *Error) GetPosition() *Error_LineAndColumn
- func (x *Error) GetStack() string
- func (*Error) ProtoMessage()
- func (x *Error) ProtoReflect() protoreflect.Message
- func (x *Error) Reset()
- func (x *Error) String() string
- type Error_LineAndColumn
- func (*Error_LineAndColumn) Descriptor() ([]byte, []int)deprecated
- func (x *Error_LineAndColumn) GetColumn() int32
- func (x *Error_LineAndColumn) GetLine() int32
- func (*Error_LineAndColumn) ProtoMessage()
- func (x *Error_LineAndColumn) ProtoReflect() protoreflect.Message
- func (x *Error_LineAndColumn) Reset()
- func (x *Error_LineAndColumn) String() string
- type FromKernel
- func (msg *FromKernel) Connections(connections []*FromKernel_Connections_Connection)
- func (*FromKernel) Descriptor() ([]byte, []int)deprecated
- func (msg *FromKernel) Executed(duration time.Duration, errors []*Error)
- func (x *FromKernel) GetConnections() *FromKernel_Connections
- func (x *FromKernel) GetExecuted() *FromKernel_Executed
- func (m *FromKernel) GetKind() isFromKernel_Kind
- func (x *FromKernel) GetOutput() *FromKernel_Output
- func (x *FromKernel) GetPrompt() *FromKernel_Prompt
- func (x *FromKernel) GetReadCache() *FromKernel_ReadCache
- func (x *FromKernel) GetWriteCache() *FromKernel_WriteCache
- func (msg *FromKernel) Output(content ...*Content)
- func (msg *FromKernel) Prompt(prompt, placeholder string, secret bool)
- func (*FromKernel) ProtoMessage()
- func (x *FromKernel) ProtoReflect() protoreflect.Message
- func (msg *FromKernel) ReadCache(key string)
- func (x *FromKernel) Reset()
- func (x *FromKernel) String() string
- func (msg *FromKernel) WriteCache(key, value string)
- type FromKernel_Connections
- func (*FromKernel_Connections) Descriptor() ([]byte, []int)deprecated
- func (x *FromKernel_Connections) GetConnection() []*FromKernel_Connections_Connection
- func (*FromKernel_Connections) ProtoMessage()
- func (x *FromKernel_Connections) ProtoReflect() protoreflect.Message
- func (x *FromKernel_Connections) Reset()
- func (x *FromKernel_Connections) String() string
- type FromKernel_Connections_
- type FromKernel_Connections_Connection
- func (*FromKernel_Connections_Connection) Descriptor() ([]byte, []int)deprecated
- func (x *FromKernel_Connections_Connection) GetId() string
- func (x *FromKernel_Connections_Connection) GetProvider() string
- func (*FromKernel_Connections_Connection) ProtoMessage()
- func (x *FromKernel_Connections_Connection) ProtoReflect() protoreflect.Message
- func (x *FromKernel_Connections_Connection) Reset()
- func (x *FromKernel_Connections_Connection) String() string
- type FromKernel_Executed
- func (msg *FromKernel_Executed) AddError(message, stack string)
- func (msg *FromKernel_Executed) AddErrorAt(message, stack string, line, col int)
- func (*FromKernel_Executed) Descriptor() ([]byte, []int)deprecated
- func (x *FromKernel_Executed) GetDuration() *durationpb.Duration
- func (x *FromKernel_Executed) GetErrors() []*Error
- func (*FromKernel_Executed) ProtoMessage()
- func (x *FromKernel_Executed) ProtoReflect() protoreflect.Message
- func (x *FromKernel_Executed) Reset()
- func (msg *FromKernel_Executed) SetDuration(d time.Duration)
- func (x *FromKernel_Executed) String() string
- type FromKernel_Executed_
- type FromKernel_Output
- func (*FromKernel_Output) Descriptor() ([]byte, []int)deprecated
- func (x *FromKernel_Output) GetContent() []*Content
- func (*FromKernel_Output) ProtoMessage()
- func (x *FromKernel_Output) ProtoReflect() protoreflect.Message
- func (x *FromKernel_Output) Reset()
- func (x *FromKernel_Output) String() string
- type FromKernel_Output_
- type FromKernel_Prompt
- func (*FromKernel_Prompt) Descriptor() ([]byte, []int)deprecated
- func (x *FromKernel_Prompt) GetPlaceholder() string
- func (x *FromKernel_Prompt) GetPrompt() string
- func (x *FromKernel_Prompt) GetSecret() bool
- func (*FromKernel_Prompt) ProtoMessage()
- func (x *FromKernel_Prompt) ProtoReflect() protoreflect.Message
- func (x *FromKernel_Prompt) Reset()
- func (x *FromKernel_Prompt) String() string
- type FromKernel_Prompt_
- type FromKernel_ReadCache
- func (*FromKernel_ReadCache) Descriptor() ([]byte, []int)deprecated
- func (x *FromKernel_ReadCache) GetKey() string
- func (*FromKernel_ReadCache) ProtoMessage()
- func (x *FromKernel_ReadCache) ProtoReflect() protoreflect.Message
- func (x *FromKernel_ReadCache) Reset()
- func (x *FromKernel_ReadCache) String() string
- type FromKernel_ReadCache_
- type FromKernel_WriteCache
- func (*FromKernel_WriteCache) Descriptor() ([]byte, []int)deprecated
- func (x *FromKernel_WriteCache) GetKey() string
- func (x *FromKernel_WriteCache) GetValue() string
- func (*FromKernel_WriteCache) ProtoMessage()
- func (x *FromKernel_WriteCache) ProtoReflect() protoreflect.Message
- func (x *FromKernel_WriteCache) Reset()
- func (x *FromKernel_WriteCache) String() string
- type FromKernel_WriteCache_
- type KernelClient
- type KernelServer
- type Kernel_SessionClient
- type Kernel_SessionServer
- type ToKernel
- func (*ToKernel) Descriptor() ([]byte, []int)deprecated
- func (msg *ToKernel) Get() interface{}
- func (x *ToKernel) GetCached() *ToKernel_Cached
- func (x *ToKernel) GetCancelExecute() *ToKernel_CancelExecute
- func (x *ToKernel) GetExecuteCode() *ToKernel_ExecuteCode
- func (x *ToKernel) GetExecuteQuery() *ToKernel_ExecuteQuery
- func (m *ToKernel) GetKind() isToKernel_Kind
- func (x *ToKernel) GetListConnections() *ToKernel_ListConnections
- func (x *ToKernel) GetPrompted() *ToKernel_Prompted
- func (x *ToKernel) GetSetup() *ToKernel_Setup
- func (*ToKernel) ProtoMessage()
- func (x *ToKernel) ProtoReflect() protoreflect.Message
- func (x *ToKernel) Reset()
- func (x *ToKernel) String() string
- type ToKernel_Cached
- func (*ToKernel_Cached) Descriptor() ([]byte, []int)deprecated
- func (x *ToKernel_Cached) GetKey() string
- func (x *ToKernel_Cached) GetValue() string
- func (*ToKernel_Cached) ProtoMessage()
- func (x *ToKernel_Cached) ProtoReflect() protoreflect.Message
- func (x *ToKernel_Cached) Reset()
- func (x *ToKernel_Cached) String() string
- type ToKernel_Cached_
- type ToKernel_CancelExecute
- type ToKernel_CancelExecute_
- type ToKernel_ExecuteCode
- func (*ToKernel_ExecuteCode) Descriptor() ([]byte, []int)deprecated
- func (x *ToKernel_ExecuteCode) GetCode() string
- func (*ToKernel_ExecuteCode) ProtoMessage()
- func (x *ToKernel_ExecuteCode) ProtoReflect() protoreflect.Message
- func (x *ToKernel_ExecuteCode) Reset()
- func (x *ToKernel_ExecuteCode) String() string
- type ToKernel_ExecuteCode_
- type ToKernel_ExecuteQuery
- func (*ToKernel_ExecuteQuery) Descriptor() ([]byte, []int)deprecated
- func (x *ToKernel_ExecuteQuery) GetConnection() string
- func (x *ToKernel_ExecuteQuery) GetDatabase() string
- func (x *ToKernel_ExecuteQuery) GetQuery() string
- func (*ToKernel_ExecuteQuery) ProtoMessage()
- func (x *ToKernel_ExecuteQuery) ProtoReflect() protoreflect.Message
- func (x *ToKernel_ExecuteQuery) Reset()
- func (x *ToKernel_ExecuteQuery) String() string
- type ToKernel_ExecuteQuery_
- type ToKernel_ListConnections
- type ToKernel_ListConnections_
- type ToKernel_Prompted
- type ToKernel_Prompted_
- type ToKernel_Setup
- type ToKernel_Setup_
- 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 Content ¶
type Content struct { Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,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 Error ¶
type Error 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 *Error_LineAndColumn `protobuf:"bytes,3,opt,name=position,proto3,oneof" json:"position,omitempty"` // contains filtered or unexported fields }
func (*Error) Descriptor
deprecated
func (*Error) GetMessage ¶
func (*Error) GetPosition ¶
func (x *Error) GetPosition() *Error_LineAndColumn
func (*Error) ProtoMessage ¶
func (*Error) ProtoMessage()
func (*Error) ProtoReflect ¶
func (x *Error) ProtoReflect() protoreflect.Message
type Error_LineAndColumn ¶
type Error_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 (*Error_LineAndColumn) Descriptor
deprecated
func (*Error_LineAndColumn) Descriptor() ([]byte, []int)
Deprecated: Use Error_LineAndColumn.ProtoReflect.Descriptor instead.
func (*Error_LineAndColumn) GetColumn ¶
func (x *Error_LineAndColumn) GetColumn() int32
func (*Error_LineAndColumn) GetLine ¶
func (x *Error_LineAndColumn) GetLine() int32
func (*Error_LineAndColumn) ProtoMessage ¶
func (*Error_LineAndColumn) ProtoMessage()
func (*Error_LineAndColumn) ProtoReflect ¶
func (x *Error_LineAndColumn) ProtoReflect() protoreflect.Message
func (*Error_LineAndColumn) Reset ¶
func (x *Error_LineAndColumn) Reset()
func (*Error_LineAndColumn) String ¶
func (x *Error_LineAndColumn) String() string
type FromKernel ¶
type FromKernel struct { // Types that are assignable to Kind: // *FromKernel_Output_ // *FromKernel_Executed_ // *FromKernel_ReadCache_ // *FromKernel_WriteCache_ // *FromKernel_Prompt_ // *FromKernel_Connections_ Kind isFromKernel_Kind `protobuf_oneof:"kind"` // contains filtered or unexported fields }
func (*FromKernel) Connections ¶
func (msg *FromKernel) Connections(connections []*FromKernel_Connections_Connection)
func (*FromKernel) Descriptor
deprecated
func (*FromKernel) Descriptor() ([]byte, []int)
Deprecated: Use FromKernel.ProtoReflect.Descriptor instead.
func (*FromKernel) Executed ¶
func (msg *FromKernel) Executed(duration time.Duration, errors []*Error)
func (*FromKernel) GetConnections ¶
func (x *FromKernel) GetConnections() *FromKernel_Connections
func (*FromKernel) GetExecuted ¶
func (x *FromKernel) GetExecuted() *FromKernel_Executed
func (*FromKernel) GetKind ¶
func (m *FromKernel) GetKind() isFromKernel_Kind
func (*FromKernel) GetOutput ¶
func (x *FromKernel) GetOutput() *FromKernel_Output
func (*FromKernel) GetPrompt ¶
func (x *FromKernel) GetPrompt() *FromKernel_Prompt
func (*FromKernel) GetReadCache ¶
func (x *FromKernel) GetReadCache() *FromKernel_ReadCache
func (*FromKernel) GetWriteCache ¶
func (x *FromKernel) GetWriteCache() *FromKernel_WriteCache
func (*FromKernel) Output ¶
func (msg *FromKernel) Output(content ...*Content)
func (*FromKernel) Prompt ¶
func (msg *FromKernel) Prompt(prompt, placeholder string, secret bool)
func (*FromKernel) ProtoMessage ¶
func (*FromKernel) ProtoMessage()
func (*FromKernel) ProtoReflect ¶
func (x *FromKernel) ProtoReflect() protoreflect.Message
func (*FromKernel) ReadCache ¶
func (msg *FromKernel) ReadCache(key string)
func (*FromKernel) Reset ¶
func (x *FromKernel) Reset()
func (*FromKernel) String ¶
func (x *FromKernel) String() string
func (*FromKernel) WriteCache ¶
func (msg *FromKernel) WriteCache(key, value string)
type FromKernel_Connections ¶
type FromKernel_Connections struct { Connection []*FromKernel_Connections_Connection `protobuf:"bytes,1,rep,name=connection,proto3" json:"connection,omitempty"` // contains filtered or unexported fields }
func (*FromKernel_Connections) Descriptor
deprecated
func (*FromKernel_Connections) Descriptor() ([]byte, []int)
Deprecated: Use FromKernel_Connections.ProtoReflect.Descriptor instead.
func (*FromKernel_Connections) GetConnection ¶
func (x *FromKernel_Connections) GetConnection() []*FromKernel_Connections_Connection
func (*FromKernel_Connections) ProtoMessage ¶
func (*FromKernel_Connections) ProtoMessage()
func (*FromKernel_Connections) ProtoReflect ¶
func (x *FromKernel_Connections) ProtoReflect() protoreflect.Message
func (*FromKernel_Connections) Reset ¶
func (x *FromKernel_Connections) Reset()
func (*FromKernel_Connections) String ¶
func (x *FromKernel_Connections) String() string
type FromKernel_Connections_ ¶
type FromKernel_Connections_ struct {
Connections *FromKernel_Connections `protobuf:"bytes,6,opt,name=connections,proto3,oneof"`
}
type FromKernel_Connections_Connection ¶
type FromKernel_Connections_Connection struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Provider *string `protobuf:"bytes,2,opt,name=provider,proto3,oneof" json:"provider,omitempty"` // contains filtered or unexported fields }
func (*FromKernel_Connections_Connection) Descriptor
deprecated
func (*FromKernel_Connections_Connection) Descriptor() ([]byte, []int)
Deprecated: Use FromKernel_Connections_Connection.ProtoReflect.Descriptor instead.
func (*FromKernel_Connections_Connection) GetId ¶
func (x *FromKernel_Connections_Connection) GetId() string
func (*FromKernel_Connections_Connection) GetProvider ¶
func (x *FromKernel_Connections_Connection) GetProvider() string
func (*FromKernel_Connections_Connection) ProtoMessage ¶
func (*FromKernel_Connections_Connection) ProtoMessage()
func (*FromKernel_Connections_Connection) ProtoReflect ¶
func (x *FromKernel_Connections_Connection) ProtoReflect() protoreflect.Message
func (*FromKernel_Connections_Connection) Reset ¶
func (x *FromKernel_Connections_Connection) Reset()
func (*FromKernel_Connections_Connection) String ¶
func (x *FromKernel_Connections_Connection) String() string
type FromKernel_Executed ¶
type FromKernel_Executed struct { Duration *durationpb.Duration `protobuf:"bytes,1,opt,name=duration,proto3" json:"duration,omitempty"` Errors []*Error `protobuf:"bytes,2,rep,name=errors,proto3" json:"errors,omitempty"` // contains filtered or unexported fields }
func (*FromKernel_Executed) AddError ¶
func (msg *FromKernel_Executed) AddError(message, stack string)
func (*FromKernel_Executed) AddErrorAt ¶
func (msg *FromKernel_Executed) AddErrorAt(message, stack string, line, col int)
func (*FromKernel_Executed) Descriptor
deprecated
func (*FromKernel_Executed) Descriptor() ([]byte, []int)
Deprecated: Use FromKernel_Executed.ProtoReflect.Descriptor instead.
func (*FromKernel_Executed) GetDuration ¶
func (x *FromKernel_Executed) GetDuration() *durationpb.Duration
func (*FromKernel_Executed) GetErrors ¶
func (x *FromKernel_Executed) GetErrors() []*Error
func (*FromKernel_Executed) ProtoMessage ¶
func (*FromKernel_Executed) ProtoMessage()
func (*FromKernel_Executed) ProtoReflect ¶
func (x *FromKernel_Executed) ProtoReflect() protoreflect.Message
func (*FromKernel_Executed) Reset ¶
func (x *FromKernel_Executed) Reset()
func (*FromKernel_Executed) SetDuration ¶
func (msg *FromKernel_Executed) SetDuration(d time.Duration)
func (*FromKernel_Executed) String ¶
func (x *FromKernel_Executed) String() string
type FromKernel_Executed_ ¶
type FromKernel_Executed_ struct {
Executed *FromKernel_Executed `protobuf:"bytes,2,opt,name=executed,proto3,oneof"`
}
type FromKernel_Output ¶
type FromKernel_Output struct { Content []*Content `protobuf:"bytes,1,rep,name=content,proto3" json:"content,omitempty"` // contains filtered or unexported fields }
func (*FromKernel_Output) Descriptor
deprecated
func (*FromKernel_Output) Descriptor() ([]byte, []int)
Deprecated: Use FromKernel_Output.ProtoReflect.Descriptor instead.
func (*FromKernel_Output) GetContent ¶
func (x *FromKernel_Output) GetContent() []*Content
func (*FromKernel_Output) ProtoMessage ¶
func (*FromKernel_Output) ProtoMessage()
func (*FromKernel_Output) ProtoReflect ¶
func (x *FromKernel_Output) ProtoReflect() protoreflect.Message
func (*FromKernel_Output) Reset ¶
func (x *FromKernel_Output) Reset()
func (*FromKernel_Output) String ¶
func (x *FromKernel_Output) String() string
type FromKernel_Output_ ¶
type FromKernel_Output_ struct {
Output *FromKernel_Output `protobuf:"bytes,1,opt,name=output,proto3,oneof"`
}
type FromKernel_Prompt ¶
type FromKernel_Prompt 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"` Secret bool `protobuf:"varint,3,opt,name=secret,proto3" json:"secret,omitempty"` // contains filtered or unexported fields }
func (*FromKernel_Prompt) Descriptor
deprecated
func (*FromKernel_Prompt) Descriptor() ([]byte, []int)
Deprecated: Use FromKernel_Prompt.ProtoReflect.Descriptor instead.
func (*FromKernel_Prompt) GetPlaceholder ¶
func (x *FromKernel_Prompt) GetPlaceholder() string
func (*FromKernel_Prompt) GetPrompt ¶
func (x *FromKernel_Prompt) GetPrompt() string
func (*FromKernel_Prompt) GetSecret ¶
func (x *FromKernel_Prompt) GetSecret() bool
func (*FromKernel_Prompt) ProtoMessage ¶
func (*FromKernel_Prompt) ProtoMessage()
func (*FromKernel_Prompt) ProtoReflect ¶
func (x *FromKernel_Prompt) ProtoReflect() protoreflect.Message
func (*FromKernel_Prompt) Reset ¶
func (x *FromKernel_Prompt) Reset()
func (*FromKernel_Prompt) String ¶
func (x *FromKernel_Prompt) String() string
type FromKernel_Prompt_ ¶
type FromKernel_Prompt_ struct {
Prompt *FromKernel_Prompt `protobuf:"bytes,5,opt,name=prompt,proto3,oneof"`
}
type FromKernel_ReadCache ¶
type FromKernel_ReadCache struct { Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` // contains filtered or unexported fields }
func (*FromKernel_ReadCache) Descriptor
deprecated
func (*FromKernel_ReadCache) Descriptor() ([]byte, []int)
Deprecated: Use FromKernel_ReadCache.ProtoReflect.Descriptor instead.
func (*FromKernel_ReadCache) GetKey ¶
func (x *FromKernel_ReadCache) GetKey() string
func (*FromKernel_ReadCache) ProtoMessage ¶
func (*FromKernel_ReadCache) ProtoMessage()
func (*FromKernel_ReadCache) ProtoReflect ¶
func (x *FromKernel_ReadCache) ProtoReflect() protoreflect.Message
func (*FromKernel_ReadCache) Reset ¶
func (x *FromKernel_ReadCache) Reset()
func (*FromKernel_ReadCache) String ¶
func (x *FromKernel_ReadCache) String() string
type FromKernel_ReadCache_ ¶
type FromKernel_ReadCache_ struct {
ReadCache *FromKernel_ReadCache `protobuf:"bytes,3,opt,name=readCache,proto3,oneof"`
}
type FromKernel_WriteCache ¶
type FromKernel_WriteCache struct { Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` Value *string `protobuf:"bytes,2,opt,name=value,proto3,oneof" json:"value,omitempty"` // contains filtered or unexported fields }
func (*FromKernel_WriteCache) Descriptor
deprecated
func (*FromKernel_WriteCache) Descriptor() ([]byte, []int)
Deprecated: Use FromKernel_WriteCache.ProtoReflect.Descriptor instead.
func (*FromKernel_WriteCache) GetKey ¶
func (x *FromKernel_WriteCache) GetKey() string
func (*FromKernel_WriteCache) GetValue ¶
func (x *FromKernel_WriteCache) GetValue() string
func (*FromKernel_WriteCache) ProtoMessage ¶
func (*FromKernel_WriteCache) ProtoMessage()
func (*FromKernel_WriteCache) ProtoReflect ¶
func (x *FromKernel_WriteCache) ProtoReflect() protoreflect.Message
func (*FromKernel_WriteCache) Reset ¶
func (x *FromKernel_WriteCache) Reset()
func (*FromKernel_WriteCache) String ¶
func (x *FromKernel_WriteCache) String() string
type FromKernel_WriteCache_ ¶
type FromKernel_WriteCache_ struct {
WriteCache *FromKernel_WriteCache `protobuf:"bytes,4,opt,name=writeCache,proto3,oneof"`
}
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_SessionClient interface { Send(*ToKernel) error Recv() (*FromKernel, error) grpc.ClientStream }
type Kernel_SessionServer ¶
type Kernel_SessionServer interface { Send(*FromKernel) error Recv() (*ToKernel, error) grpc.ServerStream }
type ToKernel ¶
type ToKernel struct { // Types that are assignable to Kind: // *ToKernel_Setup_ // *ToKernel_ExecuteCode_ // *ToKernel_ExecuteQuery_ // *ToKernel_CancelExecute_ // *ToKernel_Cached_ // *ToKernel_Prompted_ // *ToKernel_ListConnections_ Kind isToKernel_Kind `protobuf_oneof:"kind"` // contains filtered or unexported fields }
func (*ToKernel) Descriptor
deprecated
func (*ToKernel) GetCached ¶
func (x *ToKernel) GetCached() *ToKernel_Cached
func (*ToKernel) GetCancelExecute ¶
func (x *ToKernel) GetCancelExecute() *ToKernel_CancelExecute
func (*ToKernel) GetExecuteCode ¶
func (x *ToKernel) GetExecuteCode() *ToKernel_ExecuteCode
func (*ToKernel) GetExecuteQuery ¶
func (x *ToKernel) GetExecuteQuery() *ToKernel_ExecuteQuery
func (*ToKernel) GetListConnections ¶
func (x *ToKernel) GetListConnections() *ToKernel_ListConnections
func (*ToKernel) GetPrompted ¶
func (x *ToKernel) GetPrompted() *ToKernel_Prompted
func (*ToKernel) GetSetup ¶
func (x *ToKernel) GetSetup() *ToKernel_Setup
func (*ToKernel) ProtoMessage ¶
func (*ToKernel) ProtoMessage()
func (*ToKernel) ProtoReflect ¶
func (x *ToKernel) ProtoReflect() protoreflect.Message
type ToKernel_Cached ¶
type ToKernel_Cached struct { Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` Value *string `protobuf:"bytes,2,opt,name=value,proto3,oneof" json:"value,omitempty"` // contains filtered or unexported fields }
func (*ToKernel_Cached) Descriptor
deprecated
func (*ToKernel_Cached) Descriptor() ([]byte, []int)
Deprecated: Use ToKernel_Cached.ProtoReflect.Descriptor instead.
func (*ToKernel_Cached) GetKey ¶
func (x *ToKernel_Cached) GetKey() string
func (*ToKernel_Cached) GetValue ¶
func (x *ToKernel_Cached) GetValue() string
func (*ToKernel_Cached) ProtoMessage ¶
func (*ToKernel_Cached) ProtoMessage()
func (*ToKernel_Cached) ProtoReflect ¶
func (x *ToKernel_Cached) ProtoReflect() protoreflect.Message
func (*ToKernel_Cached) Reset ¶
func (x *ToKernel_Cached) Reset()
func (*ToKernel_Cached) String ¶
func (x *ToKernel_Cached) String() string
type ToKernel_Cached_ ¶
type ToKernel_Cached_ struct {
Cached *ToKernel_Cached `protobuf:"bytes,4,opt,name=cached,proto3,oneof"`
}
type ToKernel_CancelExecute ¶
type ToKernel_CancelExecute struct {
// contains filtered or unexported fields
}
func (*ToKernel_CancelExecute) Descriptor
deprecated
func (*ToKernel_CancelExecute) Descriptor() ([]byte, []int)
Deprecated: Use ToKernel_CancelExecute.ProtoReflect.Descriptor instead.
func (*ToKernel_CancelExecute) ProtoMessage ¶
func (*ToKernel_CancelExecute) ProtoMessage()
func (*ToKernel_CancelExecute) ProtoReflect ¶
func (x *ToKernel_CancelExecute) ProtoReflect() protoreflect.Message
func (*ToKernel_CancelExecute) Reset ¶
func (x *ToKernel_CancelExecute) Reset()
func (*ToKernel_CancelExecute) String ¶
func (x *ToKernel_CancelExecute) String() string
type ToKernel_CancelExecute_ ¶
type ToKernel_CancelExecute_ struct {
CancelExecute *ToKernel_CancelExecute `protobuf:"bytes,3,opt,name=cancelExecute,proto3,oneof"`
}
type ToKernel_ExecuteCode ¶
type ToKernel_ExecuteCode struct { Code string `protobuf:"bytes,1,opt,name=code,proto3" json:"code,omitempty"` // contains filtered or unexported fields }
func (*ToKernel_ExecuteCode) Descriptor
deprecated
func (*ToKernel_ExecuteCode) Descriptor() ([]byte, []int)
Deprecated: Use ToKernel_ExecuteCode.ProtoReflect.Descriptor instead.
func (*ToKernel_ExecuteCode) GetCode ¶
func (x *ToKernel_ExecuteCode) GetCode() string
func (*ToKernel_ExecuteCode) ProtoMessage ¶
func (*ToKernel_ExecuteCode) ProtoMessage()
func (*ToKernel_ExecuteCode) ProtoReflect ¶
func (x *ToKernel_ExecuteCode) ProtoReflect() protoreflect.Message
func (*ToKernel_ExecuteCode) Reset ¶
func (x *ToKernel_ExecuteCode) Reset()
func (*ToKernel_ExecuteCode) String ¶
func (x *ToKernel_ExecuteCode) String() string
type ToKernel_ExecuteCode_ ¶
type ToKernel_ExecuteCode_ struct {
ExecuteCode *ToKernel_ExecuteCode `protobuf:"bytes,1,opt,name=executeCode,proto3,oneof"`
}
type ToKernel_ExecuteQuery ¶
type ToKernel_ExecuteQuery struct { Query string `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"` Connection string `protobuf:"bytes,2,opt,name=connection,proto3" json:"connection,omitempty"` Database *string `protobuf:"bytes,3,opt,name=database,proto3,oneof" json:"database,omitempty"` // contains filtered or unexported fields }
func (*ToKernel_ExecuteQuery) Descriptor
deprecated
func (*ToKernel_ExecuteQuery) Descriptor() ([]byte, []int)
Deprecated: Use ToKernel_ExecuteQuery.ProtoReflect.Descriptor instead.
func (*ToKernel_ExecuteQuery) GetConnection ¶
func (x *ToKernel_ExecuteQuery) GetConnection() string
func (*ToKernel_ExecuteQuery) GetDatabase ¶
func (x *ToKernel_ExecuteQuery) GetDatabase() string
func (*ToKernel_ExecuteQuery) GetQuery ¶
func (x *ToKernel_ExecuteQuery) GetQuery() string
func (*ToKernel_ExecuteQuery) ProtoMessage ¶
func (*ToKernel_ExecuteQuery) ProtoMessage()
func (*ToKernel_ExecuteQuery) ProtoReflect ¶
func (x *ToKernel_ExecuteQuery) ProtoReflect() protoreflect.Message
func (*ToKernel_ExecuteQuery) Reset ¶
func (x *ToKernel_ExecuteQuery) Reset()
func (*ToKernel_ExecuteQuery) String ¶
func (x *ToKernel_ExecuteQuery) String() string
type ToKernel_ExecuteQuery_ ¶
type ToKernel_ExecuteQuery_ struct {
ExecuteQuery *ToKernel_ExecuteQuery `protobuf:"bytes,2,opt,name=executeQuery,proto3,oneof"`
}
type ToKernel_ListConnections ¶
type ToKernel_ListConnections struct {
// contains filtered or unexported fields
}
func (*ToKernel_ListConnections) Descriptor
deprecated
func (*ToKernel_ListConnections) Descriptor() ([]byte, []int)
Deprecated: Use ToKernel_ListConnections.ProtoReflect.Descriptor instead.
func (*ToKernel_ListConnections) ProtoMessage ¶
func (*ToKernel_ListConnections) ProtoMessage()
func (*ToKernel_ListConnections) ProtoReflect ¶
func (x *ToKernel_ListConnections) ProtoReflect() protoreflect.Message
func (*ToKernel_ListConnections) Reset ¶
func (x *ToKernel_ListConnections) Reset()
func (*ToKernel_ListConnections) String ¶
func (x *ToKernel_ListConnections) String() string
type ToKernel_ListConnections_ ¶
type ToKernel_ListConnections_ struct {
ListConnections *ToKernel_ListConnections `protobuf:"bytes,6,opt,name=listConnections,proto3,oneof"`
}
type ToKernel_Prompted ¶
type ToKernel_Prompted struct { Value *string `protobuf:"bytes,1,opt,name=value,proto3,oneof" json:"value,omitempty"` // contains filtered or unexported fields }
func (*ToKernel_Prompted) Descriptor
deprecated
func (*ToKernel_Prompted) Descriptor() ([]byte, []int)
Deprecated: Use ToKernel_Prompted.ProtoReflect.Descriptor instead.
func (*ToKernel_Prompted) GetValue ¶
func (x *ToKernel_Prompted) GetValue() string
func (*ToKernel_Prompted) ProtoMessage ¶
func (*ToKernel_Prompted) ProtoMessage()
func (*ToKernel_Prompted) ProtoReflect ¶
func (x *ToKernel_Prompted) ProtoReflect() protoreflect.Message
func (*ToKernel_Prompted) Reset ¶
func (x *ToKernel_Prompted) Reset()
func (*ToKernel_Prompted) String ¶
func (x *ToKernel_Prompted) String() string
type ToKernel_Prompted_ ¶
type ToKernel_Prompted_ struct {
Prompted *ToKernel_Prompted `protobuf:"bytes,5,opt,name=prompted,proto3,oneof"`
}
type ToKernel_Setup ¶
type ToKernel_Setup struct { Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"` // contains filtered or unexported fields }
func (*ToKernel_Setup) Descriptor
deprecated
func (*ToKernel_Setup) Descriptor() ([]byte, []int)
Deprecated: Use ToKernel_Setup.ProtoReflect.Descriptor instead.
func (*ToKernel_Setup) GetPath ¶
func (x *ToKernel_Setup) GetPath() string
func (*ToKernel_Setup) ProtoMessage ¶
func (*ToKernel_Setup) ProtoMessage()
func (*ToKernel_Setup) ProtoReflect ¶
func (x *ToKernel_Setup) ProtoReflect() protoreflect.Message
func (*ToKernel_Setup) Reset ¶
func (x *ToKernel_Setup) Reset()
func (*ToKernel_Setup) String ¶
func (x *ToKernel_Setup) String() string
type ToKernel_Setup_ ¶
type ToKernel_Setup_ struct {
Setup *ToKernel_Setup `protobuf:"bytes,7,opt,name=setup,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.