proto

package
v0.1.9 Latest Latest
Warning

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

 Go to latest Published: Feb 10, 2026 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Overview

Package proto provides protobuf message types and gRPC client for Geode.

The generated types come from protoc (geode.pb.go / geode_grpc.pb.go). This file provides:

  • QUIC wire-format helpers: length-prefixed protobuf encode/decode
  • Convenience constructors for QuicClientMessage/QuicServerMessage
  • DecodeQuicServerMessage for QUIC transport
  • Encode() on QuicClientMessage for QUIC transport

Index

Constants

View Source 
const (
	GeodeService_Handshake_FullMethodName         = "/geode.GeodeService/Handshake"
	GeodeService_Execute_FullMethodName           = "/geode.GeodeService/Execute"
	GeodeService_Ping_FullMethodName              = "/geode.GeodeService/Ping"
	GeodeService_Begin_FullMethodName             = "/geode.GeodeService/Begin"
	GeodeService_Commit_FullMethodName            = "/geode.GeodeService/Commit"
	GeodeService_Rollback_FullMethodName          = "/geode.GeodeService/Rollback"
	GeodeService_GetCdcDiagnostics_FullMethodName = "/geode.GeodeService/GetCdcDiagnostics"
	GeodeService_ControlCdc_FullMethodName        = "/geode.GeodeService/ControlCdc"
)

Variables

View Source 
var (
	IntKind_name = map[int32]string{
		0: "INT_KIND_UNSPECIFIED",
		1: "INT",
		2: "SMALLINT",
		3: "BIGINT",
	}
	IntKind_value = map[string]int32{
		"INT_KIND_UNSPECIFIED": 0,
		"INT":                  1,
		"SMALLINT":             2,
		"BIGINT":               3,
	}
)

Enum value maps for IntKind.

View Source 
var (
	FloatKind_name = map[int32]string{
		0: "FLOAT_KIND_UNSPECIFIED",
		1: "DOUBLE",
		2: "REAL",
	}
	FloatKind_value = map[string]int32{
		"FLOAT_KIND_UNSPECIFIED": 0,
		"DOUBLE":                 1,
		"REAL":                   2,
	}
)

Enum value maps for FloatKind.

View Source 
var (
	StringKind_name = map[int32]string{
		0: "STRING_KIND_UNSPECIFIED",
		1: "STRING",
		2: "CHAR",
		3: "VARCHAR",
		4: "TEXT",
	}
	StringKind_value = map[string]int32{
		"STRING_KIND_UNSPECIFIED": 0,
		"STRING":                  1,
		"CHAR":                    2,
		"VARCHAR":                 3,
		"TEXT":                    4,
	}
)

Enum value maps for StringKind.

View Source 
var (
	BytesKind_name = map[int32]string{
		0: "BYTES_KIND_UNSPECIFIED",
		1: "BYTEA",
		2: "RAW",
	}
	BytesKind_value = map[string]int32{
		"BYTES_KIND_UNSPECIFIED": 0,
		"BYTEA":                  1,
		"RAW":                    2,
	}
)

Enum value maps for BytesKind.

View Source 
var ErrInvalidMessage = errors.New("invalid protobuf message")

ErrInvalidMessage is returned when a protobuf message cannot be decoded.

View Source 
var File_geode_proto protoreflect.FileDescriptor
View Source 
var GeodeService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "geode.GeodeService",
	HandlerType: (*GeodeServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Handshake",
			Handler:    _GeodeService_Handshake_Handler,
		},
		{
			MethodName: "Ping",
			Handler:    _GeodeService_Ping_Handler,
		},
		{
			MethodName: "Begin",
			Handler:    _GeodeService_Begin_Handler,
		},
		{
			MethodName: "Commit",
			Handler:    _GeodeService_Commit_Handler,
		},
		{
			MethodName: "Rollback",
			Handler:    _GeodeService_Rollback_Handler,
		},
		{
			MethodName: "GetCdcDiagnostics",
			Handler:    _GeodeService_GetCdcDiagnostics_Handler,
		},
		{
			MethodName: "ControlCdc",
			Handler:    _GeodeService_ControlCdc_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Execute",
			Handler:       _GeodeService_Execute_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "geode.proto",
}

GeodeService_ServiceDesc is the grpc.ServiceDesc for GeodeService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterGeodeServiceServer added in v0.1.4 

func RegisterGeodeServiceServer(s grpc.ServiceRegistrar, srv GeodeServiceServer)

Types

type BackupRequest added in v0.1.4 

type BackupRequest struct {
	BackupType string `protobuf:"bytes,1,opt,name=backup_type,json=backupType,proto3" json:"backup_type,omitempty"` // "full"
	Compress   bool   `protobuf:"varint,3,opt,name=compress,proto3" json:"compress,omitempty"`
	// contains filtered or unexported fields
}

============================================================================ Backup / Restore ============================================================================

func (*BackupRequest) Descriptor deprecated added in v0.1.4 

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

Deprecated: Use BackupRequest.ProtoReflect.Descriptor instead.

func (*BackupRequest) GetBackupType added in v0.1.4 

func (x *BackupRequest) GetBackupType() string

func (*BackupRequest) GetCompress added in v0.1.4 

func (x *BackupRequest) GetCompress() bool

func (*BackupRequest) ProtoMessage added in v0.1.4 

func (*BackupRequest) ProtoMessage()

func (*BackupRequest) ProtoReflect added in v0.1.4 

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

func (*BackupRequest) Reset added in v0.1.4 

func (x *BackupRequest) Reset()

func (*BackupRequest) String added in v0.1.4 

func (x *BackupRequest) String() string

type BackupResponse added in v0.1.4 

type BackupResponse struct {
	Success     bool   `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Message     string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	BackupId    string `protobuf:"bytes,3,opt,name=backup_id,json=backupId,proto3" json:"backup_id,omitempty"`
	BackupType  string `protobuf:"bytes,4,opt,name=backup_type,json=backupType,proto3" json:"backup_type,omitempty"`
	SizeBytes   uint64 `protobuf:"varint,5,opt,name=size_bytes,json=sizeBytes,proto3" json:"size_bytes,omitempty"`
	Compression string `protobuf:"bytes,6,opt,name=compression,proto3" json:"compression,omitempty"`
	Checksum    string `protobuf:"bytes,7,opt,name=checksum,proto3" json:"checksum,omitempty"`
	// contains filtered or unexported fields
}

func (*BackupResponse) Descriptor deprecated added in v0.1.4 

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

Deprecated: Use BackupResponse.ProtoReflect.Descriptor instead.

func (*BackupResponse) GetBackupId added in v0.1.4 

func (x *BackupResponse) GetBackupId() string

func (*BackupResponse) GetBackupType added in v0.1.4 

func (x *BackupResponse) GetBackupType() string

func (*BackupResponse) GetChecksum added in v0.1.4 

func (x *BackupResponse) GetChecksum() string

func (*BackupResponse) GetCompression added in v0.1.4 

func (x *BackupResponse) GetCompression() string

func (*BackupResponse) GetMessage added in v0.1.4 

func (x *BackupResponse) GetMessage() string

func (*BackupResponse) GetSizeBytes added in v0.1.4 

func (x *BackupResponse) GetSizeBytes() uint64

func (*BackupResponse) GetSuccess added in v0.1.4 

func (x *BackupResponse) GetSuccess() bool

func (*BackupResponse) ProtoMessage added in v0.1.4 

func (*BackupResponse) ProtoMessage()

func (*BackupResponse) ProtoReflect added in v0.1.4 

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

func (*BackupResponse) Reset added in v0.1.4 

func (x *BackupResponse) Reset()

func (*BackupResponse) String added in v0.1.4 

func (x *BackupResponse) String() string

type BeginRequest 

type BeginRequest struct {
	ReadOnly  bool   `protobuf:"varint,1,opt,name=read_only,json=readOnly,proto3" json:"read_only,omitempty"`
	SessionId string `protobuf:"bytes,2,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"` // Required for gRPC; ignored for QUIC
	// contains filtered or unexported fields
}

============================================================================ Transactions ============================================================================

func (*BeginRequest) Descriptor deprecated added in v0.1.4 

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

Deprecated: Use BeginRequest.ProtoReflect.Descriptor instead.

func (*BeginRequest) GetReadOnly added in v0.1.4 

func (x *BeginRequest) GetReadOnly() bool

func (*BeginRequest) GetSessionId added in v0.1.4 

func (x *BeginRequest) GetSessionId() string

func (*BeginRequest) ProtoMessage added in v0.1.4 

func (*BeginRequest) ProtoMessage()

func (*BeginRequest) ProtoReflect added in v0.1.4 

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

func (*BeginRequest) Reset added in v0.1.4 

func (x *BeginRequest) Reset()

func (*BeginRequest) String added in v0.1.4 

func (x *BeginRequest) String() string

type BeginResponse 

type BeginResponse struct {
	SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	TxId      string `protobuf:"bytes,2,opt,name=tx_id,json=txId,proto3" json:"tx_id,omitempty"`
	// contains filtered or unexported fields
}

func DecodeBeginResponse 

func DecodeBeginResponse(data []byte) (*BeginResponse, error)

DecodeBeginResponse decodes a protobuf-encoded BeginResponse.

func (*BeginResponse) Descriptor deprecated added in v0.1.4 

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

Deprecated: Use BeginResponse.ProtoReflect.Descriptor instead.

func (*BeginResponse) GetSessionId added in v0.1.4 

func (x *BeginResponse) GetSessionId() string

func (*BeginResponse) GetTxId added in v0.1.4 

func (x *BeginResponse) GetTxId() string

func (*BeginResponse) ProtoMessage added in v0.1.4 

func (*BeginResponse) ProtoMessage()

func (*BeginResponse) ProtoReflect added in v0.1.4 

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

func (*BeginResponse) Reset added in v0.1.4 

func (x *BeginResponse) Reset()

func (*BeginResponse) String added in v0.1.4 

func (x *BeginResponse) String() string

type BytesKind added in v0.1.4 

type BytesKind int32
const (
	BytesKind_BYTES_KIND_UNSPECIFIED BytesKind = 0
	BytesKind_BYTEA                  BytesKind = 1
	BytesKind_RAW                    BytesKind = 2
)

func (BytesKind) Descriptor added in v0.1.4 

func (BytesKind) Descriptor() protoreflect.EnumDescriptor

func (BytesKind) Enum added in v0.1.4 

func (x BytesKind) Enum() *BytesKind

func (BytesKind) EnumDescriptor deprecated added in v0.1.4 

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

Deprecated: Use BytesKind.Descriptor instead.

func (BytesKind) Number added in v0.1.4 

func (x BytesKind) Number() protoreflect.EnumNumber

func (BytesKind) String added in v0.1.4 

func (x BytesKind) String() string

func (BytesKind) Type added in v0.1.4 

func (BytesKind) Type() protoreflect.EnumType

type BytesValue added in v0.1.4 

type BytesValue struct {
	Value []byte    `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	Kind  BytesKind `protobuf:"varint,2,opt,name=kind,proto3,enum=geode.BytesKind" json:"kind,omitempty"`
	// contains filtered or unexported fields
}

func (*BytesValue) Descriptor deprecated added in v0.1.4 

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

Deprecated: Use BytesValue.ProtoReflect.Descriptor instead.

func (*BytesValue) GetKind added in v0.1.4 

func (x *BytesValue) GetKind() BytesKind

func (*BytesValue) GetValue added in v0.1.4 

func (x *BytesValue) GetValue() []byte

func (*BytesValue) ProtoMessage added in v0.1.4 

func (*BytesValue) ProtoMessage()

func (*BytesValue) ProtoReflect added in v0.1.4 

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

func (*BytesValue) Reset added in v0.1.4 

func (x *BytesValue) Reset()

func (*BytesValue) String added in v0.1.4 

func (x *BytesValue) String() string

type CdcControlRequest 

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

func (*CdcControlRequest) Descriptor deprecated added in v0.1.4 

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

Deprecated: Use CdcControlRequest.ProtoReflect.Descriptor instead.

func (*CdcControlRequest) GetAction added in v0.1.4 

func (x *CdcControlRequest) GetAction() string

func (*CdcControlRequest) ProtoMessage added in v0.1.4 

func (*CdcControlRequest) ProtoMessage()

func (*CdcControlRequest) ProtoReflect added in v0.1.4 

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

func (*CdcControlRequest) Reset added in v0.1.4 

func (x *CdcControlRequest) Reset()

func (*CdcControlRequest) String added in v0.1.4 

func (x *CdcControlRequest) String() string

type CdcControlResponse 

type CdcControlResponse struct {
	Success        bool   `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Status         string `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	GuardrailEpoch uint64 `protobuf:"varint,3,opt,name=guardrail_epoch,json=guardrailEpoch,proto3" json:"guardrail_epoch,omitempty"`
	// contains filtered or unexported fields
}

func DecodeCdcControlResponse 

func DecodeCdcControlResponse(data []byte) (*CdcControlResponse, error)

DecodeCdcControlResponse decodes a protobuf-encoded CdcControlResponse.

func (*CdcControlResponse) Descriptor deprecated added in v0.1.4 

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

Deprecated: Use CdcControlResponse.ProtoReflect.Descriptor instead.

func (*CdcControlResponse) GetGuardrailEpoch added in v0.1.4 

func (x *CdcControlResponse) GetGuardrailEpoch() uint64

func (*CdcControlResponse) GetStatus added in v0.1.4 

func (x *CdcControlResponse) GetStatus() string

func (*CdcControlResponse) GetSuccess added in v0.1.4 

func (x *CdcControlResponse) GetSuccess() bool

func (*CdcControlResponse) ProtoMessage added in v0.1.4 

func (*CdcControlResponse) ProtoMessage()

func (*CdcControlResponse) ProtoReflect added in v0.1.4 

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

func (*CdcControlResponse) Reset added in v0.1.4 

func (x *CdcControlResponse) Reset()

func (*CdcControlResponse) String added in v0.1.4 

func (x *CdcControlResponse) String() string

type CdcDiagnosticsConfig added in v0.1.4 

type CdcDiagnosticsConfig struct {
	Enabled                      bool    `protobuf:"varint,1,opt,name=enabled,proto3" json:"enabled,omitempty"`
	MalformedSnapshotInterval    uint64  `` /* 139-byte string literal not displayed */
	MalformedHashRetain          uint32  `protobuf:"varint,3,opt,name=malformed_hash_retain,json=malformedHashRetain,proto3" json:"malformed_hash_retain,omitempty"`
	MalformedWarnPct             float64 `protobuf:"fixed64,4,opt,name=malformed_warn_pct,json=malformedWarnPct,proto3" json:"malformed_warn_pct,omitempty"`
	MalformedAbortPct            float64 `protobuf:"fixed64,5,opt,name=malformed_abort_pct,json=malformedAbortPct,proto3" json:"malformed_abort_pct,omitempty"`
	FlushIntervalMs              uint32  `protobuf:"varint,6,opt,name=flush_interval_ms,json=flushIntervalMs,proto3" json:"flush_interval_ms,omitempty"`
	BatchSize                    uint32  `protobuf:"varint,7,opt,name=batch_size,json=batchSize,proto3" json:"batch_size,omitempty"`
	PendingBackpressureWatermark uint64  `` /* 148-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*CdcDiagnosticsConfig) Descriptor deprecated added in v0.1.4 

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

Deprecated: Use CdcDiagnosticsConfig.ProtoReflect.Descriptor instead.

func (*CdcDiagnosticsConfig) GetBatchSize added in v0.1.4 

func (x *CdcDiagnosticsConfig) GetBatchSize() uint32

func (*CdcDiagnosticsConfig) GetEnabled added in v0.1.4 

func (x *CdcDiagnosticsConfig) GetEnabled() bool

func (*CdcDiagnosticsConfig) GetFlushIntervalMs added in v0.1.4 

func (x *CdcDiagnosticsConfig) GetFlushIntervalMs() uint32

func (*CdcDiagnosticsConfig) GetMalformedAbortPct added in v0.1.4 

func (x *CdcDiagnosticsConfig) GetMalformedAbortPct() float64

func (*CdcDiagnosticsConfig) GetMalformedHashRetain added in v0.1.4 

func (x *CdcDiagnosticsConfig) GetMalformedHashRetain() uint32

func (*CdcDiagnosticsConfig) GetMalformedSnapshotInterval added in v0.1.4 

func (x *CdcDiagnosticsConfig) GetMalformedSnapshotInterval() uint64

func (*CdcDiagnosticsConfig) GetMalformedWarnPct added in v0.1.4 

func (x *CdcDiagnosticsConfig) GetMalformedWarnPct() float64

func (*CdcDiagnosticsConfig) GetPendingBackpressureWatermark added in v0.1.4 

func (x *CdcDiagnosticsConfig) GetPendingBackpressureWatermark() uint64

func (*CdcDiagnosticsConfig) ProtoMessage added in v0.1.4 

func (*CdcDiagnosticsConfig) ProtoMessage()

func (*CdcDiagnosticsConfig) ProtoReflect added in v0.1.4 

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

func (*CdcDiagnosticsConfig) Reset added in v0.1.4 

func (x *CdcDiagnosticsConfig) Reset()

func (*CdcDiagnosticsConfig) String added in v0.1.4 

func (x *CdcDiagnosticsConfig) String() string

type CdcDiagnosticsEngine added in v0.1.4 

type CdcDiagnosticsEngine struct {
	IsRunning        bool   `protobuf:"varint,1,opt,name=is_running,json=isRunning,proto3" json:"is_running,omitempty"`
	LastFlushMs      int64  `protobuf:"varint,2,opt,name=last_flush_ms,json=lastFlushMs,proto3" json:"last_flush_ms,omitempty"`
	PeakBuffer       uint64 `protobuf:"varint,3,opt,name=peak_buffer,json=peakBuffer,proto3" json:"peak_buffer,omitempty"`
	CurrentBuffer    uint64 `protobuf:"varint,4,opt,name=current_buffer,json=currentBuffer,proto3" json:"current_buffer,omitempty"`
	DynamicBatchSize uint32 `protobuf:"varint,5,opt,name=dynamic_batch_size,json=dynamicBatchSize,proto3" json:"dynamic_batch_size,omitempty"`
	BatchAdjustments uint32 `protobuf:"varint,6,opt,name=batch_adjustments,json=batchAdjustments,proto3" json:"batch_adjustments,omitempty"`
	// contains filtered or unexported fields
}

func (*CdcDiagnosticsEngine) Descriptor deprecated added in v0.1.4 

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

Deprecated: Use CdcDiagnosticsEngine.ProtoReflect.Descriptor instead.

func (*CdcDiagnosticsEngine) GetBatchAdjustments added in v0.1.4 

func (x *CdcDiagnosticsEngine) GetBatchAdjustments() uint32

func (*CdcDiagnosticsEngine) GetCurrentBuffer added in v0.1.4 

func (x *CdcDiagnosticsEngine) GetCurrentBuffer() uint64

func (*CdcDiagnosticsEngine) GetDynamicBatchSize added in v0.1.4 

func (x *CdcDiagnosticsEngine) GetDynamicBatchSize() uint32

func (*CdcDiagnosticsEngine) GetIsRunning added in v0.1.4 

func (x *CdcDiagnosticsEngine) GetIsRunning() bool

func (*CdcDiagnosticsEngine) GetLastFlushMs added in v0.1.4 

func (x *CdcDiagnosticsEngine) GetLastFlushMs() int64

func (*CdcDiagnosticsEngine) GetPeakBuffer added in v0.1.4 

func (x *CdcDiagnosticsEngine) GetPeakBuffer() uint64

func (*CdcDiagnosticsEngine) ProtoMessage added in v0.1.4 

func (*CdcDiagnosticsEngine) ProtoMessage()

func (*CdcDiagnosticsEngine) ProtoReflect added in v0.1.4 

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

func (*CdcDiagnosticsEngine) Reset added in v0.1.4 

func (x *CdcDiagnosticsEngine) Reset()

func (*CdcDiagnosticsEngine) String added in v0.1.4 

func (x *CdcDiagnosticsEngine) String() string

type CdcDiagnosticsRequest 

type CdcDiagnosticsRequest struct {
	// contains filtered or unexported fields
}

============================================================================ CDC ============================================================================

func (*CdcDiagnosticsRequest) Descriptor deprecated added in v0.1.4 

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

Deprecated: Use CdcDiagnosticsRequest.ProtoReflect.Descriptor instead.

func (*CdcDiagnosticsRequest) ProtoMessage added in v0.1.4 

func (*CdcDiagnosticsRequest) ProtoMessage()

func (*CdcDiagnosticsRequest) ProtoReflect added in v0.1.4 

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

func (*CdcDiagnosticsRequest) Reset added in v0.1.4 

func (x *CdcDiagnosticsRequest) Reset()

func (*CdcDiagnosticsRequest) String added in v0.1.4 

func (x *CdcDiagnosticsRequest) String() string

type CdcDiagnosticsResponse 

type CdcDiagnosticsResponse struct {
	MalformedChangeRecords  uint64                  `` /* 130-byte string literal not displayed */
	TotalChangeAttempts     uint64                  `protobuf:"varint,2,opt,name=total_change_attempts,json=totalChangeAttempts,proto3" json:"total_change_attempts,omitempty"`
	MalformedRatio          float64                 `protobuf:"fixed64,3,opt,name=malformed_ratio,json=malformedRatio,proto3" json:"malformed_ratio,omitempty"`
	GuardrailWarnTriggered  bool                    `` /* 130-byte string literal not displayed */
	GuardrailAbortTriggered bool                    `` /* 133-byte string literal not displayed */
	FirstWarnTsMs           int64                   `protobuf:"varint,6,opt,name=first_warn_ts_ms,json=firstWarnTsMs,proto3" json:"first_warn_ts_ms,omitempty"`
	FirstAbortTsMs          int64                   `protobuf:"varint,7,opt,name=first_abort_ts_ms,json=firstAbortTsMs,proto3" json:"first_abort_ts_ms,omitempty"`
	GuardrailEpoch          uint64                  `protobuf:"varint,8,opt,name=guardrail_epoch,json=guardrailEpoch,proto3" json:"guardrail_epoch,omitempty"`
	UptimeMs                int64                   `protobuf:"varint,9,opt,name=uptime_ms,json=uptimeMs,proto3" json:"uptime_ms,omitempty"`
	Backpressure            bool                    `protobuf:"varint,10,opt,name=backpressure,proto3" json:"backpressure,omitempty"`
	Config                  *CdcDiagnosticsConfig   `protobuf:"bytes,11,opt,name=config,proto3" json:"config,omitempty"`
	Engine                  *CdcDiagnosticsEngine   `protobuf:"bytes,12,opt,name=engine,proto3" json:"engine,omitempty"`
	MalformedSnapshots      []*CdcMalformedSnapshot `protobuf:"bytes,13,rep,name=malformed_snapshots,json=malformedSnapshots,proto3" json:"malformed_snapshots,omitempty"`
	MalformedHashes         []*CdcMalformedHash     `protobuf:"bytes,14,rep,name=malformed_hashes,json=malformedHashes,proto3" json:"malformed_hashes,omitempty"`
	Version                 string                  `protobuf:"bytes,15,opt,name=version,proto3" json:"version,omitempty"`
	TimestampMs             int64                   `protobuf:"varint,16,opt,name=timestamp_ms,json=timestampMs,proto3" json:"timestamp_ms,omitempty"`
	// contains filtered or unexported fields
}

func DecodeCdcDiagnosticsResponse 

func DecodeCdcDiagnosticsResponse(data []byte) (*CdcDiagnosticsResponse, error)

DecodeCdcDiagnosticsResponse decodes a protobuf-encoded CdcDiagnosticsResponse.

func (*CdcDiagnosticsResponse) Descriptor deprecated added in v0.1.4 

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

Deprecated: Use CdcDiagnosticsResponse.ProtoReflect.Descriptor instead.

func (*CdcDiagnosticsResponse) GetBackpressure added in v0.1.4 

func (x *CdcDiagnosticsResponse) GetBackpressure() bool

func (*CdcDiagnosticsResponse) GetConfig added in v0.1.4 

func (x *CdcDiagnosticsResponse) GetConfig() *CdcDiagnosticsConfig

func (*CdcDiagnosticsResponse) GetEngine added in v0.1.4 

func (x *CdcDiagnosticsResponse) GetEngine() *CdcDiagnosticsEngine

func (*CdcDiagnosticsResponse) GetFirstAbortTsMs added in v0.1.4 

func (x *CdcDiagnosticsResponse) GetFirstAbortTsMs() int64

func (*CdcDiagnosticsResponse) GetFirstWarnTsMs added in v0.1.4 

func (x *CdcDiagnosticsResponse) GetFirstWarnTsMs() int64

func (*CdcDiagnosticsResponse) GetGuardrailAbortTriggered added in v0.1.4 

func (x *CdcDiagnosticsResponse) GetGuardrailAbortTriggered() bool

func (*CdcDiagnosticsResponse) GetGuardrailEpoch added in v0.1.4 

func (x *CdcDiagnosticsResponse) GetGuardrailEpoch() uint64

func (*CdcDiagnosticsResponse) GetGuardrailWarnTriggered added in v0.1.4 

func (x *CdcDiagnosticsResponse) GetGuardrailWarnTriggered() bool

func (*CdcDiagnosticsResponse) GetMalformedChangeRecords added in v0.1.4 

func (x *CdcDiagnosticsResponse) GetMalformedChangeRecords() uint64

func (*CdcDiagnosticsResponse) GetMalformedHashes added in v0.1.4 

func (x *CdcDiagnosticsResponse) GetMalformedHashes() []*CdcMalformedHash

func (*CdcDiagnosticsResponse) GetMalformedRatio added in v0.1.4 

func (x *CdcDiagnosticsResponse) GetMalformedRatio() float64

func (*CdcDiagnosticsResponse) GetMalformedSnapshots added in v0.1.4 

func (x *CdcDiagnosticsResponse) GetMalformedSnapshots() []*CdcMalformedSnapshot

func (*CdcDiagnosticsResponse) GetTimestampMs added in v0.1.4 

func (x *CdcDiagnosticsResponse) GetTimestampMs() int64

func (*CdcDiagnosticsResponse) GetTotalChangeAttempts added in v0.1.4 

func (x *CdcDiagnosticsResponse) GetTotalChangeAttempts() uint64

func (*CdcDiagnosticsResponse) GetUptimeMs added in v0.1.4 

func (x *CdcDiagnosticsResponse) GetUptimeMs() int64

func (*CdcDiagnosticsResponse) GetVersion added in v0.1.4 

func (x *CdcDiagnosticsResponse) GetVersion() string

func (*CdcDiagnosticsResponse) ProtoMessage added in v0.1.4 

func (*CdcDiagnosticsResponse) ProtoMessage()

func (*CdcDiagnosticsResponse) ProtoReflect added in v0.1.4 

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

func (*CdcDiagnosticsResponse) Reset added in v0.1.4 

func (x *CdcDiagnosticsResponse) Reset()

func (*CdcDiagnosticsResponse) String added in v0.1.4 

func (x *CdcDiagnosticsResponse) String() string

type CdcMalformedHash added in v0.1.4 

type CdcMalformedHash struct {
	Count     uint64 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	Hash      uint64 `protobuf:"varint,2,opt,name=hash,proto3" json:"hash,omitempty"`
	TsMs      int64  `protobuf:"varint,3,opt,name=ts_ms,json=tsMs,proto3" json:"ts_ms,omitempty"`
	PrefixHex string `protobuf:"bytes,4,opt,name=prefix_hex,json=prefixHex,proto3" json:"prefix_hex,omitempty"`
	// contains filtered or unexported fields
}

func (*CdcMalformedHash) Descriptor deprecated added in v0.1.4 

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

Deprecated: Use CdcMalformedHash.ProtoReflect.Descriptor instead.

func (*CdcMalformedHash) GetCount added in v0.1.4 

func (x *CdcMalformedHash) GetCount() uint64

func (*CdcMalformedHash) GetHash added in v0.1.4 

func (x *CdcMalformedHash) GetHash() uint64

func (*CdcMalformedHash) GetPrefixHex added in v0.1.4 

func (x *CdcMalformedHash) GetPrefixHex() string

func (*CdcMalformedHash) GetTsMs added in v0.1.4 

func (x *CdcMalformedHash) GetTsMs() int64

func (*CdcMalformedHash) ProtoMessage added in v0.1.4 

func (*CdcMalformedHash) ProtoMessage()

func (*CdcMalformedHash) ProtoReflect added in v0.1.4 

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

func (*CdcMalformedHash) Reset added in v0.1.4 

func (x *CdcMalformedHash) Reset()

func (*CdcMalformedHash) String added in v0.1.4 

func (x *CdcMalformedHash) String() string

type CdcMalformedSnapshot added in v0.1.4 

type CdcMalformedSnapshot struct {
	Count uint64 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	TsMs  int64  `protobuf:"varint,2,opt,name=ts_ms,json=tsMs,proto3" json:"ts_ms,omitempty"`
	// contains filtered or unexported fields
}

func (*CdcMalformedSnapshot) Descriptor deprecated added in v0.1.4 

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

Deprecated: Use CdcMalformedSnapshot.ProtoReflect.Descriptor instead.

func (*CdcMalformedSnapshot) GetCount added in v0.1.4 

func (x *CdcMalformedSnapshot) GetCount() uint64

func (*CdcMalformedSnapshot) GetTsMs added in v0.1.4 

func (x *CdcMalformedSnapshot) GetTsMs() int64

func (*CdcMalformedSnapshot) ProtoMessage added in v0.1.4 

func (*CdcMalformedSnapshot) ProtoMessage()

func (*CdcMalformedSnapshot) ProtoReflect added in v0.1.4 

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

func (*CdcMalformedSnapshot) Reset added in v0.1.4 

func (x *CdcMalformedSnapshot) Reset()

func (*CdcMalformedSnapshot) String added in v0.1.4 

func (x *CdcMalformedSnapshot) String() string

type ClientPacket added in v0.1.4 

type ClientPacket struct {

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

============================================================================ Transport Wrappers (QUIC framing) ============================================================================

func (*ClientPacket) Descriptor deprecated added in v0.1.4 

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

Deprecated: Use ClientPacket.ProtoReflect.Descriptor instead.

func (*ClientPacket) GetMsg added in v0.1.4 

func (x *ClientPacket) GetMsg() isClientPacket_Msg

func (*ClientPacket) GetQuic added in v0.1.4 

func (x *ClientPacket) GetQuic() *QuicClientMessage

func (*ClientPacket) ProtoMessage added in v0.1.4 

func (*ClientPacket) ProtoMessage()

func (*ClientPacket) ProtoReflect added in v0.1.4 

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

func (*ClientPacket) Reset added in v0.1.4 

func (x *ClientPacket) Reset()

func (*ClientPacket) String added in v0.1.4 

func (x *ClientPacket) String() string

type ClientPacket_Quic added in v0.1.4 

type ClientPacket_Quic struct {
	Quic *QuicClientMessage `protobuf:"bytes,1,opt,name=quic,proto3,oneof"`
}

type ColumnDefinition 

type ColumnDefinition struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*ColumnDefinition) Descriptor deprecated added in v0.1.4 

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

Deprecated: Use ColumnDefinition.ProtoReflect.Descriptor instead.

func (*ColumnDefinition) GetName added in v0.1.4 

func (x *ColumnDefinition) GetName() string

func (*ColumnDefinition) GetType added in v0.1.4 

func (x *ColumnDefinition) GetType() string

func (*ColumnDefinition) ProtoMessage added in v0.1.4 

func (*ColumnDefinition) ProtoMessage()

func (*ColumnDefinition) ProtoReflect added in v0.1.4 

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

func (*ColumnDefinition) Reset added in v0.1.4 

func (x *ColumnDefinition) Reset()

func (*ColumnDefinition) String added in v0.1.4 

func (x *ColumnDefinition) String() string

type CommitRequest 

type CommitRequest struct {
	SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"` // Required for gRPC; ignored for QUIC
	// contains filtered or unexported fields
}

func (*CommitRequest) Descriptor deprecated added in v0.1.4 

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

Deprecated: Use CommitRequest.ProtoReflect.Descriptor instead.

func (*CommitRequest) GetSessionId added in v0.1.4 

func (x *CommitRequest) GetSessionId() string

func (*CommitRequest) ProtoMessage added in v0.1.4 

func (*CommitRequest) ProtoMessage()

func (*CommitRequest) ProtoReflect added in v0.1.4 

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

func (*CommitRequest) Reset added in v0.1.4 

func (x *CommitRequest) Reset()

func (*CommitRequest) String added in v0.1.4 

func (x *CommitRequest) String() string

type CommitResponse 

type CommitResponse struct {
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	// contains filtered or unexported fields
}

func DecodeCommitResponse 

func DecodeCommitResponse(data []byte) (*CommitResponse, error)

DecodeCommitResponse decodes a protobuf-encoded CommitResponse.

func (*CommitResponse) Descriptor deprecated added in v0.1.4 

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

Deprecated: Use CommitResponse.ProtoReflect.Descriptor instead.

func (*CommitResponse) GetSuccess added in v0.1.4 

func (x *CommitResponse) GetSuccess() bool

func (*CommitResponse) ProtoMessage added in v0.1.4 

func (*CommitResponse) ProtoMessage()

func (*CommitResponse) ProtoReflect added in v0.1.4 

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

func (*CommitResponse) Reset added in v0.1.4 

func (x *CommitResponse) Reset()

func (*CommitResponse) String added in v0.1.4 

func (x *CommitResponse) String() string

type DataPage 

type DataPage struct {
	Rows      []*Row   `protobuf:"bytes,1,rep,name=rows,proto3" json:"rows,omitempty"`
	Final     bool     `protobuf:"varint,2,opt,name=final,proto3" json:"final,omitempty"`
	Ordered   bool     `protobuf:"varint,3,opt,name=ordered,proto3" json:"ordered,omitempty"`
	OrderKeys []string `protobuf:"bytes,4,rep,name=order_keys,json=orderKeys,proto3" json:"order_keys,omitempty"`
	// contains filtered or unexported fields
}

func (*DataPage) Descriptor deprecated added in v0.1.4 

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

Deprecated: Use DataPage.ProtoReflect.Descriptor instead.

func (*DataPage) GetFinal added in v0.1.4 

func (x *DataPage) GetFinal() bool

func (*DataPage) GetOrderKeys added in v0.1.4 

func (x *DataPage) GetOrderKeys() []string

func (*DataPage) GetOrdered added in v0.1.4 

func (x *DataPage) GetOrdered() bool

func (*DataPage) GetRows added in v0.1.4 

func (x *DataPage) GetRows() []*Row

func (*DataPage) ProtoMessage added in v0.1.4 

func (*DataPage) ProtoMessage()

func (*DataPage) ProtoReflect added in v0.1.4 

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

func (*DataPage) Reset added in v0.1.4 

func (x *DataPage) Reset()

func (*DataPage) String added in v0.1.4 

func (x *DataPage) String() string

type DecimalValue added in v0.1.4 

type DecimalValue struct {
	Coeff     string `protobuf:"bytes,1,opt,name=coeff,proto3" json:"coeff,omitempty"` // i128 as decimal string
	Scale     uint32 `protobuf:"varint,2,opt,name=scale,proto3" json:"scale,omitempty"`
	OrigScale uint32 `protobuf:"varint,3,opt,name=orig_scale,json=origScale,proto3" json:"orig_scale,omitempty"`
	OrigRepr  string `protobuf:"bytes,4,opt,name=orig_repr,json=origRepr,proto3" json:"orig_repr,omitempty"`
	// contains filtered or unexported fields
}

func (*DecimalValue) Descriptor deprecated added in v0.1.4 

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

Deprecated: Use DecimalValue.ProtoReflect.Descriptor instead.

func (*DecimalValue) GetCoeff added in v0.1.4 

func (x *DecimalValue) GetCoeff() string

func (*DecimalValue) GetOrigRepr added in v0.1.4 

func (x *DecimalValue) GetOrigRepr() string

func (*DecimalValue) GetOrigScale added in v0.1.4 

func (x *DecimalValue) GetOrigScale() uint32

func (*DecimalValue) GetScale added in v0.1.4 

func (x *DecimalValue) GetScale() uint32

func (*DecimalValue) ProtoMessage added in v0.1.4 

func (*DecimalValue) ProtoMessage()

func (*DecimalValue) ProtoReflect added in v0.1.4 

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

func (*DecimalValue) Reset added in v0.1.4 

func (x *DecimalValue) Reset()

func (*DecimalValue) String added in v0.1.4 

func (x *DecimalValue) String() string

type DoubleValue added in v0.1.4 

type DoubleValue struct {
	Value float64   `protobuf:"fixed64,1,opt,name=value,proto3" json:"value,omitempty"`
	Kind  FloatKind `protobuf:"varint,2,opt,name=kind,proto3,enum=geode.FloatKind" json:"kind,omitempty"`
	// contains filtered or unexported fields
}

func (*DoubleValue) Descriptor deprecated added in v0.1.4 

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

Deprecated: Use DoubleValue.ProtoReflect.Descriptor instead.

func (*DoubleValue) GetKind added in v0.1.4 

func (x *DoubleValue) GetKind() FloatKind

func (*DoubleValue) GetValue added in v0.1.4 

func (x *DoubleValue) GetValue() float64

func (*DoubleValue) ProtoMessage added in v0.1.4 

func (*DoubleValue) ProtoMessage()

func (*DoubleValue) ProtoReflect added in v0.1.4 

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

func (*DoubleValue) Reset added in v0.1.4 

func (x *DoubleValue) Reset()

func (*DoubleValue) String added in v0.1.4 

func (x *DoubleValue) String() string

type EdgeValue added in v0.1.4 

type EdgeValue struct {
	Id         uint64      `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	FromId     uint64      `protobuf:"varint,2,opt,name=from_id,json=fromId,proto3" json:"from_id,omitempty"`
	ToId       uint64      `protobuf:"varint,3,opt,name=to_id,json=toId,proto3" json:"to_id,omitempty"`
	Label      string      `protobuf:"bytes,4,opt,name=label,proto3" json:"label,omitempty"`
	Properties []*MapEntry `protobuf:"bytes,5,rep,name=properties,proto3" json:"properties,omitempty"`
	// contains filtered or unexported fields
}

func (*EdgeValue) Descriptor deprecated added in v0.1.4 

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

Deprecated: Use EdgeValue.ProtoReflect.Descriptor instead.

func (*EdgeValue) GetFromId added in v0.1.4 

func (x *EdgeValue) GetFromId() uint64

func (*EdgeValue) GetId added in v0.1.4 

func (x *EdgeValue) GetId() uint64

func (*EdgeValue) GetLabel added in v0.1.4 

func (x *EdgeValue) GetLabel() string

func (*EdgeValue) GetProperties added in v0.1.4 

func (x *EdgeValue) GetProperties() []*MapEntry

func (*EdgeValue) GetToId added in v0.1.4 

func (x *EdgeValue) GetToId() uint64

func (*EdgeValue) ProtoMessage added in v0.1.4 

func (*EdgeValue) ProtoMessage()

func (*EdgeValue) ProtoReflect added in v0.1.4 

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

func (*EdgeValue) Reset added in v0.1.4 

func (x *EdgeValue) Reset()

func (*EdgeValue) String added in v0.1.4 

func (x *EdgeValue) String() string

type Error 

type Error struct {
	Code    string `protobuf:"bytes,1,opt,name=code,proto3" json:"code,omitempty"`
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	Type    string `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"` // "ERROR"
	Anchor  string `protobuf:"bytes,4,opt,name=anchor,proto3" json:"anchor,omitempty"`
	// contains filtered or unexported fields
}

func (*Error) Descriptor deprecated added in v0.1.4 

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

Deprecated: Use Error.ProtoReflect.Descriptor instead.

func (*Error) GetAnchor added in v0.1.4 

func (x *Error) GetAnchor() string

func (*Error) GetCode added in v0.1.4 

func (x *Error) GetCode() string

func (*Error) GetMessage added in v0.1.4 

func (x *Error) GetMessage() string

func (*Error) GetType added in v0.1.4 

func (x *Error) GetType() string

func (*Error) ProtoMessage added in v0.1.4 

func (*Error) ProtoMessage()

func (*Error) ProtoReflect added in v0.1.4 

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

func (*Error) Reset added in v0.1.4 

func (x *Error) Reset()

func (*Error) String added in v0.1.4 

func (x *Error) String() string

type ExecuteRequest 

