sonar

Documentation

Index

• type Progress
• type Sonar
  • func NewSonar(logger *slog.Logger, cursorFile string, socketURL string) (*Sonar, error)
  • func (s *Sonar) HandleRepoCommit(ctx context.Context, evt *comatproto.SyncSubscribeRepos_Commit) error
  • func (s *Sonar) HandleStreamEvent(ctx context.Context, xe *events.XRPCStreamEvent) error
  • func (s *Sonar) ReadCursorFile() error
  • func (s *Sonar) WriteCursorFile() error

Types

type Progress

type Progress struct {
	LastSeq            int64     `json:"last_seq"`
	LastSeqProcessedAt time.Time `json:"last_seq_processed_at"`
}

type Sonar

type Sonar struct {
	SocketURL  string
	Progress   *Progress
	ProgMux    sync.Mutex
	Logger     *slog.Logger
	CursorFile string
}

func NewSonar

func NewSonar(logger *slog.Logger, cursorFile string, socketURL string) (*Sonar, error)

func (*Sonar) HandleRepoCommit

func (s *Sonar) HandleRepoCommit(ctx context.Context, evt *comatproto.SyncSubscribeRepos_Commit) error

func (*Sonar) HandleStreamEvent

func (s *Sonar) HandleStreamEvent(ctx context.Context, xe *events.XRPCStreamEvent) error

func (*Sonar) ReadCursorFile

func (s *Sonar) ReadCursorFile() error

func (*Sonar) WriteCursorFile

func (s *Sonar) WriteCursorFile() error