metadata

package
v0.2.2 Latest Latest
Warning

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

 Go to latest Published: Mar 20, 2025 License: MIT Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type CursorUpdater 

type CursorUpdater interface {
	GetCursor() *envelopes.Cursor
	AddSubscriber(clientID string, updateChan chan struct{})
	RemoveSubscriber(clientID string)
	Stop()
}

func NewCursorUpdater 

func NewCursorUpdater(ctx context.Context, log *zap.Logger, store *sql.DB) CursorUpdater

type DBBasedCursorUpdater 

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

func (*DBBasedCursorUpdater) AddSubscriber 

func (cu *DBBasedCursorUpdater) AddSubscriber(clientID string, updateChan chan struct{})

func (*DBBasedCursorUpdater) GetCursor 

func (cu *DBBasedCursorUpdater) GetCursor() *envelopes.Cursor

func (*DBBasedCursorUpdater) RemoveSubscriber 

func (cu *DBBasedCursorUpdater) RemoveSubscriber(clientID string)

func (*DBBasedCursorUpdater) Stop 

func (cu *DBBasedCursorUpdater) Stop()

type Service 

type Service struct {
	metadata_api.UnimplementedMetadataApiServer
	// contains filtered or unexported fields
}

func NewMetadataApiService 

func NewMetadataApiService(
	ctx context.Context,
	log *zap.Logger,
	updater CursorUpdater,
) (*Service, error)

func (*Service) GetSyncCursor 

func (s *Service) GetSyncCursor(
	_ context.Context,
	_ *metadata_api.GetSyncCursorRequest,
) (*metadata_api.GetSyncCursorResponse, error)

func (*Service) SubscribeSyncCursor 

func (s *Service) SubscribeSyncCursor(
	_ *metadata_api.GetSyncCursorRequest,
	stream metadata_api.MetadataApi_SubscribeSyncCursorServer,
) error

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.