core

Documentation

Index

• Constants
• Variables
• func AddByDomain[C CtClient](domain string, def DefaultCTClient[C], clients *CTClients[C], null func() C) (C, int, error)
• func DelByDomain[C CtClient](domain string, clients *CTClients[C], null func() C) (C, int, error)
• func SelectByDomain[C CtClient](domain string, clients *CTClients[C], null func() C) (C, int, error)
• type CTClients
  • func NewCTClients[T CtClient](clients []T, sleep time.Duration) (*CTClients[T], error)
  • func (clients *CTClients[T]) GetDomain() string
  • func (clients *CTClients[T]) Init() error
  • func (clients *CTClients[T]) Next(callback Callback)
• type CTStream
  • func NewCTStream[T CtClient](client T, sleep time.Duration, Ctx context.Context) (*CTStream[T], error)
  • func (stream *CTStream[T]) Await()
  • func (stream *CTStream[T]) Init() error
  • func (stream *CTStream[T]) Next(callback Callback)
  • func (stream *CTStream[T]) Run(callback Callback)
  • func (stream *CTStream[T]) Start(callback Callback)
  • func (stream *CTStream[T]) Stop()
• type CTsStream
• type Callback
• type CtClient
• type CtStream
• type DefaultCTClient
• type LogID
• type PararellCTsStream
  • func NewPararellCTsStream[T CtStream](streams []T, sleep time.Duration) (*PararellCTsStream[T], error)
  • func (stream PararellCTsStream[T]) Await()
  • func (stream *PararellCTsStream[T]) Init() error
  • func (stream *PararellCTsStream[T]) Next(callback Callback)
  • func (stream *PararellCTsStream[T]) Run(callback Callback)
  • func (stream *PararellCTsStream[T]) Start(callback Callback)
  • func (stream *PararellCTsStream[T]) Stop()

Constants

const ERROR_NOT_FOUND = "not found"

Variables

var DefaultEpochSleep = time.Minute * 20

var DefaultMaxEntries int64 = 256

var DefaultPullingSleep = time.Second * 10

Functions

func AddByDomain

func AddByDomain[C CtClient](
	domain string,
	def DefaultCTClient[C],
	clients *CTClients[C],
	null func() C,
) (C, int, error)

func DelByDomain

func DelByDomain[C CtClient](
	domain string,
	clients *CTClients[C],
	null func() C,
) (C, int, error)

func SelectByDomain

func SelectByDomain[C CtClient](
	domain string,
	clients *CTClients[C],
	null func() C,
) (C, int, error)

Types

type CTClients

type CTClients[T CtClient] struct {
	Clients []T
	Sleep   time.Duration
}

func NewCTClients

func NewCTClients[T CtClient](clients []T, sleep time.Duration) (*CTClients[T], error)

func (*CTClients[T]) GetDomain

func (clients *CTClients[T]) GetDomain() string

func (*CTClients[T]) Init

func (clients *CTClients[T]) Init() error

func (*CTClients[T]) Next

func (clients *CTClients[T]) Next(callback Callback)

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 CtClient

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

type CtStream

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

type DefaultCTClient

type DefaultCTClient[C CtClient] func(string) (C, error)

type LogID

type LogID = int64

type PararellCTsStream

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

func NewPararellCTsStream

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

func (PararellCTsStream[T]) Await

func (stream PararellCTsStream[T]) Await()

func (*PararellCTsStream[T]) Init

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

func (*PararellCTsStream[T]) Next

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

func (*PararellCTsStream[T]) Run

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

func (*PararellCTsStream[T]) Start

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

func (*PararellCTsStream[T]) Stop

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