check

Documentation

Index

• type Checker
• type IpniNonStreamingChecker
  • func NewIpniNonStreamingChecker(o ...Option) (*IpniNonStreamingChecker, error)
  • func (c *IpniNonStreamingChecker) Check(ctx context.Context, set *sample.Set) *Results
• type Option
  • func WithCascadeLabels(l []string) Option
  • func WithCheckTimeout(checkTimeout time.Duration) Option
  • func WithHttpClient(httpClient *http.Client) Option
  • func WithIpniEndpoint(endpoint string) Option
  • func WithName(name string) Option
  • func WithParallelism(parallelism int) Option
• type Result
• type Results

Types

type Checker

type Checker interface {
	Check(context.Context, *sample.Set) *Results
}

type IpniNonStreamingChecker

type IpniNonStreamingChecker struct {
	// contains filtered or unexported fields
}

func NewIpniNonStreamingChecker

func NewIpniNonStreamingChecker(o ...Option) (*IpniNonStreamingChecker, error)

func (*IpniNonStreamingChecker) Check

func (c *IpniNonStreamingChecker) Check(ctx context.Context, set *sample.Set) *Results

type Option

type Option func(*options) error

func WithCascadeLabels

func WithCascadeLabels(l []string) Option

func WithCheckTimeout

func WithCheckTimeout(checkTimeout time.Duration) Option

func WithHttpClient

func WithHttpClient(httpClient *http.Client) Option

func WithIpniEndpoint

func WithIpniEndpoint(endpoint string) Option

func WithName

func WithName(name string) Option

func WithParallelism

func WithParallelism(parallelism int) Option

type Result

type Result struct {
	Multihash  multihash.Multihash
	Err        error
	StatusCode int
	Timeout    time.Duration
	Elapsed    time.Duration
	Streaming  bool
}

type Results

type Results struct {
	Results       []*Result
	SampleSetName string
	CheckerName   string
}