ctstream

package module
v0.0.14 Latest Latest
Warning

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

 Go to latest Published: Aug 7, 2024 License: MIT Imports: 9 Imported by: 0

README

ct-stream

The library, streaming the certificates from ct logs, written in golang.

Documentation

Index

Constants

View Source 
const (
	ERROR_FAILED_TO_NEW        = "failed to create new client"
	ERROR_FAILED_TO_FETCH_STH  = "failed to fetch STH"
	ERROR_NEW_LOGS_NOT_FOUND   = "new logs not found"
	ERROR_FAILED_TO_GET_CERT   = "failed to get certificate"
	ERROR_FAILED_TO_PARSE_CERT = "failed to parse certificate"
	NO_CERT_AND_PRECERT_LEAF   = "no certificate and precertificate leaf"
)

Variables

View Source 
var DefaultMaxEntries int64 = 256
View Source 
var DefaultSleep = 1 * time.Second

Functions

This section is empty.

Types

type CTClient added in v0.0.6 

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

func DefaultCTClient added in v0.0.6 

func DefaultCTClient(url string) (*CTClient, error)

func NewCTClient added in v0.0.6 

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

func (*CTClient) Init added in v0.0.6 

func (stream *CTClient) Init() error

func (*CTClient) Next added in v0.0.6 

func (stream *CTClient) Next() ([]ct.LogEntry, error)

type CTStream 

type CTStream struct {
	Client *CTClient
	Sleep  time.Duration
	Ctx    context.Context
	Wg     sync.WaitGroup
	Stop   context.CancelFunc
}

func DefaultCTStream added in v0.0.6 

func DefaultCTStream(url string, ctx context.Context) (*CTStream, error)

func NewCTStream added in v0.0.6 

func NewCTStream(client *CTClient, sleep time.Duration, Ctx context.Context) (*CTStream, error)

func (*CTStream) Await added in v0.0.11 

func (stream *CTStream) Await()

func (*CTStream) Init 

func (stream *CTStream) Init() error

func (*CTStream) Next 

func (stream *CTStream) Next(callback Callback)

func (*CTStream) Run 

func (stream *CTStream) Run(callback Callback)

func (*CTStream) Start added in v0.0.13 

func (stream *CTStream) Start(callback Callback)

type CTsStream added in v0.0.6 

type CTsStream struct {
	Streams []*CTStream
	Sleep   time.Duration
}

func DefaultCTsStream added in v0.0.6 

func DefaultCTsStream(urls []string, ctx context.Context) (*CTsStream, error)

func NewCTsStream added in v0.0.6 

func NewCTsStream(streams []*CTStream, sleep time.Duration) (*CTsStream, error)

func SemiDefaultCTsStream added in v0.0.14 

func SemiDefaultCTsStream(streams []*CTStream, sleep time.Duration) (*CTsStream, error)

func (*CTsStream) Await added in v0.0.9 

func (stream *CTsStream) Await()

func (*CTsStream) Init added in v0.0.6 

func (stream *CTsStream) Init() error

func (*CTsStream) Run added in v0.0.6 

func (stream *CTsStream) Run(callback Callback)

func (*CTsStream) Start added in v0.0.9 

func (stream *CTsStream) Start(callback Callback)

func (*CTsStream) Stop added in v0.0.6 

func (stream *CTsStream) Stop()

type Callback 

type Callback func(*ctx509.Certificate, LogID, *client.LogClient, error)

type LogID 

type LogID = int64

Source Files

View all Source files

Directories

Path Synopsis

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.