proxy

package

Go to main page

Versions in this module

v1

v1.0.6

Feb 14, 2025

v1.0.5

Feb 10, 2025

Changes in this version

+ const ExternalHostInstanceID

+ const ExternalHostProjectID

type CassandraToSpannerConfigs

+ ReadinessCheckEndpoint string

v1.0.4

Feb 4, 2025

Changes in this version

type CassandraToSpannerConfigs

+ CaCertificate string

+ ClientCertificate string

+ ClientKey string

+ Endpoint string

+ UsePlainText bool

type Config

+ CaCertificate string

+ ClientCertificate string

+ ClientKey string

+ Endpoint string

+ UsePlainText bool

type OtelConfig

+ DisableRandomServiceInstanceIDKey bool

v1.0.3

Jan 24, 2025

v1.0.2

Jan 22, 2025

v1.0.1

Oct 30, 2024

Changes in this version

type CassandraToSpannerConfigs

+ UseRowTTL bool

+ UseRowTimestamp bool

type Config

+ UseRowTTL bool

+ UseRowTimestamp bool

v1.0.0

Oct 10, 2024

Changes in this version

+ const DefaultConfigTableName

+ const DefaultSpannerGrpcChannels

+ const DefaultSpannerMaxSession

+ const DefaultSpannerMinSession

+ const Query

+ const SpannerConnectionString

+ var ErrProxyAlreadyConnected = errors.New("proxy already connected")

+ var ErrProxyClosed = errors.New("proxy closed")

+ var ErrProxyNotConnected = errors.New("proxy not connected")

+ var NewSpannerClient = func(ctx context.Context, config Config, ot *otelgo.OpenTelemetry) iface.SpannerClientInterface

+ var TCP_BIND_PORT = "0.0.0.0:%s"

+ func NewDefaultPreparedCache(size int) (proxycore.PreparedCache, error)

+ func Run(ctx context.Context, args []string) int

+ func ValidateAndApplyDefaults(cfg *UserConfig) error

+ type CassandraToSpannerConfigs struct

+ ConfigTableName string

+ KeyspaceFlatter bool

+ ProjectID string

+ type Config struct

+ Auth proxycore.Authenticator

+ CQLVersion string

+ ConnectTimeout time.Duration

+ DC string

+ Debug bool

+ HeartBeatInterval time.Duration

+ IdleTimeout time.Duration

+ KeyspaceFlatter bool

+ Logger *zap.Logger

+ MaxVersion primitive.ProtocolVersion

+ OtelConfig *OtelConfig

+ Partitioner string

+ PreparedCache proxycore.PreparedCache

+ RPCAddr string

+ ReleaseVersion string

+ Resolver proxycore.EndpointResolver

+ RetryPolicy RetryPolicy

+ SpannerConfig SpannerConfig

+ Tokens []string

+ UserAgent string

+ Version primitive.ProtocolVersion

+ type Listener struct

+ Name string

+ Otel Otel

+ Port int

+ Spanner Spanner

+ type Operation struct

+ MaxCommitDelay uint64

+ ReplayProtection bool

+ type Otel struct

+ Disabled bool

+ type OtelConfig struct

+ Enabled bool

+ EnabledClientSideMetrics bool

+ HealthCheck struct{ ... }

+ Metrics struct{ ... }

+ ServiceName string

+ Traces struct{ ... }

+ type PeerConfig struct

+ DC string

+ RPCAddr string

+ Tokens []string

+ type PreparedQuery struct

+ PreparedColumns []string

+ Query string

+ SelectedColumns []string

+ type Proxy struct

+ func NewProxy(ctx context.Context, config Config) (*Proxy, error)

+ func (p *Proxy) Close() error

+ func (p *Proxy) Connect() error

+ func (p *Proxy) IsIdempotent(id []byte) bool

+ func (p *Proxy) MaybeStorePreparedIdempotence(raw *frame.RawFrame, msg message.Message)

+ func (p *Proxy) OnEvent(event proxycore.Event)

+ func (p *Proxy) Ready() bool

+ func (p *Proxy) Serve(l net.Listener) (err error)

+ type RetryDecision int

+ const RetryNext

+ const RetrySame

+ const ReturnError

+ func (r RetryDecision) String() string

+ type RetryPolicy interface

+ OnErrorResponse func(msg message.Error, retryCount int) RetryDecision

+ OnReadTimeout func(msg *message.ReadTimeout, retryCount int) RetryDecision

+ OnUnavailable func(msg *message.Unavailable, retryCount int) RetryDecision

+ OnWriteTimeout func(msg *message.WriteTimeout, retryCount int) RetryDecision

+ func NewDefaultRetryPolicy() RetryPolicy

+ type Sender interface

+ Send func(hdr *frame.Header, msg message.Message)

+ type Session struct

+ GrpcChannels int

+ Max uint64

+ Min uint64

+ type Spanner struct

+ ConfigTableName string

+ DatabaseID string

+ InstanceID string

+ Operation Operation

+ ProjectID string

+ Session Session

+ type SpannerClient struct

+ Client *spanner.Client

+ KeyspaceFlatter interface{}

+ Logger interface{}

+ func (sc *SpannerClient) GetClient(ctx context.Context) (*spanner.Client, error)

+ type SpannerConfig struct

+ ConfigTableName string

+ DatabaseName string

+ GCPProjectID string

+ InstanceName string

+ KeyspaceFlatter bool

+ MaxCommitDelay uint64

+ MaxSessions uint64

+ MinSessions uint64

+ NumOfChannels int

+ ReplayProtection bool

+ type UserConfig struct

+ CassandraToSpannerConfigs CassandraToSpannerConfigs

+ Listeners []Listener

+ LoggerConfig *utilities.LoggerConfig

+ Otel *OtelConfig

+ func LoadConfig(filename string) (*UserConfig, error)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL