grpc

Jan 23, 2026

Changes in this version

+ type AuthInterceptor struct

+ func NewAuthInterceptor(token string) *AuthInterceptor

+ func (a *AuthInterceptor) Stream() grpc.StreamServerInterceptor

+ func (a *AuthInterceptor) Unary() grpc.UnaryServerInterceptor

Jan 10, 2026

Changes in this version

+ type DataSourceNamesFn func() []string

type HADB

+ LatestSnapshot func(context.Context) (uint64, io.ReadCloser, error)

+ type ReplicationIDsFn func() []string

+ type SQLExpectResultSetFn func(context.Context, string) (bool, error)

type Service

+ DSNList DataSourceNamesFn

+ ReplicationIDList ReplicationIDsFn

+ SQLExpectResultSet SQLExpectResultSetFn

+ func (s *Service) DataSourceNames(ctx context.Context, req *sqlv1.DataSourceNamesRequest) (*sqlv1.DataSourceNamesResponse, error)

+ func (s *Service) LatestSnapshot(ctx context.Context, req *sqlv1.LatestSnapshotRequest) (*sqlv1.LatestSnapshotResponse, error)

+ func (s *Service) ReplicationIDs(ctx context.Context, req *sqlv1.ReplicationIDsRequest) (*sqlv1.ReplicationIDsResponse, error)

Jan 4, 2026

Changes in this version

+ func FromAnypb(p *anypb.Any) any

+ func ToAnypb(val any) (*anypb.Any, error)

+ type DBProvider func(id string) (HADB, bool)

+ type HADB interface

+ DB func() *sql.DB

+ PubSeq func() uint64

+ type Server struct

+ ReferenceCount int

+ type Service struct

+ DBProvider DBProvider

+ func (s *Service) Query(stream grpc.BidiStreamingServer[sqlv1.QueryRequest, sqlv1.QueryResponse]) error