Versions in this module Expand all Collapse all v0 v0.3.1 Jul 6, 2025 Changes in this version + func Marshal(c *proto.Command) ([]byte, error) + func MarshalLoadChunkRequest(lr *proto.LoadChunkRequest) ([]byte, error) + func MarshalLoadRequest(lr *proto.LoadRequest) ([]byte, error) + func MarshalNoop(c *proto.Noop) ([]byte, error) + func Unmarshal(b []byte, c *proto.Command) error + func UnmarshalLoadChunkRequest(b []byte, lr *proto.LoadChunkRequest) error + func UnmarshalLoadRequest(b []byte, lr *proto.LoadRequest) error + func UnmarshalNoop(b []byte, c *proto.Noop) error + func UnmarshalSubCommand(c *proto.Command, m pb.Message) error + type ExecuteQueryRequest struct + Freshness int64 + FreshnessStrict bool + Level QueryRequest_Level + Request *Request + Timings bool + type Parameter struct + Name string + Value isParameter_Value + type QueryRequest_Level int32 + const QueryRequest_QUERY_REQUEST_LEVEL_AUTO + const QueryRequest_QUERY_REQUEST_LEVEL_NONE + const QueryRequest_QUERY_REQUEST_LEVEL_STRONG + const QueryRequest_QUERY_REQUEST_LEVEL_WEAK + type Request struct + DbTimeout int64 + Statements []*Statement + Transaction bool + type RequestMarshaler struct + BatchThreshold int + ForceCompression bool + SizeThreshold int + func NewRequestMarshaler() *RequestMarshaler + func (m *RequestMarshaler) Marshal(r Requester) ([]byte, bool, error) + func (m *RequestMarshaler) Stats() map[string]interface{} + type Requester interface + GetRequest func() *proto.Request + type Statement struct + ForceQuery bool + Parameters []*Parameter + Sql string
Go to main page