direct

Documentation

Index

• Constants
• Variables
• func DefaultCTStream(url string, ctx context.Context) (*core.CTStream[*CTClient], error)
• func DefaultCTsStream(urls []string, ctx context.Context) (*core.PararellCTsStream[*core.CTStream[*CTClient]], error)
• type Args
• type CTClient
  • func DefaultCTClient(url string, ctx context.Context) (*CTClient, error)
  • func NewCTClient(url string, maxEntrySize int64, ctx context.Context, ops jsonclient.Options) (*CTClient, error)
  • func (stream *CTClient) GetDomain() string
  • func (stream *CTClient) Init() error
  • func (stream *CTClient) Next(callback core.Callback)
• type CTClientParams

Constants

const (
	ERROR_FAILED_TO_NEW       = "failed to create new client"
	ERROR_FAILED_TO_FETCH_STH = "failed to fetch STH"
	NO_CERT_AND_PRECERT_LEAF  = "no certificate and precertificate leaf"
	ERROR_FAILED_TO_GET_CERT  = "failed to get certificate"
)

Variables

var DefaultSleep = 1 * time.Second

var FetchingThread = 0

var MaxThread = 50

var ThreadManager = threadManager{
	FetchingThread: FetchingThread,
	MaxThread:      MaxThread,
	Mutex:          sync.Mutex{},
}

Functions

func DefaultCTStream

func DefaultCTStream(url string, ctx context.Context) (*core.CTStream[*CTClient], error)

func DefaultCTsStream

func DefaultCTsStream(urls []string, ctx context.Context) (*core.PararellCTsStream[*core.CTStream[*CTClient]], error)

Types

type Args

type Args []any

type CTClient

type CTClient struct {
	Url string
	*client.LogClient
	context.Context
	// contains filtered or unexported fields
}

func DefaultCTClient

func DefaultCTClient(url string, ctx context.Context) (*CTClient, error)

func NewCTClient

func NewCTClient(url string, maxEntrySize int64, ctx context.Context, ops jsonclient.Options) (*CTClient, error)

func (*CTClient) GetDomain

func (stream *CTClient) GetDomain() string

func (*CTClient) Init

func (stream *CTClient) Init() error

func (*CTClient) Next

func (stream *CTClient) Next(callback core.Callback)

type CTClientParams

type CTClientParams struct {
	Start     core.LogID
	LogClient *client.LogClient
}