directivehttp

Documentation

Index

• Constants
• type Options
• type Source
  • func New(opts Options) *Source
  • func (s *Source) Close() error
  • func (s *Source) Read(ctx context.Context, reference directive.HTTPReference, ...) ([]byte, error)

Constants

const Protocol = "dp.resolve.v1"

Types

type Options

type Options struct {
	Timeout             time.Duration
	MaxPayloadBytes     int64
	MaxIdleConns        int
	MaxIdleConnsPerHost int
	MaxConnsPerHost     int
	IdleConnTimeout     time.Duration
}

type Source

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

func New

func New(opts Options) *Source

func (*Source) Close

func (s *Source) Close() error

func (*Source) Read

func (s *Source) Read(ctx context.Context, reference directive.HTTPReference, request directive.RequestSnapshot) ([]byte, error)