core

type CTStream[T CtClient] struct {
	Client T
	Sleep  time.Duration
	Ctx    context.Context
	Wg     sync.WaitGroup
	// contains filtered or unexported fields
}

type CTsStream[T CtStream] struct {
	Streams []T
	Sleep   time.Duration
}

type Callback func(*ctx509.Certificate, int, any, error)

type CtClient interface {
	Init() error
	Next(callback Callback)
}

type CtStream interface {
	Init() error
	Start(Callback)
	Run(Callback)
	Stop()
	Await()
}

type LogID = int64