grpc

Documentation

Index

• func FromAnypb(p *anypb.Any) any
• func NewAuthInterceptor(token string) *authInterceptor
• func ToAnypb(val any) (*anypb.Any, error)
• type DBProvider
• type DataSourceNamesFn
• type HADB
• type HistoryItem
• type ReplicationIDsFn
• type SQLExpectResultSetFn
• type Server
• type Service
  • func (s *Service) DataSourceNames(ctx context.Context, req *connect.Request[sqlv1.DataSourceNamesRequest]) (*connect.Response[sqlv1.DataSourceNamesResponse], error)
  • func (s *Service) Download(ctx context.Context, req *connect.Request[sqlv1.DownloadRequest], ...) error
  • func (s *Service) LatestSnapshot(ctx context.Context, req *connect.Request[sqlv1.LatestSnapshotRequest], ...) error
  • func (s *Service) Query(ctx context.Context, ...) error
  • func (s *Service) ReplicationIDs(ctx context.Context, req *connect.Request[sqlv1.ReplicationIDsRequest]) (*connect.Response[sqlv1.ReplicationIDsResponse], error)

Functions

func FromAnypb

func FromAnypb(p *anypb.Any) any

func NewAuthInterceptor

func NewAuthInterceptor(token string) *authInterceptor

func ToAnypb

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

Types

type DBProvider

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

type DataSourceNamesFn

type DataSourceNamesFn func() []string

type HADB

type HADB interface {
	PubSeq() uint64
	DB() *sql.DB
	LatestSnapshot(context.Context) (uint64, io.ReadCloser, error)
	Backup(context.Context, io.Writer) error
	HistoryBySeq(context.Context, uint64) ([]HistoryItem, error)
	HistoryByTime(context.Context, time.Duration) ([]HistoryItem, error)
	UndoBySeq(context.Context, uint64) error
	UndoByTime(context.Context, time.Duration) error
}

type HistoryItem

type HistoryItem struct {
	Seq       uint64   `json:"seq"`
	SQL       []string `json:"sql"`
	Timestamp int64    `json:"timestamp_ns"`
}

type ReplicationIDsFn

type ReplicationIDsFn func() []string

type SQLExpectResultSetFn

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

type Server

type Server struct {
	*http.Server
	ReferenceCount int
}

type Service

type Service struct {
	sqlv1connect.UnimplementedDatabaseServiceHandler
	DBProvider         DBProvider
	DSNList            DataSourceNamesFn
	ReplicationIDList  ReplicationIDsFn
	SQLExpectResultSet SQLExpectResultSetFn
}

func (*Service) DataSourceNames

func (s *Service) DataSourceNames(ctx context.Context, req *connect.Request[sqlv1.DataSourceNamesRequest]) (*connect.Response[sqlv1.DataSourceNamesResponse], error)

func (*Service) Download

func (s *Service) Download(ctx context.Context, req *connect.Request[sqlv1.DownloadRequest], resp *connect.ServerStream[sqlv1.DownloadResponse]) error

func (*Service) LatestSnapshot

func (s *Service) LatestSnapshot(ctx context.Context, req *connect.Request[sqlv1.LatestSnapshotRequest], resp *connect.ServerStream[sqlv1.LatestSnapshotResponse]) error

func (*Service) Query

func (s *Service) Query(ctx context.Context, stream *connect.BidiStream[sqlv1.QueryRequest, sqlv1.QueryResponse]) error

func (*Service) ReplicationIDs

func (s *Service) ReplicationIDs(ctx context.Context, req *connect.Request[sqlv1.ReplicationIDsRequest]) (*connect.Response[sqlv1.ReplicationIDsResponse], error)