type ExecuteRequest struct {
	SessionId string   `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	Query     string   `protobuf:"bytes,2,opt,name=query,proto3" json:"query,omitempty"`
	Params    []*Param `protobuf:"bytes,3,rep,name=params,proto3" json:"params,omitempty"`
	// contains filtered or unexported fields
}

============================================================================ Query Execution (RUN_GQL + PULL) ============================================================================

func (*ExecuteRequest) Descriptor deprecated added in v0.1.4 

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

Deprecated: Use ExecuteRequest.ProtoReflect.Descriptor instead.

func (*ExecuteRequest) GetParams added in v0.1.4 

func (x *ExecuteRequest) GetParams() []*Param

func (*ExecuteRequest) GetQuery added in v0.1.4 

func (x *ExecuteRequest) GetQuery() string

func (*ExecuteRequest) GetSessionId added in v0.1.4 

func (x *ExecuteRequest) GetSessionId() string

func (*ExecuteRequest) ProtoMessage added in v0.1.4 

func (*ExecuteRequest) ProtoMessage()

func (*ExecuteRequest) ProtoReflect added in v0.1.4 

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

func (*ExecuteRequest) Reset added in v0.1.4 

func (x *ExecuteRequest) Reset()

func (*ExecuteRequest) String added in v0.1.4 

func (x *ExecuteRequest) String() string

type ExecutionMetrics 

type ExecutionMetrics struct {
	ParseDurationNs   int64 `protobuf:"varint,1,opt,name=parse_duration_ns,json=parseDurationNs,proto3" json:"parse_duration_ns,omitempty"`
	PlanDurationNs    int64 `protobuf:"varint,2,opt,name=plan_duration_ns,json=planDurationNs,proto3" json:"plan_duration_ns,omitempty"`
	ExecuteDurationNs int64 `protobuf:"varint,3,opt,name=execute_duration_ns,json=executeDurationNs,proto3" json:"execute_duration_ns,omitempty"`
	TotalDurationNs   int64 `protobuf:"varint,4,opt,name=total_duration_ns,json=totalDurationNs,proto3" json:"total_duration_ns,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecutionMetrics) Descriptor deprecated added in v0.1.4 

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

Deprecated: Use ExecutionMetrics.ProtoReflect.Descriptor instead.

func (*ExecutionMetrics) GetExecuteDurationNs added in v0.1.4 

func (x *ExecutionMetrics) GetExecuteDurationNs() int64

func (*ExecutionMetrics) GetParseDurationNs added in v0.1.4 

func (x *ExecutionMetrics) GetParseDurationNs() int64

func (*ExecutionMetrics) GetPlanDurationNs added in v0.1.4 

func (x *ExecutionMetrics) GetPlanDurationNs() int64

func (*ExecutionMetrics) GetTotalDurationNs added in v0.1.4 

func (x *ExecutionMetrics) GetTotalDurationNs() int64

func (*ExecutionMetrics) ProtoMessage added in v0.1.4 

func (*ExecutionMetrics) ProtoMessage()

func (*ExecutionMetrics) ProtoReflect added in v0.1.4 

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

func (*ExecutionMetrics) Reset added in v0.1.4 

func (x *ExecutionMetrics) Reset()

func (*ExecutionMetrics) String added in v0.1.4 

func (x *ExecutionMetrics) String() string

type ExecutionResponse 

type ExecutionResponse struct {
	Status *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// Types that are valid to be assigned to Payload:
	//
	//	*ExecutionResponse_Schema
	//	*ExecutionResponse_Page
	//	*ExecutionResponse_Error
	//	*ExecutionResponse_Metrics
	//	*ExecutionResponse_Explain
	//	*ExecutionResponse_Profile
	//	*ExecutionResponse_Heartbeat
	Payload isExecutionResponse_Payload `protobuf_oneof:"payload"`
	// contains filtered or unexported fields
}

func DecodeExecutionResponse 

func DecodeExecutionResponse(data []byte) (*ExecutionResponse, error)

DecodeExecutionResponse decodes a protobuf-encoded ExecutionResponse.

func (*ExecutionResponse) Descriptor deprecated added in v0.1.4 

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

Deprecated: Use ExecutionResponse.ProtoReflect.Descriptor instead.

func (*ExecutionResponse) GetError added in v0.1.4 

func (x *ExecutionResponse) GetError() *Error

func (*ExecutionResponse) GetExplain added in v0.1.4 

func (x *ExecutionResponse) GetExplain() *ExplainPayload

func (*ExecutionResponse) GetHeartbeat added in v0.1.4 

func (x *ExecutionResponse) GetHeartbeat() *Heartbeat

func (*ExecutionResponse) GetMetrics added in v0.1.4 

func (x *ExecutionResponse) GetMetrics() *ExecutionMetrics

func (*ExecutionResponse) GetPage added in v0.1.4 

func (x *ExecutionResponse) GetPage() *DataPage

func (*ExecutionResponse) GetPayload added in v0.1.4 

func (x *ExecutionResponse) GetPayload() isExecutionResponse_Payload

func (*ExecutionResponse) GetProfile added in v0.1.4 

func (x *ExecutionResponse) GetProfile() *ProfilePayload

func (*ExecutionResponse) GetSchema added in v0.1.4 

func (x *ExecutionResponse) GetSchema() *SchemaDefinition

func (*ExecutionResponse) GetStatus added in v0.1.4 

func (x *ExecutionResponse) GetStatus() *Status

func (*ExecutionResponse) ProtoMessage added in v0.1.4 

func (*ExecutionResponse) ProtoMessage()

func (*ExecutionResponse) ProtoReflect added in v0.1.4 

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

func (*ExecutionResponse) Reset added in v0.1.4 

func (x *ExecutionResponse) Reset()

func (*ExecutionResponse) String added in v0.1.4 

func (x *ExecutionResponse) String() string

type ExecutionResponse_Error added in v0.1.4 

type ExecutionResponse_Error struct {
	Error *Error `protobuf:"bytes,4,opt,name=error,proto3,oneof"`
}

type ExecutionResponse_Explain added in v0.1.4 

type ExecutionResponse_Explain struct {
	Explain *ExplainPayload `protobuf:"bytes,6,opt,name=explain,proto3,oneof"`
}

type ExecutionResponse_Heartbeat added in v0.1.4 

type ExecutionResponse_Heartbeat struct {
	Heartbeat *Heartbeat `protobuf:"bytes,8,opt,name=heartbeat,proto3,oneof"`
}

type ExecutionResponse_Metrics added in v0.1.4 

type ExecutionResponse_Metrics struct {
	Metrics *ExecutionMetrics `protobuf:"bytes,5,opt,name=metrics,proto3,oneof"`
}

type ExecutionResponse_Page added in v0.1.4 

type ExecutionResponse_Page struct {
	Page *DataPage `protobuf:"bytes,3,opt,name=page,proto3,oneof"`
}

type ExecutionResponse_Profile added in v0.1.4 

type ExecutionResponse_Profile struct {
	Profile *ProfilePayload `protobuf:"bytes,7,opt,name=profile,proto3,oneof"`
}

type ExecutionResponse_Schema added in v0.1.4 

type ExecutionResponse_Schema struct {
	Schema *SchemaDefinition `protobuf:"bytes,2,opt,name=schema,proto3,oneof"`
}

type ExplainCalibration added in v0.1.4 

type ExplainCalibration struct {
	Mape    float64                    `protobuf:"fixed64,1,opt,name=mape,proto3" json:"mape,omitempty"`
	Entries []*ExplainCalibrationEntry `protobuf:"bytes,2,rep,name=entries,proto3" json:"entries,omitempty"`
	// contains filtered or unexported fields
}

func (*ExplainCalibration) Descriptor deprecated added in v0.1.4 

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

Deprecated: Use ExplainCalibration.ProtoReflect.Descriptor instead.

func (*ExplainCalibration) GetEntries added in v0.1.4 

func (x *ExplainCalibration) GetEntries() []*ExplainCalibrationEntry

func (*ExplainCalibration) GetMape added in v0.1.4 

func (x *ExplainCalibration) GetMape() float64

func (*ExplainCalibration) ProtoMessage added in v0.1.4 

func (*ExplainCalibration) ProtoMessage()

func (*ExplainCalibration) ProtoReflect added in v0.1.4 

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

func (*ExplainCalibration) Reset added in v0.1.4 

func (x *ExplainCalibration) Reset()

func (*ExplainCalibration) String added in v0.1.4 

func (x *ExplainCalibration) String() string

type ExplainCalibrationEntry added in v0.1.4 

type ExplainCalibrationEntry struct {
	Idx        uint32  `protobuf:"varint,1,opt,name=idx,proto3" json:"idx,omitempty"`
	EstRows    float64 `protobuf:"fixed64,2,opt,name=est_rows,json=estRows,proto3" json:"est_rows,omitempty"`
	ActualRows float64 `protobuf:"fixed64,3,opt,name=actual_rows,json=actualRows,proto3" json:"actual_rows,omitempty"`
	// contains filtered or unexported fields
}

func (*ExplainCalibrationEntry) Descriptor deprecated added in v0.1.4 

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

Deprecated: Use ExplainCalibrationEntry.ProtoReflect.Descriptor instead.

func (*ExplainCalibrationEntry) GetActualRows added in v0.1.4 

func (x *ExplainCalibrationEntry) GetActualRows() float64

func (*ExplainCalibrationEntry) GetEstRows added in v0.1.4 

func (x *ExplainCalibrationEntry) GetEstRows() float64

func (*ExplainCalibrationEntry) GetIdx added in v0.1.4 

func (x *ExplainCalibrationEntry) GetIdx() uint32

func (*ExplainCalibrationEntry) ProtoMessage added in v0.1.4 

func (*ExplainCalibrationEntry) ProtoMessage()

func (*ExplainCalibrationEntry) ProtoReflect added in v0.1.4 

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

func (*ExplainCalibrationEntry) Reset added in v0.1.4 

func (x *ExplainCalibrationEntry) Reset()

func (*ExplainCalibrationEntry) String added in v0.1.4 

func (x *ExplainCalibrationEntry) String() string

type ExplainOp added in v0.1.4 

type ExplainOp struct {
	Idx     uint32 `protobuf:"varint,1,opt,name=idx,proto3" json:"idx,omitempty"`
	Kind    string `protobuf:"bytes,2,opt,name=kind,proto3" json:"kind,omitempty"`
	EstRows int64  `protobuf:"varint,3,opt,name=est_rows,json=estRows,proto3" json:"est_rows,omitempty"`
	Cost    int64  `protobuf:"varint,4,opt,name=cost,proto3" json:"cost,omitempty"`
	// contains filtered or unexported fields
}

func (*ExplainOp) Descriptor deprecated added in v0.1.4 

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

Deprecated: Use ExplainOp.ProtoReflect.Descriptor instead.

func (*ExplainOp) GetCost added in v0.1.4 

func (x *ExplainOp) GetCost() int64

func (*ExplainOp) GetEstRows added in v0.1.4 

func (x *ExplainOp) GetEstRows() int64

func (*ExplainOp) GetIdx added in v0.1.4 

func (x *ExplainOp) GetIdx() uint32

func (*ExplainOp) GetKind added in v0.1.4 

func (x *ExplainOp) GetKind() string

func (*ExplainOp) ProtoMessage added in v0.1.4 

func (*ExplainOp) ProtoMessage()

func (*ExplainOp) ProtoReflect added in v0.1.4 

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

func (*ExplainOp) Reset added in v0.1.4 

func (x *ExplainOp) Reset()

func (*ExplainOp) String added in v0.1.4 

func (x *ExplainOp) String() string

type ExplainPayload added in v0.1.4 

type ExplainPayload struct {
	Schema         string              `protobuf:"bytes,1,opt,name=schema,proto3" json:"schema,omitempty"`
	Ops            []*ExplainOp        `protobuf:"bytes,2,rep,name=ops,proto3" json:"ops,omitempty"`
	Totals         *ExplainTotals      `protobuf:"bytes,3,opt,name=totals,proto3" json:"totals,omitempty"`
	Properties     *ExplainProperties  `protobuf:"bytes,4,opt,name=properties,proto3" json:"properties,omitempty"`
	Calibration    *ExplainCalibration `protobuf:"bytes,5,opt,name=calibration,proto3" json:"calibration,omitempty"`
	ProfileVersion uint32              `protobuf:"varint,6,opt,name=profile_version,json=profileVersion,proto3" json:"profile_version,omitempty"`
	// contains filtered or unexported fields
}

func (*ExplainPayload) Descriptor deprecated added in v0.1.4 

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

Deprecated: Use ExplainPayload.ProtoReflect.Descriptor instead.

func (*ExplainPayload) GetCalibration added in v0.1.4 

func (x *ExplainPayload) GetCalibration() *ExplainCalibration

func (*ExplainPayload) GetOps added in v0.1.4 

func (x *ExplainPayload) GetOps() []*ExplainOp

func (*ExplainPayload) GetProfileVersion added in v0.1.4 

func (x *ExplainPayload) GetProfileVersion() uint32

func (*ExplainPayload) GetProperties added in v0.1.4 

func (x *ExplainPayload) GetProperties() *ExplainProperties

func (*ExplainPayload) GetSchema added in v0.1.4 

func (x *ExplainPayload) GetSchema() string

func (*ExplainPayload) GetTotals added in v0.1.4 

func (x *ExplainPayload) GetTotals() *ExplainTotals

func (*ExplainPayload) ProtoMessage added in v0.1.4 

func (*ExplainPayload) ProtoMessage()

func (*ExplainPayload) ProtoReflect added in v0.1.4 

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

func (*ExplainPayload) Reset added in v0.1.4 

func (x *ExplainPayload) Reset()

func (*ExplainPayload) String added in v0.1.4 

func (x *ExplainPayload) String() string

type ExplainProperties added in v0.1.4 

type ExplainProperties struct {
	Ordered        bool   `protobuf:"varint,1,opt,name=ordered,proto3" json:"ordered,omitempty"`
	Limit          uint64 `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"`
	Offset         uint64 `protobuf:"varint,3,opt,name=offset,proto3" json:"offset,omitempty"`
	Distinct       bool   `protobuf:"varint,4,opt,name=distinct,proto3" json:"distinct,omitempty"`
	UnionMode      string `protobuf:"bytes,5,opt,name=union_mode,json=unionMode,proto3" json:"union_mode,omitempty"`
	UnionPartCount uint32 `protobuf:"varint,6,opt,name=union_part_count,json=unionPartCount,proto3" json:"union_part_count,omitempty"`
	// contains filtered or unexported fields
}

func (*ExplainProperties) Descriptor deprecated added in v0.1.4 

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

Deprecated: Use ExplainProperties.ProtoReflect.Descriptor instead.

func (*ExplainProperties) GetDistinct added in v0.1.4 

func (x *ExplainProperties) GetDistinct() bool

func (*ExplainProperties) GetLimit added in v0.1.4 

func (x *ExplainProperties) GetLimit() uint64

func (*ExplainProperties) GetOffset added in v0.1.4 

func (x *ExplainProperties) GetOffset() uint64

func (*ExplainProperties) GetOrdered added in v0.1.4 

func (x *ExplainProperties) GetOrdered() bool

func (*ExplainProperties) GetUnionMode added in v0.1.4 

func (x *ExplainProperties) GetUnionMode() string

func (*ExplainProperties) GetUnionPartCount added in v0.1.4 

func (x *ExplainProperties) GetUnionPartCount() uint32

func (*ExplainProperties) ProtoMessage added in v0.1.4 

func (*ExplainProperties) ProtoMessage()

func (*ExplainProperties) ProtoReflect added in v0.1.4 

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

func (*ExplainProperties) Reset added in v0.1.4 

func (x *ExplainProperties) Reset()

func (*ExplainProperties) String added in v0.1.4 

func (x *ExplainProperties) String() string

type ExplainTotals added in v0.1.4 

type ExplainTotals struct {
	EstRows int64 `protobuf:"varint,1,opt,name=est_rows,json=estRows,proto3" json:"est_rows,omitempty"`
	Cost    int64 `protobuf:"varint,2,opt,name=cost,proto3" json:"cost,omitempty"`
	// contains filtered or unexported fields
}

func (*ExplainTotals) Descriptor deprecated added in v0.1.4 

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

Deprecated: Use ExplainTotals.ProtoReflect.Descriptor instead.

func (*ExplainTotals) GetCost added in v0.1.4 

func (x *ExplainTotals) GetCost() int64

func (*ExplainTotals) GetEstRows added in v0.1.4 

func (x *ExplainTotals) GetEstRows() int64

func (*ExplainTotals) ProtoMessage added in v0.1.4 

func (*ExplainTotals) ProtoMessage()

func (*ExplainTotals) ProtoReflect added in v0.1.4 

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

func (*ExplainTotals) Reset added in v0.1.4 

func (x *ExplainTotals) Reset()

func (*ExplainTotals) String added in v0.1.4 

func (x *ExplainTotals) String() string

type ExtendedValue added in v0.1.4 

type ExtendedValue struct {
	TypeName string `protobuf:"bytes,1,opt,name=type_name,json=typeName,proto3" json:"type_name,omitempty"`
	// Types that are valid to be assigned to Data:
	//
	//	*ExtendedValue_Text
	//	*ExtendedValue_Bytes
	//	*ExtendedValue_IntVal
	//	*ExtendedValue_DoubleVal
	//	*ExtendedValue_BoolVal
	Data isExtendedValue_Data `protobuf_oneof:"data"`
	// contains filtered or unexported fields
}

func (*ExtendedValue) Descriptor deprecated added in v0.1.4 

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

Deprecated: Use ExtendedValue.ProtoReflect.Descriptor instead.

func (*ExtendedValue) GetBoolVal added in v0.1.4 

func (x *ExtendedValue) GetBoolVal() bool

func (*ExtendedValue) GetBytes added in v0.1.4 

func (x *ExtendedValue) GetBytes() []byte

func (*ExtendedValue) GetData added in v0.1.4 

func (x *ExtendedValue) GetData() isExtendedValue_Data

func (*ExtendedValue) GetDoubleVal added in v0.1.4 

func (x *ExtendedValue) GetDoubleVal() float64

func (*ExtendedValue) GetIntVal added in v0.1.4 

func (x *ExtendedValue) GetIntVal() int64

func (*ExtendedValue) GetText added in v0.1.4 

func (x *ExtendedValue) GetText() string

func (*ExtendedValue) GetTypeName added in v0.1.4 

func (x *ExtendedValue) GetTypeName() string

func (*ExtendedValue) ProtoMessage added in v0.1.4 

func (*ExtendedValue) ProtoMessage()

func (*ExtendedValue) ProtoReflect added in v0.1.4 

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

func (*ExtendedValue) Reset added in v0.1.4 

func (x *ExtendedValue) Reset()

func (*ExtendedValue) String added in v0.1.4 

func (x *ExtendedValue) String() string

type ExtendedValue_BoolVal added in v0.1.4 

type ExtendedValue_BoolVal struct {
	BoolVal bool `protobuf:"varint,6,opt,name=bool_val,json=boolVal,proto3,oneof"`
}

type ExtendedValue_Bytes added in v0.1.4 

type ExtendedValue_Bytes struct {
	Bytes []byte `protobuf:"bytes,3,opt,name=bytes,proto3,oneof"`
}

type ExtendedValue_DoubleVal added in v0.1.4 

type ExtendedValue_DoubleVal struct {
	DoubleVal float64 `protobuf:"fixed64,5,opt,name=double_val,json=doubleVal,proto3,oneof"`
}

type ExtendedValue_IntVal added in v0.1.4 

type ExtendedValue_IntVal struct {
	IntVal int64 `protobuf:"varint,4,opt,name=int_val,json=intVal,proto3,oneof"`
}

type ExtendedValue_Text added in v0.1.4 

type ExtendedValue_Text struct {
	Text string `protobuf:"bytes,2,opt,name=text,proto3,oneof"`
}

type FloatKind added in v0.1.4 

type FloatKind int32
const (
	FloatKind_FLOAT_KIND_UNSPECIFIED FloatKind = 0
	FloatKind_DOUBLE                 FloatKind = 1
	FloatKind_REAL                   FloatKind = 2
)

func (FloatKind) Descriptor added in v0.1.4 

func (FloatKind) Descriptor() protoreflect.EnumDescriptor

func (FloatKind) Enum added in v0.1.4 

func (x FloatKind) Enum() *FloatKind

func (FloatKind) EnumDescriptor deprecated added in v0.1.4 

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

Deprecated: Use FloatKind.Descriptor instead.

func (FloatKind) Number added in v0.1.4 

func (x FloatKind) Number() protoreflect.EnumNumber

func (FloatKind) String added in v0.1.4 

func (x FloatKind) String() string

func (FloatKind) Type added in v0.1.4 

func (FloatKind) Type() protoreflect.EnumType

type GeodeServiceClient 

type GeodeServiceClient interface {
	Handshake(ctx context.Context, in *HelloRequest, opts ...grpc.CallOption) (*HelloResponse, error)
	Execute(ctx context.Context, in *ExecuteRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[ExecutionResponse], error)
	Ping(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*PingResponse, error)
	Begin(ctx context.Context, in *BeginRequest, opts ...grpc.CallOption) (*BeginResponse, error)
	Commit(ctx context.Context, in *CommitRequest, opts ...grpc.CallOption) (*CommitResponse, error)
	Rollback(ctx context.Context, in *RollbackRequest, opts ...grpc.CallOption) (*RollbackResponse, error)
	GetCdcDiagnostics(ctx context.Context, in *CdcDiagnosticsRequest, opts ...grpc.CallOption) (*CdcDiagnosticsResponse, error)
	ControlCdc(ctx context.Context, in *CdcControlRequest, opts ...grpc.CallOption) (*CdcControlResponse, error)
}

GeodeServiceClient is the client API for GeodeService 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.

GeodeService provides gRPC access to the Geode database.

func NewGeodeServiceClient 

func NewGeodeServiceClient(cc grpc.ClientConnInterface) GeodeServiceClient

type GeodeServiceServer 

type GeodeServiceServer interface {
	Handshake(context.Context, *HelloRequest) (*HelloResponse, error)
	Execute(*ExecuteRequest, grpc.ServerStreamingServer[ExecutionResponse]) error
	Ping(context.Context, *PingRequest) (*PingResponse, error)
	Begin(context.Context, *BeginRequest) (*BeginResponse, error)
	Commit(context.Context, *CommitRequest) (*CommitResponse, error)
	Rollback(context.Context, *RollbackRequest) (*RollbackResponse, error)
	GetCdcDiagnostics(context.Context, *CdcDiagnosticsRequest) (*CdcDiagnosticsResponse, error)
	ControlCdc(context.Context, *CdcControlRequest) (*CdcControlResponse, error)
	// contains filtered or unexported methods
}

GeodeServiceServer is the server API for GeodeService service. All implementations must embed UnimplementedGeodeServiceServer for forward compatibility.

GeodeService provides gRPC access to the Geode database.

type GeodeService_ExecuteClient 

type GeodeService_ExecuteClient = grpc.ServerStreamingClient[ExecutionResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type GeodeService_ExecuteServer 

type GeodeService_ExecuteServer = grpc.ServerStreamingServer[ExecutionResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type Heartbeat 

type Heartbeat struct {
	// contains filtered or unexported fields
}

func (*Heartbeat) Descriptor deprecated added in v0.1.4 

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

Deprecated: Use Heartbeat.ProtoReflect.Descriptor instead.

func (*Heartbeat) ProtoMessage added in v0.1.4 

func (*Heartbeat) ProtoMessage()

func (*Heartbeat) ProtoReflect added in v0.1.4 

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

func (*Heartbeat) Reset added in v0.1.4 

func (x *Heartbeat) Reset()

func (*Heartbeat) String added in v0.1.4 

func (x *Heartbeat) String() string

type HelloRequest 

type HelloRequest struct {
	Username          string  `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"`
	Password          string  `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"`
	TenantId          *string `protobuf:"bytes,3,opt,name=tenant_id,json=tenantId,proto3,oneof" json:"tenant_id,omitempty"`
	ClientName        string  `protobuf:"bytes,4,opt,name=client_name,json=clientName,proto3" json:"client_name,omitempty"`
	ClientVersion     string  `protobuf:"bytes,5,opt,name=client_version,json=clientVersion,proto3" json:"client_version,omitempty"`
	WantedConformance string  `protobuf:"bytes,6,opt,name=wanted_conformance,json=wantedConformance,proto3" json:"wanted_conformance,omitempty"`
	// contains filtered or unexported fields
}

============================================================================ Authentication (HELLO) ============================================================================

func (*HelloRequest) Descriptor deprecated added in v0.1.4 

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

Deprecated: Use HelloRequest.ProtoReflect.Descriptor instead.

func (*HelloRequest) GetClientName added in v0.1.4 

func (x *HelloRequest) GetClientName() string

func (*HelloRequest) GetClientVersion added in v0.1.4 

func (x *HelloRequest) GetClientVersion() string

func (*HelloRequest) GetPassword added in v0.1.4 

func (x *HelloRequest) GetPassword() string

func (*HelloRequest) GetTenantId added in v0.1.4 

func (x *HelloRequest) GetTenantId() string

func (*HelloRequest) GetUsername added in v0.1.4 

func (x *HelloRequest) GetUsername() string

func (*HelloRequest) GetWantedConformance added in v0.1.4 

func (x *HelloRequest) GetWantedConformance() string

func (*HelloRequest) ProtoMessage added in v0.1.4 

func (*HelloRequest) ProtoMessage()

func (*HelloRequest) ProtoReflect added in v0.1.4 

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

func (*HelloRequest) Reset added in v0.1.4 

func (x *HelloRequest) Reset()

func (*HelloRequest) String added in v0.1.4 

func (x *HelloRequest) String() string

type HelloResponse 

type HelloResponse struct {
	Success      bool     `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	SessionId    string   `protobuf:"bytes,2,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	ErrorMessage string   `protobuf:"bytes,3,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
	Capabilities []string `protobuf:"bytes,4,rep,name=capabilities,proto3" json:"capabilities,omitempty"`
	// contains filtered or unexported fields
}

func DecodeHelloResponse 

func DecodeHelloResponse(data []byte) (*HelloResponse, error)

DecodeHelloResponse decodes a protobuf-encoded HelloResponse.

func (*HelloResponse) Descriptor deprecated added in v0.1.4 

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

Deprecated: Use HelloResponse.ProtoReflect.Descriptor instead.

func (*HelloResponse) GetCapabilities added in v0.1.4 

func (x *HelloResponse) GetCapabilities() []string

func (*HelloResponse) GetErrorMessage added in v0.1.4 

func (x *HelloResponse) GetErrorMessage() string

func (*HelloResponse) GetSessionId added in v0.1.4 

func (x *HelloResponse) GetSessionId() string

func (*HelloResponse) GetSuccess added in v0.1.4 

func (x *HelloResponse) GetSuccess() bool

func (*HelloResponse) ProtoMessage added in v0.1.4 

func (*HelloResponse) ProtoMessage()

func (*HelloResponse) ProtoReflect added in v0.1.4 

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

func (*HelloResponse) Reset added in v0.1.4 

func (x *HelloResponse) Reset()

func (*HelloResponse) String added in v0.1.4 

func (x *HelloResponse) String() string

type IntKind added in v0.1.4 

type IntKind int32
const (
	IntKind_INT_KIND_UNSPECIFIED IntKind = 0
	IntKind_INT                  IntKind = 1
	IntKind_SMALLINT             IntKind = 2
	IntKind_BIGINT               IntKind = 3
)

func (IntKind) Descriptor added in v0.1.4 

func (IntKind) Descriptor() protoreflect.EnumDescriptor

func (IntKind) Enum added in v0.1.4 

func (x IntKind) Enum() *IntKind

func (IntKind) EnumDescriptor deprecated added in v0.1.4 

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

Deprecated: Use IntKind.Descriptor instead.

func (IntKind) Number added in v0.1.4 

func (x IntKind) Number() protoreflect.EnumNumber

func (IntKind) String added in v0.1.4 

func (x IntKind) String() string

func (IntKind) Type added in v0.1.4 

func (IntKind) Type() protoreflect.EnumType

type IntValue added in v0.1.4 

type IntValue struct {
	Value int64   `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"`
	Kind  IntKind `protobuf:"varint,2,opt,name=kind,proto3,enum=geode.IntKind" json:"kind,omitempty"`
	// contains filtered or unexported fields
}

func (*IntValue) Descriptor deprecated added in v0.1.4 

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

Deprecated: Use IntValue.ProtoReflect.Descriptor instead.

func (*IntValue) GetKind added in v0.1.4 

func (x *IntValue) GetKind() IntKind

func (*IntValue) GetValue added in v0.1.4 

func (x *IntValue) GetValue() int64

func (*IntValue) ProtoMessage added in v0.1.4 

func (*IntValue) ProtoMessage()

func (*IntValue) ProtoReflect added in v0.1.4 

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

func (*IntValue) Reset added in v0.1.4 

func (x *IntValue) Reset()

func (*IntValue) String added in v0.1.4 

func (x *IntValue) String() string

type ListValue added in v0.1.4 

type ListValue struct {
	Values []*Value `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*ListValue) Descriptor deprecated added in v0.1.4 

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

Deprecated: Use ListValue.ProtoReflect.Descriptor instead.

func (*ListValue) GetValues added in v0.1.4 

func (x *ListValue) GetValues() []*Value

func (*ListValue) ProtoMessage added in v0.1.4 

func (*ListValue) ProtoMessage()

func (*ListValue) ProtoReflect added in v0.1.4 

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

func (*ListValue) Reset added in v0.1.4 

func (x *ListValue) Reset()

func (*ListValue) String added in v0.1.4 

func (x *ListValue) String() string

type MapEntry added in v0.1.4 

type MapEntry struct {
	Key   string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value *Value `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*MapEntry) Descriptor deprecated added in v0.1.4 

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

Deprecated: Use MapEntry.ProtoReflect.Descriptor instead.

func (*MapEntry) GetKey added in v0.1.4 

func (x *MapEntry) GetKey() string

func (*MapEntry) GetValue added in v0.1.4 

func (x *MapEntry) GetValue() *Value

func (*MapEntry) ProtoMessage added in v0.1.4 

func (*MapEntry) ProtoMessage()

func (*MapEntry) ProtoReflect added in v0.1.4 

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

func (*MapEntry) Reset added in v0.1.4 

func (x *MapEntry) Reset()

func (*MapEntry) String added in v0.1.4 

func (x *MapEntry) String() string

type MapValue added in v0.1.4 

type MapValue struct {
	Entries []*MapEntry `protobuf:"bytes,1,rep,name=entries,proto3" json:"entries,omitempty"`
	// contains filtered or unexported fields
}

func (*MapValue) Descriptor deprecated added in v0.1.4 

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

Deprecated: Use MapValue.ProtoReflect.Descriptor instead.

func (*MapValue) GetEntries added in v0.1.4 

func (x *MapValue) GetEntries() []*MapEntry

func (*MapValue) ProtoMessage added in v0.1.4 

func (*MapValue) ProtoMessage()

func (*MapValue) ProtoReflect added in v0.1.4 

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

func (*MapValue) Reset added in v0.1.4 

func (x *MapValue) Reset()

func (*MapValue) String added in v0.1.4 

func (x *MapValue) String() string

type NodeValue added in v0.1.4 

type NodeValue struct {
	Id         uint64      `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Labels     []string    `protobuf:"bytes,2,rep,name=labels,proto3" json:"labels,omitempty"`
	Properties []*MapEntry `protobuf:"bytes,3,rep,name=properties,proto3" json:"properties,omitempty"`
	// contains filtered or unexported fields
}

func (*NodeValue) Descriptor deprecated added in v0.1.4 

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

Deprecated: Use NodeValue.ProtoReflect.Descriptor instead.

func (*NodeValue) GetId added in v0.1.4 

func (x *NodeValue) GetId() uint64

func (*NodeValue) GetLabels added in v0.1.4 

func (x *NodeValue) GetLabels() []string

func (*NodeValue) GetProperties added in v0.1.4 

func (x *NodeValue) GetProperties() []*MapEntry

func (*NodeValue) ProtoMessage added in v0.1.4 

func (*NodeValue) ProtoMessage()

func (*NodeValue) ProtoReflect added in v0.1.4 

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

func (*NodeValue) Reset added in v0.1.4 

func (x *NodeValue) Reset()

func (*NodeValue) String added in v0.1.4 

func (x *NodeValue) String() string

type NullValue added in v0.1.4 

type NullValue struct {
	// contains filtered or unexported fields
}

func (*NullValue) Descriptor deprecated added in v0.1.4 

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

Deprecated: Use NullValue.ProtoReflect.Descriptor instead.

func (*NullValue) ProtoMessage added in v0.1.4 

func (*NullValue) ProtoMessage()

func (*NullValue) ProtoReflect added in v0.1.4 

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

func (*NullValue) Reset added in v0.1.4 

func (x *NullValue) Reset()

func (*NullValue) String added in v0.1.4 

func (x *NullValue) String() string

type Param added in v0.1.4 

type Param struct {
	Name  string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Value *Value `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func BoolParam added in v0.1.4 

func BoolParam(name string, val bool) *Param

BoolParam creates a Param with a bool value.

func FloatParam added in v0.1.4 

func FloatParam(name string, val float64) *Param

FloatParam creates a Param with a float value.

func IntParam added in v0.1.4 

func IntParam(name string, val int64) *Param

IntParam creates a Param with an integer value.

func MakeParam added in v0.1.4 

func MakeParam(name string, val interface{}) *Param

MakeParam creates a Param with the appropriate protobuf type for the given Go value.

func NullParam added in v0.1.4 

func NullParam(name string) *Param

NullParam creates a Param with a null value.

func StringParam added in v0.1.4 

func StringParam(name, val string) *Param

StringParam creates a Param with a string value.

func (*Param) Descriptor deprecated added in v0.1.4 

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

Deprecated: Use Param.ProtoReflect.Descriptor instead.

func (*Param) GetName added in v0.1.4 

func (x *Param) GetName() string

func (*Param) GetValue added in v0.1.4 

func (x *Param) GetValue() *Value

func (*Param) ProtoMessage added in v0.1.4 

func (*Param) ProtoMessage()

func (*Param) ProtoReflect added in v0.1.4 

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

func (*Param) Reset added in v0.1.4 

func (x *Param) Reset()

func (*Param) String added in v0.1.4 

func (x *Param) String() string

type PathValue added in v0.1.4 

type PathValue struct {
	Nodes []*NodeValue `protobuf:"bytes,1,rep,name=nodes,proto3" json:"nodes,omitempty"`
	Edges []*EdgeValue `protobuf:"bytes,2,rep,name=edges,proto3" json:"edges,omitempty"`
	// contains filtered or unexported fields
}

func (*PathValue) Descriptor deprecated added in v0.1.4 

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

Deprecated: Use PathValue.ProtoReflect.Descriptor instead.

func (*PathValue) GetEdges added in v0.1.4 

func (x *PathValue) GetEdges() []*EdgeValue

func (*PathValue) GetNodes added in v0.1.4 

func (x *PathValue) GetNodes() []*NodeValue

func (*PathValue) ProtoMessage added in v0.1.4 

func (*PathValue) ProtoMessage()

func (*PathValue) ProtoReflect added in v0.1.4 

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

func (*PathValue) Reset added in v0.1.4 

func (x *PathValue) Reset()

func (*PathValue) String added in v0.1.4 

func (x *PathValue) String() string

type PingRequest 

type PingRequest struct {
	// contains filtered or unexported fields
}

============================================================================ Utilities (PING) ============================================================================

func (*PingRequest) Descriptor deprecated added in v0.1.4 

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

Deprecated: Use PingRequest.ProtoReflect.Descriptor instead.

func (*PingRequest) ProtoMessage added in v0.1.4 

func (*PingRequest) ProtoMessage()

func (*PingRequest) ProtoReflect added in v0.1.4 

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

func (*PingRequest) Reset added in v0.1.4 

func (x *PingRequest) Reset()

func (*PingRequest) String added in v0.1.4 

func (x *PingRequest) String() string

type PingResponse 

type PingResponse struct {
	Ok bool `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	// contains filtered or unexported fields
}

func DecodePingResponse 

func DecodePingResponse(data []byte) (*PingResponse, error)

DecodePingResponse decodes a protobuf-encoded PingResponse.

func (*PingResponse) Descriptor deprecated added in v0.1.4 

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

Deprecated: Use PingResponse.ProtoReflect.Descriptor instead.

func (*PingResponse) GetOk added in v0.1.4 

func (x *PingResponse) GetOk() bool

func (*PingResponse) ProtoMessage added in v0.1.4 

func (*PingResponse) ProtoMessage()

func (*PingResponse) ProtoReflect added in v0.1.4 

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

func (*PingResponse) Reset added in v0.1.4 

func (x *PingResponse) Reset()

func (*PingResponse) String added in v0.1.4 

func (x *PingResponse) String() string

type ProfileMemCurvePoint added in v0.1.4 

type ProfileMemCurvePoint struct {
	OpIndex    uint32 `protobuf:"varint,1,opt,name=op_index,json=opIndex,proto3" json:"op_index,omitempty"`
	NetAfterOp uint64 `protobuf:"varint,2,opt,name=net_after_op,json=netAfterOp,proto3" json:"net_after_op,omitempty"`
	// contains filtered or unexported fields
}

func (*ProfileMemCurvePoint) Descriptor deprecated added in v0.1.4 

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

Deprecated: Use ProfileMemCurvePoint.ProtoReflect.Descriptor instead.

func (*ProfileMemCurvePoint) GetNetAfterOp added in v0.1.4 

func (x *ProfileMemCurvePoint) GetNetAfterOp() uint64

func (*ProfileMemCurvePoint) GetOpIndex added in v0.1.4 

func (x *ProfileMemCurvePoint) GetOpIndex() uint32

func (*ProfileMemCurvePoint) ProtoMessage added in v0.1.4 

func (*ProfileMemCurvePoint) ProtoMessage()

func (*ProfileMemCurvePoint) ProtoReflect added in v0.1.4 

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

func (*ProfileMemCurvePoint) Reset added in v0.1.4 

func (x *ProfileMemCurvePoint) Reset()

func (*ProfileMemCurvePoint) String added in v0.1.4 

func (x *ProfileMemCurvePoint) String() string

type ProfileMemory added in v0.1.4 

type ProfileMemory struct {
	NetBytes        uint64 `protobuf:"varint,1,opt,name=net_bytes,json=netBytes,proto3" json:"net_bytes,omitempty"`
	PeakBytes       uint64 `protobuf:"varint,2,opt,name=peak_bytes,json=peakBytes,proto3" json:"peak_bytes,omitempty"`
	TotalAllocBytes uint64 `protobuf:"varint,3,opt,name=total_alloc_bytes,json=totalAllocBytes,proto3" json:"total_alloc_bytes,omitempty"`
	// contains filtered or unexported fields
}

func (*ProfileMemory) Descriptor deprecated added in v0.1.4 

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

Deprecated: Use ProfileMemory.ProtoReflect.Descriptor instead.

func (*ProfileMemory) GetNetBytes added in v0.1.4 

func (x *ProfileMemory) GetNetBytes() uint64

func (*ProfileMemory) GetPeakBytes added in v0.1.4 

func (x *ProfileMemory) GetPeakBytes() uint64

func (*ProfileMemory) GetTotalAllocBytes added in v0.1.4 

func (x *ProfileMemory) GetTotalAllocBytes() uint64

func (*ProfileMemory) ProtoMessage added in v0.1.4 

func (*ProfileMemory) ProtoMessage()

func (*ProfileMemory) ProtoReflect added in v0.1.4 

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

func (*ProfileMemory) Reset added in v0.1.4 

func (x *ProfileMemory) Reset()

func (*ProfileMemory) String added in v0.1.4 

func (x *ProfileMemory) String() string

type ProfileOp added in v0.1.4 

type ProfileOp struct {
	Op               string  `protobuf:"bytes,1,opt,name=op,proto3" json:"op,omitempty"`
	Phase            string  `protobuf:"bytes,2,opt,name=phase,proto3" json:"phase,omitempty"`
	Id               uint32  `protobuf:"varint,3,opt,name=id,proto3" json:"id,omitempty"`
	OpIndex          uint32  `protobuf:"varint,4,opt,name=op_index,json=opIndex,proto3" json:"op_index,omitempty"`
	InputRows        uint64  `protobuf:"varint,5,opt,name=input_rows,json=inputRows,proto3" json:"input_rows,omitempty"`
	Rows             uint64  `protobuf:"varint,6,opt,name=rows,proto3" json:"rows,omitempty"`
	TimeNs           uint64  `protobuf:"varint,7,opt,name=time_ns,json=timeNs,proto3" json:"time_ns,omitempty"`
	CpuTimeNs        uint64  `protobuf:"varint,8,opt,name=cpu_time_ns,json=cpuTimeNs,proto3" json:"cpu_time_ns,omitempty"`
	BytesOut         uint64  `protobuf:"varint,9,opt,name=bytes_out,json=bytesOut,proto3" json:"bytes_out,omitempty"`
	BytesAlloc       uint64  `protobuf:"varint,10,opt,name=bytes_alloc,json=bytesAlloc,proto3" json:"bytes_alloc,omitempty"`
	EstimateBytes    uint64  `protobuf:"varint,11,opt,name=estimate_bytes,json=estimateBytes,proto3" json:"estimate_bytes,omitempty"`
	EstimateVsActual uint64  `protobuf:"varint,12,opt,name=estimate_vs_actual,json=estimateVsActual,proto3" json:"estimate_vs_actual,omitempty"`
	PercentPeak      uint64  `protobuf:"varint,13,opt,name=percent_peak,json=percentPeak,proto3" json:"percent_peak,omitempty"`
	PercentNet       uint64  `protobuf:"varint,14,opt,name=percent_net,json=percentNet,proto3" json:"percent_net,omitempty"`
	CumulativeTimeNs uint64  `protobuf:"varint,15,opt,name=cumulative_time_ns,json=cumulativeTimeNs,proto3" json:"cumulative_time_ns,omitempty"`
	FreedBytes       uint64  `protobuf:"varint,16,opt,name=freed_bytes,json=freedBytes,proto3" json:"freed_bytes,omitempty"`
	NetAfterOp       uint64  `protobuf:"varint,17,opt,name=net_after_op,json=netAfterOp,proto3" json:"net_after_op,omitempty"`
	ErrorBytes       uint64  `protobuf:"varint,18,opt,name=error_bytes,json=errorBytes,proto3" json:"error_bytes,omitempty"`
	ErrorAbsPct      uint64  `protobuf:"varint,19,opt,name=error_abs_pct,json=errorAbsPct,proto3" json:"error_abs_pct,omitempty"`
	IndexName        string  `protobuf:"bytes,20,opt,name=index_name,json=indexName,proto3" json:"index_name,omitempty"`
	SelectivityEst   float64 `protobuf:"fixed64,21,opt,name=selectivity_est,json=selectivityEst,proto3" json:"selectivity_est,omitempty"`
	// contains filtered or unexported fields
}

func (*ProfileOp) Descriptor deprecated added in v0.1.4 

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

Deprecated: Use ProfileOp.ProtoReflect.Descriptor instead.

func (*ProfileOp) GetBytesAlloc added in v0.1.4 

func (x *ProfileOp) GetBytesAlloc() uint64

func (*ProfileOp) GetBytesOut added in v0.1.4 

func (x *ProfileOp) GetBytesOut() uint64

func (*ProfileOp) GetCpuTimeNs added in v0.1.4 

func (x *ProfileOp) GetCpuTimeNs() uint64

func (*ProfileOp) GetCumulativeTimeNs added in v0.1.4 

func (x *ProfileOp) GetCumulativeTimeNs() uint64

func (*ProfileOp) GetErrorAbsPct added in v0.1.4 

func (x *ProfileOp) GetErrorAbsPct() uint64

func (*ProfileOp) GetErrorBytes added in v0.1.4 

func (x *ProfileOp) GetErrorBytes() uint64

func (*ProfileOp) GetEstimateBytes added in v0.1.4 

func (x *ProfileOp) GetEstimateBytes() uint64

func (*ProfileOp) GetEstimateVsActual added in v0.1.4 

func (x *ProfileOp) GetEstimateVsActual() uint64

func (*ProfileOp) GetFreedBytes added in v0.1.4 

func (x *ProfileOp) GetFreedBytes() uint64

func (*ProfileOp) GetId added in v0.1.4 

func (x *ProfileOp) GetId() uint32

func (*ProfileOp) GetIndexName added in v0.1.4 

func (x *ProfileOp) GetIndexName() string

func (*ProfileOp) GetInputRows added in v0.1.4 

func (x *ProfileOp) GetInputRows() uint64

func (*ProfileOp) GetNetAfterOp added in v0.1.4 

func (x *ProfileOp) GetNetAfterOp() uint64

func (*ProfileOp) GetOp added in v0.1.4 

func (x *ProfileOp) GetOp() string

func (*ProfileOp) GetOpIndex added in v0.1.4 

func (x *ProfileOp) GetOpIndex() uint32

func (*ProfileOp) GetPercentNet added in v0.1.4 

func (x *ProfileOp) GetPercentNet() uint64

func (*ProfileOp) GetPercentPeak added in v0.1.4 

func (x *ProfileOp) GetPercentPeak() uint64

func (*ProfileOp) GetPhase added in v0.1.4 

func (x *ProfileOp) GetPhase() string

func (*ProfileOp) GetRows added in v0.1.4 

func (x *ProfileOp) GetRows() uint64

func (*ProfileOp) GetSelectivityEst added in v0.1.4 

func (x *ProfileOp) GetSelectivityEst() float64

func (*ProfileOp) GetTimeNs added in v0.1.4 

func (x *ProfileOp) GetTimeNs() uint64

func (*ProfileOp) ProtoMessage added in v0.1.4 

func (*ProfileOp) ProtoMessage()

func (*ProfileOp) ProtoReflect added in v0.1.4 

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

func (*ProfileOp) Reset added in v0.1.4 

func (x *ProfileOp) Reset()

func (*ProfileOp) String added in v0.1.4 

func (x *ProfileOp) String() string

type ProfilePayload added in v0.1.4 

type ProfilePayload struct {
	ProfileVersion     uint32                    `protobuf:"varint,1,opt,name=profile_version,json=profileVersion,proto3" json:"profile_version,omitempty"`
	Ops                []*ProfileOp              `protobuf:"bytes,2,rep,name=ops,proto3" json:"ops,omitempty"`
	PeakContributors   []*ProfilePeakContributor `protobuf:"bytes,3,rep,name=peak_contributors,json=peakContributors,proto3" json:"peak_contributors,omitempty"`
	Totals             *ProfileTotals            `protobuf:"bytes,4,opt,name=totals,proto3" json:"totals,omitempty"`
	TotalTimeNs        uint64                    `protobuf:"varint,5,opt,name=total_time_ns,json=totalTimeNs,proto3" json:"total_time_ns,omitempty"`
	Spills             *ProfileSpills            `protobuf:"bytes,6,opt,name=spills,proto3" json:"spills,omitempty"`
	Memory             *ProfileMemory            `protobuf:"bytes,7,opt,name=memory,proto3" json:"memory,omitempty"`
	PlannerEstimates   *ProfilePlannerEstimates  `protobuf:"bytes,8,opt,name=planner_estimates,json=plannerEstimates,proto3" json:"planner_estimates,omitempty"`
	MemCurve           []*ProfileMemCurvePoint   `protobuf:"bytes,9,rep,name=mem_curve,json=memCurve,proto3" json:"mem_curve,omitempty"`
	Setop              *ProfileSetOp             `protobuf:"bytes,10,opt,name=setop,proto3" json:"setop,omitempty"`
	HashaggSpills      uint64                    `protobuf:"varint,11,opt,name=hashagg_spills,json=hashaggSpills,proto3" json:"hashagg_spills,omitempty"`
	HashaggSpillReason string                    `protobuf:"bytes,12,opt,name=hashagg_spill_reason,json=hashaggSpillReason,proto3" json:"hashagg_spill_reason,omitempty"`
	CommittedTxns      uint64                    `protobuf:"varint,13,opt,name=committed_txns,json=committedTxns,proto3" json:"committed_txns,omitempty"`
	GraphStoreNodes    uint64                    `protobuf:"varint,14,opt,name=graph_store_nodes,json=graphStoreNodes,proto3" json:"graph_store_nodes,omitempty"`
	GraphStoreEdges    uint64                    `protobuf:"varint,15,opt,name=graph_store_edges,json=graphStoreEdges,proto3" json:"graph_store_edges,omitempty"`
	GraphStoreDirty    bool                      `protobuf:"varint,16,opt,name=graph_store_dirty,json=graphStoreDirty,proto3" json:"graph_store_dirty,omitempty"`
	FlaggerFindings    []string                  `protobuf:"bytes,17,rep,name=flagger_findings,json=flaggerFindings,proto3" json:"flagger_findings,omitempty"`
	Compact            bool                      `protobuf:"varint,18,opt,name=compact,proto3" json:"compact,omitempty"`
	// contains filtered or unexported fields
}

func (*ProfilePayload) Descriptor deprecated added in v0.1.4 

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

Deprecated: Use ProfilePayload.ProtoReflect.Descriptor instead.

func (*ProfilePayload) GetCommittedTxns added in v0.1.4 

func (x *ProfilePayload) GetCommittedTxns() uint64

func (*ProfilePayload) GetCompact added in v0.1.4 

func (x *ProfilePayload) GetCompact() bool

func (*ProfilePayload) GetFlaggerFindings added in v0.1.4 

func (x *ProfilePayload) GetFlaggerFindings() []string

func (*ProfilePayload) GetGraphStoreDirty added in v0.1.4 

func (x *ProfilePayload) GetGraphStoreDirty() bool

func (*ProfilePayload) GetGraphStoreEdges added in v0.1.4 

func (x *ProfilePayload) GetGraphStoreEdges() uint64

func (*ProfilePayload) GetGraphStoreNodes added in v0.1.4 

func (x *ProfilePayload) GetGraphStoreNodes() uint64

func (*ProfilePayload) GetHashaggSpillReason added in v0.1.4 

func (x *ProfilePayload) GetHashaggSpillReason() string

func (*ProfilePayload) GetHashaggSpills added in v0.1.4 

func (x *ProfilePayload) GetHashaggSpills() uint64

func (*ProfilePayload) GetMemCurve added in v0.1.4 

func (x *ProfilePayload) GetMemCurve() []*ProfileMemCurvePoint

func (*ProfilePayload) GetMemory added in v0.1.4 

func (x *ProfilePayload) GetMemory() *ProfileMemory

func (*ProfilePayload) GetOps added in v0.1.4 

func (x *ProfilePayload) GetOps() []*ProfileOp

func (*ProfilePayload) GetPeakContributors added in v0.1.4 

func (x *ProfilePayload) GetPeakContributors() []*ProfilePeakContributor

func (*ProfilePayload) GetPlannerEstimates added in v0.1.4 

func (x *ProfilePayload) GetPlannerEstimates() *ProfilePlannerEstimates

func (*ProfilePayload) GetProfileVersion added in v0.1.4 

func (x *ProfilePayload) GetProfileVersion() uint32

func (*ProfilePayload) GetSetop added in v0.1.4 

func (x *ProfilePayload) GetSetop() *ProfileSetOp

func (*ProfilePayload) GetSpills added in v0.1.4 

func (x *ProfilePayload) GetSpills() *ProfileSpills

func (*ProfilePayload) GetTotalTimeNs added in v0.1.4 

func (x *ProfilePayload) GetTotalTimeNs() uint64

func (*ProfilePayload) GetTotals added in v0.1.4 

func (x *ProfilePayload) GetTotals() *ProfileTotals

func (*ProfilePayload) ProtoMessage added in v0.1.4 

func (*ProfilePayload) ProtoMessage()

func (*ProfilePayload) ProtoReflect added in v0.1.4 

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

func (*ProfilePayload) Reset added in v0.1.4 

func (x *ProfilePayload) Reset()

func (*ProfilePayload) String added in v0.1.4 

func (x *ProfilePayload) String() string

type ProfilePeakContributor added in v0.1.4 

type ProfilePeakContributor struct {
	Op         string `protobuf:"bytes,1,opt,name=op,proto3" json:"op,omitempty"`
	BytesAlloc uint64 `protobuf:"varint,2,opt,name=bytes_alloc,json=bytesAlloc,proto3" json:"bytes_alloc,omitempty"`
	// contains filtered or unexported fields
}

func (*ProfilePeakContributor) Descriptor deprecated added in v0.1.4 

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

Deprecated: Use ProfilePeakContributor.ProtoReflect.Descriptor instead.

func (*ProfilePeakContributor) GetBytesAlloc added in v0.1.4 

func (x *ProfilePeakContributor) GetBytesAlloc() uint64

func (*ProfilePeakContributor) GetOp added in v0.1.4 

func (x *ProfilePeakContributor) GetOp() string

func (*ProfilePeakContributor) ProtoMessage added in v0.1.4 

func (*ProfilePeakContributor) ProtoMessage()

func (*ProfilePeakContributor) ProtoReflect added in v0.1.4 

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

func (*ProfilePeakContributor) Reset added in v0.1.4 

func (x *ProfilePeakContributor) Reset()

func (*ProfilePeakContributor) String added in v0.1.4 

func (x *ProfilePeakContributor) String() string

type ProfilePlannerEstimates added in v0.1.4 

type ProfilePlannerEstimates struct {
	SumEstimateBytes       uint64  `protobuf:"varint,1,opt,name=sum_estimate_bytes,json=sumEstimateBytes,proto3" json:"sum_estimate_bytes,omitempty"`
	SumActualBytes         uint64  `protobuf:"varint,2,opt,name=sum_actual_bytes,json=sumActualBytes,proto3" json:"sum_actual_bytes,omitempty"`
	CountEstimatedOps      uint32  `protobuf:"varint,3,opt,name=count_estimated_ops,json=countEstimatedOps,proto3" json:"count_estimated_ops,omitempty"`
	MinErrorAbsPct         float64 `protobuf:"fixed64,4,opt,name=min_error_abs_pct,json=minErrorAbsPct,proto3" json:"min_error_abs_pct,omitempty"`
	MaxErrorAbsPct         float64 `protobuf:"fixed64,5,opt,name=max_error_abs_pct,json=maxErrorAbsPct,proto3" json:"max_error_abs_pct,omitempty"`
	MeanErrorAbsPct        float64 `protobuf:"fixed64,6,opt,name=mean_error_abs_pct,json=meanErrorAbsPct,proto3" json:"mean_error_abs_pct,omitempty"`
	MedianErrorAbsPct      float64 `protobuf:"fixed64,7,opt,name=median_error_abs_pct,json=medianErrorAbsPct,proto3" json:"median_error_abs_pct,omitempty"`
	StddevErrorAbsPct      float64 `protobuf:"fixed64,8,opt,name=stddev_error_abs_pct,json=stddevErrorAbsPct,proto3" json:"stddev_error_abs_pct,omitempty"`
	AdjustedEstimateFactor float64 `` /* 131-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ProfilePlannerEstimates) Descriptor deprecated added in v0.1.4 

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

Deprecated: Use ProfilePlannerEstimates.ProtoReflect.Descriptor instead.

func (*ProfilePlannerEstimates) GetAdjustedEstimateFactor added in v0.1.4 

func (x *ProfilePlannerEstimates) GetAdjustedEstimateFactor() float64

func (*ProfilePlannerEstimates) GetCountEstimatedOps added in v0.1.4 

func (x *ProfilePlannerEstimates) GetCountEstimatedOps() uint32

func (*ProfilePlannerEstimates) GetMaxErrorAbsPct added in v0.1.4 

func (x *ProfilePlannerEstimates) GetMaxErrorAbsPct() float64

func (*ProfilePlannerEstimates) GetMeanErrorAbsPct added in v0.1.4 

func (x *ProfilePlannerEstimates) GetMeanErrorAbsPct() float64

func (*ProfilePlannerEstimates) GetMedianErrorAbsPct added in v0.1.4 

func (x *ProfilePlannerEstimates) GetMedianErrorAbsPct() float64

func (*ProfilePlannerEstimates) GetMinErrorAbsPct added in v0.1.4 

func (x *ProfilePlannerEstimates) GetMinErrorAbsPct() float64

func (*ProfilePlannerEstimates) GetStddevErrorAbsPct added in v0.1.4 

func (x *ProfilePlannerEstimates) GetStddevErrorAbsPct() float64

func (*ProfilePlannerEstimates) GetSumActualBytes added in v0.1.4 

func (x *ProfilePlannerEstimates) GetSumActualBytes() uint64

func (*ProfilePlannerEstimates) GetSumEstimateBytes added in v0.1.4 

func (x *ProfilePlannerEstimates) GetSumEstimateBytes() uint64

func (*ProfilePlannerEstimates) ProtoMessage added in v0.1.4 

func (*ProfilePlannerEstimates) ProtoMessage()

func (*ProfilePlannerEstimates) ProtoReflect added in v0.1.4 

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

func (*ProfilePlannerEstimates) Reset added in v0.1.4 

func (x *ProfilePlannerEstimates) Reset()

func (*ProfilePlannerEstimates) String added in v0.1.4 

func (x *ProfilePlannerEstimates) String() string

type ProfileSetOp added in v0.1.4 

type ProfileSetOp struct {
	Type            string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Mode            string `protobuf:"bytes,2,opt,name=mode,proto3" json:"mode,omitempty"`
	InputRows       uint64 `protobuf:"varint,3,opt,name=input_rows,json=inputRows,proto3" json:"input_rows,omitempty"`
	OutputRows      uint64 `protobuf:"varint,4,opt,name=output_rows,json=outputRows,proto3" json:"output_rows,omitempty"`
	HashDedupSize   uint64 `protobuf:"varint,5,opt,name=hash_dedup_size,json=hashDedupSize,proto3" json:"hash_dedup_size,omitempty"`
	DistinctFillPct uint64 `protobuf:"varint,6,opt,name=distinct_fill_pct,json=distinctFillPct,proto3" json:"distinct_fill_pct,omitempty"`
	// contains filtered or unexported fields
}

func (*ProfileSetOp) Descriptor deprecated added in v0.1.4 

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

Deprecated: Use ProfileSetOp.ProtoReflect.Descriptor instead.

func (*ProfileSetOp) GetDistinctFillPct added in v0.1.4 

func (x *ProfileSetOp) GetDistinctFillPct() uint64

func (*ProfileSetOp) GetHashDedupSize added in v0.1.4 

func (x *ProfileSetOp) GetHashDedupSize() uint64

func (*ProfileSetOp) GetInputRows added in v0.1.4 

func (x *ProfileSetOp) GetInputRows() uint64

func (*ProfileSetOp) GetMode added in v0.1.4 

func (x *ProfileSetOp) GetMode() string

func (*ProfileSetOp) GetOutputRows added in v0.1.4 

func (x *ProfileSetOp) GetOutputRows() uint64

func (*ProfileSetOp) GetType added in v0.1.4 

func (x *ProfileSetOp) GetType() string

func (*ProfileSetOp) ProtoMessage added in v0.1.4 

func (*ProfileSetOp) ProtoMessage()

func (*ProfileSetOp) ProtoReflect added in v0.1.4 

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

func (*ProfileSetOp) Reset added in v0.1.4 

func (x *ProfileSetOp) Reset()

func (*ProfileSetOp) String added in v0.1.4 

func (x *ProfileSetOp) String() string

type ProfileSpills added in v0.1.4 

type ProfileSpills struct {
	SortSpills        uint64 `protobuf:"varint,1,opt,name=sort_spills,json=sortSpills,proto3" json:"sort_spills,omitempty"`
	DistinctSpills    uint64 `protobuf:"varint,2,opt,name=distinct_spills,json=distinctSpills,proto3" json:"distinct_spills,omitempty"`
	UnionSpills       uint64 `protobuf:"varint,3,opt,name=union_spills,json=unionSpills,proto3" json:"union_spills,omitempty"`
	SpillReason       string `protobuf:"bytes,4,opt,name=spill_reason,json=spillReason,proto3" json:"spill_reason,omitempty"`
	PeakBytesAtSpill  uint64 `protobuf:"varint,5,opt,name=peak_bytes_at_spill,json=peakBytesAtSpill,proto3" json:"peak_bytes_at_spill,omitempty"`
	FirstSpillOpIndex uint32 `protobuf:"varint,6,opt,name=first_spill_op_index,json=firstSpillOpIndex,proto3" json:"first_spill_op_index,omitempty"`
	// contains filtered or unexported fields
}

func (*ProfileSpills) Descriptor deprecated added in v0.1.4 

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

Deprecated: Use ProfileSpills.ProtoReflect.Descriptor instead.

func (*ProfileSpills) GetDistinctSpills added in v0.1.4 

func (x *ProfileSpills) GetDistinctSpills() uint64

func (*ProfileSpills) GetFirstSpillOpIndex added in v0.1.4 

func (x *ProfileSpills) GetFirstSpillOpIndex() uint32

func (*ProfileSpills) GetPeakBytesAtSpill added in v0.1.4 

func (x *ProfileSpills) GetPeakBytesAtSpill() uint64

func (*ProfileSpills) GetSortSpills added in v0.1.4 

func (x *ProfileSpills) GetSortSpills() uint64

func (*ProfileSpills) GetSpillReason added in v0.1.4 

func (x *ProfileSpills) GetSpillReason() string

func (*ProfileSpills) GetUnionSpills added in v0.1.4 

func (x *ProfileSpills) GetUnionSpills() uint64

func (*ProfileSpills) ProtoMessage added in v0.1.4 

func (*ProfileSpills) ProtoMessage()

func (*ProfileSpills) ProtoReflect added in v0.1.4 

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

func (*ProfileSpills) Reset added in v0.1.4 

func (x *ProfileSpills) Reset()

func (*ProfileSpills) String added in v0.1.4 

func (x *ProfileSpills) String() string

type ProfileTotals added in v0.1.4 

type ProfileTotals struct {
	TimeNs    uint64 `protobuf:"varint,1,opt,name=time_ns,json=timeNs,proto3" json:"time_ns,omitempty"`
	PeakBytes uint64 `protobuf:"varint,2,opt,name=peak_bytes,json=peakBytes,proto3" json:"peak_bytes,omitempty"`
	// contains filtered or unexported fields
}

func (*ProfileTotals) Descriptor deprecated added in v0.1.4 

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

Deprecated: Use ProfileTotals.ProtoReflect.Descriptor instead.

func (*ProfileTotals) GetPeakBytes added in v0.1.4 

func (x *ProfileTotals) GetPeakBytes() uint64

func (*ProfileTotals) GetTimeNs added in v0.1.4 

func (x *ProfileTotals) GetTimeNs() uint64

func (*ProfileTotals) ProtoMessage added in v0.1.4 

func (*ProfileTotals) ProtoMessage()

func (*ProfileTotals) ProtoReflect added in v0.1.4 

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

func (*ProfileTotals) Reset added in v0.1.4 

func (x *ProfileTotals) Reset()

func (*ProfileTotals) String added in v0.1.4 

func (x *ProfileTotals) String() string

type PullRequest added in v0.1.4 

type PullRequest struct {
	RequestId uint64 `protobuf:"varint,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	PageSize  uint32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	SessionId string `protobuf:"bytes,3,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"` // Required for gRPC; ignored for QUIC
	// contains filtered or unexported fields
}

func (*PullRequest) Descriptor deprecated added in v0.1.4 

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

Deprecated: Use PullRequest.ProtoReflect.Descriptor instead.

func (*PullRequest) GetPageSize added in v0.1.4 

func (x *PullRequest) GetPageSize() uint32

func (*PullRequest) GetRequestId added in v0.1.4 

func (x *PullRequest) GetRequestId() uint64

func (*PullRequest) GetSessionId added in v0.1.4 

func (x *PullRequest) GetSessionId() string

func (*PullRequest) ProtoMessage added in v0.1.4 

func (*PullRequest) ProtoMessage()

func (*PullRequest) ProtoReflect added in v0.1.4 

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

func (*PullRequest) Reset added in v0.1.4 

func (x *PullRequest) Reset()

func (*PullRequest) String added in v0.1.4 

func (x *PullRequest) String() string

type PullResponse added in v0.1.4 

type PullResponse struct {
	Response *ExecutionResponse `protobuf:"bytes,1,opt,name=response,proto3" json:"response,omitempty"`
	// contains filtered or unexported fields
}

func (*PullResponse) Descriptor deprecated added in v0.1.4 

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

Deprecated: Use PullResponse.ProtoReflect.Descriptor instead.

func (*PullResponse) GetResponse added in v0.1.4 

func (x *PullResponse) GetResponse() *ExecutionResponse

func (*PullResponse) ProtoMessage added in v0.1.4 

func (*PullResponse) ProtoMessage()

func (*PullResponse) ProtoReflect added in v0.1.4 

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

func (*PullResponse) Reset added in v0.1.4 

func (x *PullResponse) Reset()

func (*PullResponse) String added in v0.1.4 

func (x *PullResponse) String() string

type QuicClientMessage 

type QuicClientMessage struct {

	// Types that are valid to be assigned to Msg:
	//
	//	*QuicClientMessage_Hello
	//	*QuicClientMessage_Execute
	//	*QuicClientMessage_Pull
	//	*QuicClientMessage_Ping
	//	*QuicClientMessage_CdcDiag
	//	*QuicClientMessage_CdcCtrl
	//	*QuicClientMessage_Begin
	//	*QuicClientMessage_Commit
	//	*QuicClientMessage_Rollback
	//	*QuicClientMessage_Savepoint
	//	*QuicClientMessage_RollbackTo
	//	*QuicClientMessage_Backup
	//	*QuicClientMessage_Restore
	//	*QuicClientMessage_UploadBackup
	Msg isQuicClientMessage_Msg `protobuf_oneof:"msg"`
	// contains filtered or unexported fields
}

============================================================================ QUIC Messages ============================================================================

func NewBeginMessage added in v0.1.4 

func NewBeginMessage(req *BeginRequest) *QuicClientMessage

NewBeginMessage creates a QuicClientMessage with a BeginRequest.

func NewCdcCtrlMessage added in v0.1.4 

func NewCdcCtrlMessage(req *CdcControlRequest) *QuicClientMessage

NewCdcCtrlMessage creates a QuicClientMessage with a CdcControlRequest.

func NewCdcDiagMessage added in v0.1.4 

func NewCdcDiagMessage(req *CdcDiagnosticsRequest) *QuicClientMessage

NewCdcDiagMessage creates a QuicClientMessage with a CdcDiagnosticsRequest.

func NewCommitMessage added in v0.1.4 

func NewCommitMessage(req *CommitRequest) *QuicClientMessage

NewCommitMessage creates a QuicClientMessage with a CommitRequest.

func NewExecuteMessage added in v0.1.4 

func NewExecuteMessage(req *ExecuteRequest) *QuicClientMessage

NewExecuteMessage creates a QuicClientMessage with an ExecuteRequest.

func NewHelloMessage added in v0.1.4 

func NewHelloMessage(req *HelloRequest) *QuicClientMessage

NewHelloMessage creates a QuicClientMessage with a HelloRequest.

func NewPingMessage added in v0.1.4 

func NewPingMessage(req *PingRequest) *QuicClientMessage

NewPingMessage creates a QuicClientMessage with a PingRequest.

func NewPullMessage added in v0.1.8 

func NewPullMessage(req *PullRequest) *QuicClientMessage

NewPullMessage creates a QuicClientMessage with a PullRequest.

func NewRollbackMessage added in v0.1.4 

func NewRollbackMessage(req *RollbackRequest) *QuicClientMessage

NewRollbackMessage creates a QuicClientMessage with a RollbackRequest.

func (*QuicClientMessage) Descriptor deprecated added in v0.1.4 

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

Deprecated: Use QuicClientMessage.ProtoReflect.Descriptor instead.

func (*QuicClientMessage) Encode 

func (x *QuicClientMessage) Encode() ([]byte, error)

Encode serializes a QuicClientMessage using standard protobuf marshaling.

func (*QuicClientMessage) GetBackup added in v0.1.4 

func (x *QuicClientMessage) GetBackup() *BackupRequest

func (*QuicClientMessage) GetBegin added in v0.1.4 

func (x *QuicClientMessage) GetBegin() *BeginRequest

func (*QuicClientMessage) GetCdcCtrl added in v0.1.4 

func (x *QuicClientMessage) GetCdcCtrl() *CdcControlRequest

func (*QuicClientMessage) GetCdcDiag added in v0.1.4 

func (x *QuicClientMessage) GetCdcDiag() *CdcDiagnosticsRequest

func (*QuicClientMessage) GetCommit added in v0.1.4 

func (x *QuicClientMessage) GetCommit() *CommitRequest

func (*QuicClientMessage) GetExecute added in v0.1.4 

func (x *QuicClientMessage) GetExecute() *ExecuteRequest

func (*QuicClientMessage) GetHello added in v0.1.4 

func (x *QuicClientMessage) GetHello() *HelloRequest

func (*QuicClientMessage) GetMsg added in v0.1.4 

func (x *QuicClientMessage) GetMsg() isQuicClientMessage_Msg

func (*QuicClientMessage) GetPing added in v0.1.4 

func (x *QuicClientMessage) GetPing() *PingRequest

func (*QuicClientMessage) GetPull added in v0.1.4 

func (x *QuicClientMessage) GetPull() *PullRequest

func (*QuicClientMessage) GetRestore added in v0.1.4 

func (x *QuicClientMessage) GetRestore() *RestoreRequest

func (*QuicClientMessage) GetRollback added in v0.1.4 

func (x *QuicClientMessage) GetRollback() *RollbackRequest

func (*QuicClientMessage) GetRollbackTo added in v0.1.4 

func (x *QuicClientMessage) GetRollbackTo() *RollbackToRequest

func (*QuicClientMessage) GetSavepoint added in v0.1.4 

func (x *QuicClientMessage) GetSavepoint() *SavepointRequest

func (*QuicClientMessage) GetUploadBackup added in v0.1.4 

func (x *QuicClientMessage) GetUploadBackup() *UploadBackupRequest

func (*QuicClientMessage) ProtoMessage added in v0.1.4 

func (*QuicClientMessage) ProtoMessage()

func (*QuicClientMessage) ProtoReflect added in v0.1.4 

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

func (*QuicClientMessage) Reset added in v0.1.4 

func (x *QuicClientMessage) Reset()

func (*QuicClientMessage) String added in v0.1.4 

func (x *QuicClientMessage) String() string

type QuicClientMessage_Backup added in v0.1.4 

type QuicClientMessage_Backup struct {
	Backup *BackupRequest `protobuf:"bytes,12,opt,name=backup,proto3,oneof"`
}

type QuicClientMessage_Begin added in v0.1.4 

type QuicClientMessage_Begin struct {
	Begin *BeginRequest `protobuf:"bytes,7,opt,name=begin,proto3,oneof"`
}

type QuicClientMessage_CdcCtrl added in v0.1.4 

type QuicClientMessage_CdcCtrl struct {
	CdcCtrl *CdcControlRequest `protobuf:"bytes,6,opt,name=cdc_ctrl,json=cdcCtrl,proto3,oneof"`
}

type QuicClientMessage_CdcDiag added in v0.1.4 

type QuicClientMessage_CdcDiag struct {
	CdcDiag *CdcDiagnosticsRequest `protobuf:"bytes,5,opt,name=cdc_diag,json=cdcDiag,proto3,oneof"`
}

type QuicClientMessage_Commit added in v0.1.4 

type QuicClientMessage_Commit struct {
	Commit *CommitRequest `protobuf:"bytes,8,opt,name=commit,proto3,oneof"`
}

type QuicClientMessage_Execute added in v0.1.4 

type QuicClientMessage_Execute struct {
	Execute *ExecuteRequest `protobuf:"bytes,2,opt,name=execute,proto3,oneof"`
}

type QuicClientMessage_Hello added in v0.1.4 

type QuicClientMessage_Hello struct {
	Hello *HelloRequest `protobuf:"bytes,1,opt,name=hello,proto3,oneof"`
}

type QuicClientMessage_Ping added in v0.1.4 

type QuicClientMessage_Ping struct {
	Ping *PingRequest `protobuf:"bytes,4,opt,name=ping,proto3,oneof"`
}

type QuicClientMessage_Pull added in v0.1.4 

type QuicClientMessage_Pull struct {
	Pull *PullRequest `protobuf:"bytes,3,opt,name=pull,proto3,oneof"`
}

type QuicClientMessage_Restore added in v0.1.4 

type QuicClientMessage_Restore struct {
	Restore *RestoreRequest `protobuf:"bytes,13,opt,name=restore,proto3,oneof"`
}

type QuicClientMessage_Rollback added in v0.1.4 

type QuicClientMessage_Rollback struct {
	Rollback *RollbackRequest `protobuf:"bytes,9,opt,name=rollback,proto3,oneof"`
}

type QuicClientMessage_RollbackTo added in v0.1.4 

type QuicClientMessage_RollbackTo struct {
	RollbackTo *RollbackToRequest `protobuf:"bytes,11,opt,name=rollback_to,json=rollbackTo,proto3,oneof"`
}

type QuicClientMessage_Savepoint added in v0.1.4 

type QuicClientMessage_Savepoint struct {
	Savepoint *SavepointRequest `protobuf:"bytes,10,opt,name=savepoint,proto3,oneof"`
}

type QuicClientMessage_UploadBackup added in v0.1.4 

type QuicClientMessage_UploadBackup struct {
	UploadBackup *UploadBackupRequest `protobuf:"bytes,14,opt,name=upload_backup,json=uploadBackup,proto3,oneof"`
}

type QuicServerMessage 

type QuicServerMessage struct {

	// Types that are valid to be assigned to Msg:
	//
	//	*QuicServerMessage_Hello
	//	*QuicServerMessage_Execute
	//	*QuicServerMessage_Pull
	//	*QuicServerMessage_Ping
	//	*QuicServerMessage_CdcDiag
	//	*QuicServerMessage_CdcCtrl
	//	*QuicServerMessage_Begin
	//	*QuicServerMessage_Commit
	//	*QuicServerMessage_Rollback
	//	*QuicServerMessage_Savepoint
	//	*QuicServerMessage_RollbackTo
	//	*QuicServerMessage_Backup
	//	*QuicServerMessage_Restore
	//	*QuicServerMessage_UploadBackup
	Msg isQuicServerMessage_Msg `protobuf_oneof:"msg"`
	// contains filtered or unexported fields
}

func DecodeQuicServerMessage 

func DecodeQuicServerMessage(data []byte) (*QuicServerMessage, error)

DecodeQuicServerMessage decodes a protobuf-encoded QuicServerMessage.

func (*QuicServerMessage) Descriptor deprecated added in v0.1.4 

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

Deprecated: Use QuicServerMessage.ProtoReflect.Descriptor instead.

func (*QuicServerMessage) GetBackup added in v0.1.4 

func (x *QuicServerMessage) GetBackup() *BackupResponse

func (*QuicServerMessage) GetBegin added in v0.1.4 

func (x *QuicServerMessage) GetBegin() *BeginResponse

func (*QuicServerMessage) GetBeginResp added in v0.1.4 

func (x *QuicServerMessage) GetBeginResp() *BeginResponse

GetBeginResp returns the BeginResponse if this is a begin message, or nil.

func (*QuicServerMessage) GetCdcCtrl added in v0.1.4 

func (x *QuicServerMessage) GetCdcCtrl() *CdcControlResponse

func (*QuicServerMessage) GetCdcDiag added in v0.1.4 

func (x *QuicServerMessage) GetCdcDiag() *CdcDiagnosticsResponse

func (*QuicServerMessage) GetCommit added in v0.1.4 

func (x *QuicServerMessage) GetCommit() *CommitResponse

func (*QuicServerMessage) GetCommitResp added in v0.1.4 

func (x *QuicServerMessage) GetCommitResp() *CommitResponse

GetCommitResp returns the CommitResponse if this is a commit message, or nil.

func (*QuicServerMessage) GetExecute added in v0.1.4 

func (x *QuicServerMessage) GetExecute() *ExecutionResponse

func (*QuicServerMessage) GetExecuteResponse added in v0.1.4 

func (x *QuicServerMessage) GetExecuteResponse() *ExecutionResponse

GetExecuteResponse returns the ExecutionResponse if this is an execute message, or nil.

func (*QuicServerMessage) GetHello added in v0.1.4 

func (x *QuicServerMessage) GetHello() *HelloResponse

func (*QuicServerMessage) GetHelloResponse added in v0.1.4 

func (x *QuicServerMessage) GetHelloResponse() *HelloResponse

GetHelloResponse returns the HelloResponse if this is a hello message, or nil.

func (*QuicServerMessage) GetMsg added in v0.1.4 

func (x *QuicServerMessage) GetMsg() isQuicServerMessage_Msg

func (*QuicServerMessage) GetPing added in v0.1.4 

func (x *QuicServerMessage) GetPing() *PingResponse

func (*QuicServerMessage) GetPingResp added in v0.1.4 

func (x *QuicServerMessage) GetPingResp() *PingResponse

GetPingResp returns the PingResponse if this is a ping message, or nil.

func (*QuicServerMessage) GetPull added in v0.1.4 

func (x *QuicServerMessage) GetPull() *PullResponse

func (*QuicServerMessage) GetRestore added in v0.1.4 

func (x *QuicServerMessage) GetRestore() *RestoreResponse

func (*QuicServerMessage) GetRollback added in v0.1.4 

func (x *QuicServerMessage) GetRollback() *RollbackResponse

func (*QuicServerMessage) GetRollbackResp added in v0.1.4 

func (x *QuicServerMessage) GetRollbackResp() *RollbackResponse

GetRollbackResp returns the RollbackResponse if this is a rollback message, or nil.

func (*QuicServerMessage) GetRollbackTo added in v0.1.4 

func (x *QuicServerMessage) GetRollbackTo() *RollbackToResponse

func (*QuicServerMessage) GetSavepoint added in v0.1.4 

func (x *QuicServerMessage) GetSavepoint() *SavepointResponse

func (*QuicServerMessage) GetUploadBackup added in v0.1.4 

func (x *QuicServerMessage) GetUploadBackup() *UploadBackupResponse

func (*QuicServerMessage) ProtoMessage added in v0.1.4 

func (*QuicServerMessage) ProtoMessage()

func (*QuicServerMessage) ProtoReflect added in v0.1.4 

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

func (*QuicServerMessage) Reset added in v0.1.4 

func (x *QuicServerMessage) Reset()

func (*QuicServerMessage) String added in v0.1.4 

func (x *QuicServerMessage) String() string

type QuicServerMessage_Backup added in v0.1.4 

type QuicServerMessage_Backup struct {
	Backup *BackupResponse `protobuf:"bytes,12,opt,name=backup,proto3,oneof"`
}

type QuicServerMessage_Begin added in v0.1.4 

type QuicServerMessage_Begin struct {
	Begin *BeginResponse `protobuf:"bytes,7,opt,name=begin,proto3,oneof"`
}

type QuicServerMessage_CdcCtrl added in v0.1.4 

type QuicServerMessage_CdcCtrl struct {
	CdcCtrl *CdcControlResponse `protobuf:"bytes,6,opt,name=cdc_ctrl,json=cdcCtrl,proto3,oneof"`
}

type QuicServerMessage_CdcDiag added in v0.1.4 

type QuicServerMessage_CdcDiag struct {
	CdcDiag *CdcDiagnosticsResponse `protobuf:"bytes,5,opt,name=cdc_diag,json=cdcDiag,proto3,oneof"`
}

type QuicServerMessage_Commit added in v0.1.4 

type QuicServerMessage_Commit struct {
	Commit *CommitResponse `protobuf:"bytes,8,opt,name=commit,proto3,oneof"`
}

type QuicServerMessage_Execute added in v0.1.4 

type QuicServerMessage_Execute struct {
	Execute *ExecutionResponse `protobuf:"bytes,2,opt,name=execute,proto3,oneof"`
}

type QuicServerMessage_Hello added in v0.1.4 

type QuicServerMessage_Hello struct {
	Hello *HelloResponse `protobuf:"bytes,1,opt,name=hello,proto3,oneof"`
}

type QuicServerMessage_Ping added in v0.1.4 

type QuicServerMessage_Ping struct {
	Ping *PingResponse `protobuf:"bytes,4,opt,name=ping,proto3,oneof"`
}

type QuicServerMessage_Pull added in v0.1.4 

type QuicServerMessage_Pull struct {
	Pull *PullResponse `protobuf:"bytes,3,opt,name=pull,proto3,oneof"`
}

type QuicServerMessage_Restore added in v0.1.4 

type QuicServerMessage_Restore struct {
	Restore *RestoreResponse `protobuf:"bytes,13,opt,name=restore,proto3,oneof"`
}

type QuicServerMessage_Rollback added in v0.1.4 

type QuicServerMessage_Rollback struct {
	Rollback *RollbackResponse `protobuf:"bytes,9,opt,name=rollback,proto3,oneof"`
}

type QuicServerMessage_RollbackTo added in v0.1.4 

type QuicServerMessage_RollbackTo struct {
	RollbackTo *RollbackToResponse `protobuf:"bytes,11,opt,name=rollback_to,json=rollbackTo,proto3,oneof"`
}

type QuicServerMessage_Savepoint added in v0.1.4 

type QuicServerMessage_Savepoint struct {
	Savepoint *SavepointResponse `protobuf:"bytes,10,opt,name=savepoint,proto3,oneof"`
}

type QuicServerMessage_UploadBackup added in v0.1.4 

type QuicServerMessage_UploadBackup struct {
	UploadBackup *UploadBackupResponse `protobuf:"bytes,14,opt,name=upload_backup,json=uploadBackup,proto3,oneof"`
}

type RestoreRequest added in v0.1.4 

type RestoreRequest struct {
	TargetTime string `protobuf:"bytes,1,opt,name=target_time,json=targetTime,proto3" json:"target_time,omitempty"`
	Confirm    bool   `protobuf:"varint,2,opt,name=confirm,proto3" json:"confirm,omitempty"`
	// contains filtered or unexported fields
}

func (*RestoreRequest) Descriptor deprecated added in v0.1.4 

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

Deprecated: Use RestoreRequest.ProtoReflect.Descriptor instead.

func (*RestoreRequest) GetConfirm added in v0.1.4 

func (x *RestoreRequest) GetConfirm() bool

func (*RestoreRequest) GetTargetTime added in v0.1.4 

func (x *RestoreRequest) GetTargetTime() string

func (*RestoreRequest) ProtoMessage added in v0.1.4 

func (*RestoreRequest) ProtoMessage()

func (*RestoreRequest) ProtoReflect added in v0.1.4 

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

func (*RestoreRequest) Reset added in v0.1.4 

func (x *RestoreRequest) Reset()

func (*RestoreRequest) String added in v0.1.4 

func (x *RestoreRequest) String() string

type RestoreResponse added in v0.1.4 

type RestoreResponse struct {
	Success          bool   `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Message          string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	RestoreDir       string `protobuf:"bytes,3,opt,name=restore_dir,json=restoreDir,proto3" json:"restore_dir,omitempty"`
	TargetTime       string `protobuf:"bytes,4,opt,name=target_time,json=targetTime,proto3" json:"target_time,omitempty"`
	RestoreTimestamp uint64 `protobuf:"varint,5,opt,name=restore_timestamp,json=restoreTimestamp,proto3" json:"restore_timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*RestoreResponse) Descriptor deprecated added in v0.1.4 

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

Deprecated: Use RestoreResponse.ProtoReflect.Descriptor instead.

func (*RestoreResponse) GetMessage added in v0.1.4 

func (x *RestoreResponse) GetMessage() string

func (*RestoreResponse) GetRestoreDir added in v0.1.4 

func (x *RestoreResponse) GetRestoreDir() string

func (*RestoreResponse) GetRestoreTimestamp added in v0.1.4 

func (x *RestoreResponse) GetRestoreTimestamp() uint64

func (*RestoreResponse) GetSuccess added in v0.1.4 

func (x *RestoreResponse) GetSuccess() bool

func (*RestoreResponse) GetTargetTime added in v0.1.4 

func (x *RestoreResponse) GetTargetTime() string

func (*RestoreResponse) ProtoMessage added in v0.1.4 

func (*RestoreResponse) ProtoMessage()

func (*RestoreResponse) ProtoReflect added in v0.1.4 

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

func (*RestoreResponse) Reset added in v0.1.4 

func (x *RestoreResponse) Reset()

func (*RestoreResponse) String added in v0.1.4 

func (x *RestoreResponse) String() string

type RollbackRequest 

type RollbackRequest struct {
	SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"` // Required for gRPC; ignored for QUIC
	// contains filtered or unexported fields
}

func (*RollbackRequest) Descriptor deprecated added in v0.1.4 

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

Deprecated: Use RollbackRequest.ProtoReflect.Descriptor instead.

func (*RollbackRequest) GetSessionId added in v0.1.4 

func (x *RollbackRequest) GetSessionId() string

func (*RollbackRequest) ProtoMessage added in v0.1.4 

func (*RollbackRequest) ProtoMessage()

func (*RollbackRequest) ProtoReflect added in v0.1.4 

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

func (*RollbackRequest) Reset added in v0.1.4 

func (x *RollbackRequest) Reset()

func (*RollbackRequest) String added in v0.1.4 

func (x *RollbackRequest) String() string

type RollbackResponse 

type RollbackResponse struct {
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	// contains filtered or unexported fields
}

func DecodeRollbackResponse 

func DecodeRollbackResponse(data []byte) (*RollbackResponse, error)

DecodeRollbackResponse decodes a protobuf-encoded RollbackResponse.

func (*RollbackResponse) Descriptor deprecated added in v0.1.4 

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

Deprecated: Use RollbackResponse.ProtoReflect.Descriptor instead.

func (*RollbackResponse) GetSuccess added in v0.1.4 

func (x *RollbackResponse) GetSuccess() bool

func (*RollbackResponse) ProtoMessage added in v0.1.4 

func (*RollbackResponse) ProtoMessage()

func (*RollbackResponse) ProtoReflect added in v0.1.4 

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

func (*RollbackResponse) Reset added in v0.1.4 

func (x *RollbackResponse) Reset()

func (*RollbackResponse) String added in v0.1.4 

func (x *RollbackResponse) String() string

type RollbackToRequest added in v0.1.4 

type RollbackToRequest struct {
	Name      string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	SessionId string `protobuf:"bytes,2,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"` // Required for gRPC; ignored for QUIC
	// contains filtered or unexported fields
}

func (*RollbackToRequest) Descriptor deprecated added in v0.1.4 

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

Deprecated: Use RollbackToRequest.ProtoReflect.Descriptor instead.

func (*RollbackToRequest) GetName added in v0.1.4 

func (x *RollbackToRequest) GetName() string

func (*RollbackToRequest) GetSessionId added in v0.1.4 

func (x *RollbackToRequest) GetSessionId() string

func (*RollbackToRequest) ProtoMessage added in v0.1.4 

func (*RollbackToRequest) ProtoMessage()

func (*RollbackToRequest) ProtoReflect added in v0.1.4 

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

func (*RollbackToRequest) Reset added in v0.1.4 

func (x *RollbackToRequest) Reset()

func (*RollbackToRequest) String added in v0.1.4 

func (x *RollbackToRequest) String() string

type RollbackToResponse added in v0.1.4 

type RollbackToResponse struct {
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	// contains filtered or unexported fields
}

func (*RollbackToResponse) Descriptor deprecated added in v0.1.4 

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

Deprecated: Use RollbackToResponse.ProtoReflect.Descriptor instead.

func (*RollbackToResponse) GetSuccess added in v0.1.4 

func (x *RollbackToResponse) GetSuccess() bool

func (*RollbackToResponse) ProtoMessage added in v0.1.4 

func (*RollbackToResponse) ProtoMessage()

func (*RollbackToResponse) ProtoReflect added in v0.1.4 

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

func (*RollbackToResponse) Reset added in v0.1.4 

func (x *RollbackToResponse) Reset()

func (*RollbackToResponse) String added in v0.1.4 

func (x *RollbackToResponse) String() string

type Row 

type Row struct {
	Values []*Value `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*Row) Descriptor deprecated added in v0.1.4 

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

Deprecated: Use Row.ProtoReflect.Descriptor instead.

func (*Row) GetValues added in v0.1.4 

func (x *Row) GetValues() []*Value

func (*Row) ProtoMessage added in v0.1.4 

func (*Row) ProtoMessage()

func (*Row) ProtoReflect added in v0.1.4 

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

func (*Row) Reset added in v0.1.4 

func (x *Row) Reset()

func (*Row) String added in v0.1.4 

func (x *Row) String() string

type SavepointRequest added in v0.1.4 

type SavepointRequest struct {
	Name      string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	SessionId string `protobuf:"bytes,2,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"` // Required for gRPC; ignored for QUIC
	// contains filtered or unexported fields
}

func (*SavepointRequest) Descriptor deprecated added in v0.1.4 

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

Deprecated: Use SavepointRequest.ProtoReflect.Descriptor instead.

func (*SavepointRequest) GetName added in v0.1.4 

func (x *SavepointRequest) GetName() string

func (*SavepointRequest) GetSessionId added in v0.1.4 

func (x *SavepointRequest) GetSessionId() string

func (*SavepointRequest) ProtoMessage added in v0.1.4 

func (*SavepointRequest) ProtoMessage()

func (*SavepointRequest) ProtoReflect added in v0.1.4 

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

func (*SavepointRequest) Reset added in v0.1.4 

func (x *SavepointRequest) Reset()

func (*SavepointRequest) String added in v0.1.4 

func (x *SavepointRequest) String() string

type SavepointResponse added in v0.1.4 

type SavepointResponse struct {
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	// contains filtered or unexported fields
}

func (*SavepointResponse) Descriptor deprecated added in v0.1.4 

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

Deprecated: Use SavepointResponse.ProtoReflect.Descriptor instead.

func (*SavepointResponse) GetSuccess added in v0.1.4 

func (x *SavepointResponse) GetSuccess() bool

func (*SavepointResponse) ProtoMessage added in v0.1.4 

func (*SavepointResponse) ProtoMessage()

func (*SavepointResponse) ProtoReflect added in v0.1.4 

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

func (*SavepointResponse) Reset added in v0.1.4 

func (x *SavepointResponse) Reset()

func (*SavepointResponse) String added in v0.1.4 

func (x *SavepointResponse) String() string

type SchemaDefinition 

type SchemaDefinition struct {
	Columns []*ColumnDefinition `protobuf:"bytes,1,rep,name=columns,proto3" json:"columns,omitempty"`
	// contains filtered or unexported fields
}

func (*SchemaDefinition) Descriptor deprecated added in v0.1.4 

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

Deprecated: Use SchemaDefinition.ProtoReflect.Descriptor instead.

func (*SchemaDefinition) GetColumns added in v0.1.4 

func (x *SchemaDefinition) GetColumns() []*ColumnDefinition

func (*SchemaDefinition) ProtoMessage added in v0.1.4 

func (*SchemaDefinition) ProtoMessage()

func (*SchemaDefinition) ProtoReflect added in v0.1.4 

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

func (*SchemaDefinition) Reset added in v0.1.4 

func (x *SchemaDefinition) Reset()

func (*SchemaDefinition) String added in v0.1.4 

func (x *SchemaDefinition) String() string

type ServerPacket added in v0.1.4 

type ServerPacket struct {

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

func (*ServerPacket) Descriptor deprecated added in v0.1.4 

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

Deprecated: Use ServerPacket.ProtoReflect.Descriptor instead.

func (*ServerPacket) GetMsg added in v0.1.4 

func (x *ServerPacket) GetMsg() isServerPacket_Msg

func (*ServerPacket) GetQuic added in v0.1.4 

func (x *ServerPacket) GetQuic() *QuicServerMessage

func (*ServerPacket) ProtoMessage added in v0.1.4 

func (*ServerPacket) ProtoMessage()

func (*ServerPacket) ProtoReflect added in v0.1.4 

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

func (*ServerPacket) Reset added in v0.1.4 

func (x *ServerPacket) Reset()

func (*ServerPacket) String added in v0.1.4 

func (x *ServerPacket) String() string

type ServerPacket_Quic added in v0.1.4 

type ServerPacket_Quic struct {
	Quic *QuicServerMessage `protobuf:"bytes,1,opt,name=quic,proto3,oneof"`
}

type Status added in v0.1.4 

type Status struct {
	StatusClass        string   `protobuf:"bytes,1,opt,name=status_class,json=statusClass,proto3" json:"status_class,omitempty"` // e.g., "00000"
	StatusSubclass     string   `protobuf:"bytes,2,opt,name=status_subclass,json=statusSubclass,proto3" json:"status_subclass,omitempty"`
	AdditionalStatuses []string `protobuf:"bytes,3,rep,name=additional_statuses,json=additionalStatuses,proto3" json:"additional_statuses,omitempty"`
	FlaggerFindings    []string `protobuf:"bytes,4,rep,name=flagger_findings,json=flaggerFindings,proto3" json:"flagger_findings,omitempty"`
	// contains filtered or unexported fields
}

============================================================================ Execution Responses ============================================================================

func (*Status) Descriptor deprecated added in v0.1.4 

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

Deprecated: Use Status.ProtoReflect.Descriptor instead.

func (*Status) GetAdditionalStatuses added in v0.1.4 

func (x *Status) GetAdditionalStatuses() []string

func (*Status) GetFlaggerFindings added in v0.1.4 

func (x *Status) GetFlaggerFindings() []string

func (*Status) GetStatusClass added in v0.1.4 

func (x *Status) GetStatusClass() string

func (*Status) GetStatusSubclass added in v0.1.4 

func (x *Status) GetStatusSubclass() string

func (*Status) ProtoMessage added in v0.1.4 

func (*Status) ProtoMessage()

func (*Status) ProtoReflect added in v0.1.4 

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

func (*Status) Reset added in v0.1.4 

func (x *Status) Reset()

func (*Status) String added in v0.1.4 

func (x *Status) String() string

type StringKind added in v0.1.4 

type StringKind int32
const (
	StringKind_STRING_KIND_UNSPECIFIED StringKind = 0
	StringKind_STRING                  StringKind = 1
	StringKind_CHAR                    StringKind = 2
	StringKind_VARCHAR                 StringKind = 3
	StringKind_TEXT                    StringKind = 4
)

func (StringKind) Descriptor added in v0.1.4 

func (StringKind) Descriptor() protoreflect.EnumDescriptor

func (StringKind) Enum added in v0.1.4 

func (x StringKind) Enum() *StringKind

func (StringKind) EnumDescriptor deprecated added in v0.1.4 

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

Deprecated: Use StringKind.Descriptor instead.

func (StringKind) Number added in v0.1.4 

func (x StringKind) Number() protoreflect.EnumNumber

func (StringKind) String added in v0.1.4 

func (x StringKind) String() string

func (StringKind) Type added in v0.1.4 

func (StringKind) Type() protoreflect.EnumType

type StringValue added in v0.1.4 

type StringValue struct {
	Value string     `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	Kind  StringKind `protobuf:"varint,2,opt,name=kind,proto3,enum=geode.StringKind" json:"kind,omitempty"`
	// contains filtered or unexported fields
}

func (*StringValue) Descriptor deprecated added in v0.1.4 

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

Deprecated: Use StringValue.ProtoReflect.Descriptor instead.

func (*StringValue) GetKind added in v0.1.4 

func (x *StringValue) GetKind() StringKind

func (*StringValue) GetValue added in v0.1.4 

func (x *StringValue) GetValue() string

func (*StringValue) ProtoMessage added in v0.1.4 

func (*StringValue) ProtoMessage()

func (*StringValue) ProtoReflect added in v0.1.4 

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

func (*StringValue) Reset added in v0.1.4 

func (x *StringValue) Reset()

func (*StringValue) String added in v0.1.4 

func (x *StringValue) String() string

type UnimplementedGeodeServiceServer 

type UnimplementedGeodeServiceServer struct{}

UnimplementedGeodeServiceServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedGeodeServiceServer) Begin 

func (UnimplementedGeodeServiceServer) Begin(context.Context, *BeginRequest) (*BeginResponse, error)

func (UnimplementedGeodeServiceServer) Commit 

func (UnimplementedGeodeServiceServer) Commit(context.Context, *CommitRequest) (*CommitResponse, error)

func (UnimplementedGeodeServiceServer) ControlCdc 

func (UnimplementedGeodeServiceServer) ControlCdc(context.Context, *CdcControlRequest) (*CdcControlResponse, error)

func (UnimplementedGeodeServiceServer) Execute 

func (UnimplementedGeodeServiceServer) Execute(*ExecuteRequest, grpc.ServerStreamingServer[ExecutionResponse]) error

func (UnimplementedGeodeServiceServer) GetCdcDiagnostics 

func (UnimplementedGeodeServiceServer) GetCdcDiagnostics(context.Context, *CdcDiagnosticsRequest) (*CdcDiagnosticsResponse, error)

func (UnimplementedGeodeServiceServer) Handshake 

func (UnimplementedGeodeServiceServer) Handshake(context.Context, *HelloRequest) (*HelloResponse, error)

func (UnimplementedGeodeServiceServer) Ping 

func (UnimplementedGeodeServiceServer) Ping(context.Context, *PingRequest) (*PingResponse, error)

func (UnimplementedGeodeServiceServer) Rollback 

func (UnimplementedGeodeServiceServer) Rollback(context.Context, *RollbackRequest) (*RollbackResponse, error)

type UnsafeGeodeServiceServer added in v0.1.4 

type UnsafeGeodeServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeGeodeServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to GeodeServiceServer will result in compilation errors.

type UploadBackupRequest added in v0.1.4 

type UploadBackupRequest struct {
	SizeBytes uint64 `protobuf:"varint,1,opt,name=size_bytes,json=sizeBytes,proto3" json:"size_bytes,omitempty"`
	Checksum  string `protobuf:"bytes,2,opt,name=checksum,proto3" json:"checksum,omitempty"`
	// contains filtered or unexported fields
}

func (*UploadBackupRequest) Descriptor deprecated added in v0.1.4 

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

Deprecated: Use UploadBackupRequest.ProtoReflect.Descriptor instead.

func (*UploadBackupRequest) GetChecksum added in v0.1.4 

func (x *UploadBackupRequest) GetChecksum() string

func (*UploadBackupRequest) GetSizeBytes added in v0.1.4 

func (x *UploadBackupRequest) GetSizeBytes() uint64

func (*UploadBackupRequest) ProtoMessage added in v0.1.4 

func (*UploadBackupRequest) ProtoMessage()

func (*UploadBackupRequest) ProtoReflect added in v0.1.4 

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

func (*UploadBackupRequest) Reset added in v0.1.4 

func (x *UploadBackupRequest) Reset()

func (*UploadBackupRequest) String added in v0.1.4 

func (x *UploadBackupRequest) String() string

type UploadBackupResponse added in v0.1.4 

type UploadBackupResponse struct {
	Success    bool   `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Message    string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	UploadPath string `protobuf:"bytes,3,opt,name=upload_path,json=uploadPath,proto3" json:"upload_path,omitempty"`
	// contains filtered or unexported fields
}

func (*UploadBackupResponse) Descriptor deprecated added in v0.1.4 

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

Deprecated: Use UploadBackupResponse.ProtoReflect.Descriptor instead.

func (*UploadBackupResponse) GetMessage added in v0.1.4 

func (x *UploadBackupResponse) GetMessage() string

func (*UploadBackupResponse) GetSuccess added in v0.1.4 

func (x *UploadBackupResponse) GetSuccess() bool

func (*UploadBackupResponse) GetUploadPath added in v0.1.4 

func (x *UploadBackupResponse) GetUploadPath() string

func (*UploadBackupResponse) ProtoMessage added in v0.1.4 

func (*UploadBackupResponse) ProtoMessage()

func (*UploadBackupResponse) ProtoReflect added in v0.1.4 

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

func (*UploadBackupResponse) Reset added in v0.1.4 

func (x *UploadBackupResponse) Reset()

func (*UploadBackupResponse) String added in v0.1.4 

func (x *UploadBackupResponse) String() string

type Value 

type Value struct {

	// Types that are valid to be assigned to Kind:
	//
	//	*Value_NullVal
	//	*Value_IntVal
	//	*Value_DoubleVal
	//	*Value_BoolVal
	//	*Value_StringVal
	//	*Value_DecimalVal
	//	*Value_BytesVal
	//	*Value_ListVal
	//	*Value_MapVal
	//	*Value_NodeVal
	//	*Value_EdgeVal
	//	*Value_PathVal
	//	*Value_ExtVal
	Kind isValue_Kind `protobuf_oneof:"kind"`
	// contains filtered or unexported fields
}

---------------------------------------------------------------------------- Value Encoding ----------------------------------------------------------------------------

func (*Value) Descriptor deprecated added in v0.1.4 

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

Deprecated: Use Value.ProtoReflect.Descriptor instead.

func (*Value) GetBoolVal added in v0.1.4 

func (x *Value) GetBoolVal() bool

func (*Value) GetBytesVal added in v0.1.4 

func (x *Value) GetBytesVal() *BytesValue

func (*Value) GetDecimalVal added in v0.1.4 

func (x *Value) GetDecimalVal() *DecimalValue

func (*Value) GetDoubleVal added in v0.1.4 

func (x *Value) GetDoubleVal() *DoubleValue

func (*Value) GetEdgeVal added in v0.1.4 

func (x *Value) GetEdgeVal() *EdgeValue

func (*Value) GetExtVal added in v0.1.4 

func (x *Value) GetExtVal() *ExtendedValue

func (*Value) GetIntVal added in v0.1.4 

func (x *Value) GetIntVal() *IntValue

func (*Value) GetKind added in v0.1.4 

func (x *Value) GetKind() isValue_Kind

func (*Value) GetListVal added in v0.1.4 

func (x *Value) GetListVal() *ListValue

func (*Value) GetMapVal added in v0.1.4 

func (x *Value) GetMapVal() *MapValue

func (*Value) GetNodeVal added in v0.1.4 

func (x *Value) GetNodeVal() *NodeValue

func (*Value) GetNullVal added in v0.1.4 

func (x *Value) GetNullVal() *NullValue

func (*Value) GetPathVal added in v0.1.4 

func (x *Value) GetPathVal() *PathValue

func (*Value) GetStringVal added in v0.1.4 

func (x *Value) GetStringVal() *StringValue

func (*Value) ProtoMessage added in v0.1.4 

func (*Value) ProtoMessage()

func (*Value) ProtoReflect added in v0.1.4 

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

func (*Value) Reset added in v0.1.4 

func (x *Value) Reset()

func (*Value) String added in v0.1.4 

func (x *Value) String() string

type Value_BoolVal added in v0.1.4 

type Value_BoolVal struct {
	BoolVal bool `protobuf:"varint,4,opt,name=bool_val,json=boolVal,proto3,oneof"`
}

type Value_BytesVal added in v0.1.4 

type Value_BytesVal struct {
	BytesVal *BytesValue `protobuf:"bytes,7,opt,name=bytes_val,json=bytesVal,proto3,oneof"`
}

type Value_DecimalVal added in v0.1.4 

type Value_DecimalVal struct {
	DecimalVal *DecimalValue `protobuf:"bytes,6,opt,name=decimal_val,json=decimalVal,proto3,oneof"`
}

type Value_DoubleVal added in v0.1.4 

type Value_DoubleVal struct {
	DoubleVal *DoubleValue `protobuf:"bytes,3,opt,name=double_val,json=doubleVal,proto3,oneof"`
}

type Value_EdgeVal added in v0.1.4 

type Value_EdgeVal struct {
	EdgeVal *EdgeValue `protobuf:"bytes,11,opt,name=edge_val,json=edgeVal,proto3,oneof"`
}

type Value_ExtVal added in v0.1.4 

type Value_ExtVal struct {
	ExtVal *ExtendedValue `protobuf:"bytes,13,opt,name=ext_val,json=extVal,proto3,oneof"`
}

type Value_IntVal added in v0.1.4 

type Value_IntVal struct {
	IntVal *IntValue `protobuf:"bytes,2,opt,name=int_val,json=intVal,proto3,oneof"`
}

type Value_ListVal added in v0.1.4 

type Value_ListVal struct {
	ListVal *ListValue `protobuf:"bytes,8,opt,name=list_val,json=listVal,proto3,oneof"`
}

type Value_MapVal added in v0.1.4 

type Value_MapVal struct {
	MapVal *MapValue `protobuf:"bytes,9,opt,name=map_val,json=mapVal,proto3,oneof"`
}

type Value_NodeVal added in v0.1.4 

type Value_NodeVal struct {
	NodeVal *NodeValue `protobuf:"bytes,10,opt,name=node_val,json=nodeVal,proto3,oneof"`
}

type Value_NullVal added in v0.1.4 

type Value_NullVal struct {
	NullVal *NullValue `protobuf:"bytes,1,opt,name=null_val,json=nullVal,proto3,oneof"`
}

type Value_PathVal added in v0.1.4 

type Value_PathVal struct {
	PathVal *PathValue `protobuf:"bytes,12,opt,name=path_val,json=pathVal,proto3,oneof"`
}

type Value_StringVal added in v0.1.4 

type Value_StringVal struct {
	StringVal *StringValue `protobuf:"bytes,5,opt,name=string_val,json=stringVal,proto3,oneof"`
}

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.