core

package
v0.0.27 Latest Latest
Warning

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

 Go to latest Published: Sep 10, 2024 License: MIT Imports: 4 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var DefaultMaxEntries int64 = 256

Functions

This section is empty.

Types

type CTStream 

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

func NewCTStream 

func NewCTStream[T CtClient](
	client T,
	sleep time.Duration,
	Ctx context.Context,
) (*CTStream[T], error)

func (*CTStream[T]) Await 

func (stream *CTStream[T]) Await()

func (*CTStream[T]) Init 

func (stream *CTStream[T]) Init() error

func (*CTStream[T]) Next 

func (stream *CTStream[T]) Next(callback Callback)

func (*CTStream[T]) Run 

func (stream *CTStream[T]) Run(callback Callback)

func (*CTStream[T]) Start 

func (stream *CTStream[T]) Start(callback Callback)

func (*CTStream[T]) Stop 

func (stream *CTStream[T]) Stop()

type CTsStream 

type CTsStream[T CtStream] PararellCTsStream[T]

type Callback 

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

type ConcurrentCTsStream added in v0.0.24 

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

func NewConcurrentCTsStream added in v0.0.24 

func NewConcurrentCTsStream[T CtStream](streams []T, sleep time.Duration) (*ConcurrentCTsStream[T], error)

func (ConcurrentCTsStream[T]) Await added in v0.0.24 

func (stream ConcurrentCTsStream[T]) Await()

func (*ConcurrentCTsStream[T]) Init added in v0.0.24 

func (stream *ConcurrentCTsStream[T]) Init() error

func (*ConcurrentCTsStream[T]) Next added in v0.0.24 

func (stream *ConcurrentCTsStream[T]) Next(callback Callback)

func (*ConcurrentCTsStream[T]) Run added in v0.0.24 

func (stream *ConcurrentCTsStream[T]) Run(callback Callback)

func (*ConcurrentCTsStream[T]) Start added in v0.0.24 

func (stream *ConcurrentCTsStream[T]) Start(callback Callback)

func (*ConcurrentCTsStream[T]) Stop added in v0.0.24 

func (stream *ConcurrentCTsStream[T]) Stop()

type CtClient 

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

type CtStream 

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

type LogID 

type LogID = int64

type PararellCTsStream added in v0.0.24 

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

func NewPararellCTsStream added in v0.0.24 

func NewPararellCTsStream[T CtStream](streams []T, sleep time.Duration) (*PararellCTsStream[T], error)

func (PararellCTsStream[T]) Await added in v0.0.24 

func (stream PararellCTsStream[T]) Await()

func (*PararellCTsStream[T]) Init added in v0.0.24 

func (stream *PararellCTsStream[T]) Init() error

func (*PararellCTsStream[T]) Next added in v0.0.24 

func (stream *PararellCTsStream[T]) Next(callback Callback)

func (*PararellCTsStream[T]) Run added in v0.0.24 

func (stream *PararellCTsStream[T]) Run(callback Callback)

func (*PararellCTsStream[T]) Start added in v0.0.24 

func (stream *PararellCTsStream[T]) Start(callback Callback)

func (*PararellCTsStream[T]) Stop added in v0.0.24 

func (stream *PararellCTsStream[T]) Stop()

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.