datasource

package
v0.1.2 Latest Latest
Warning

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

Go to latest
Published: Aug 19, 2024 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type CyclicReader

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

func NewCyclicReader

func NewCyclicReader(rs io.ReadSeeker) *CyclicReader

func (*CyclicReader) Read

func (r *CyclicReader) Read(b []byte) (int, error)

type FileDataSource

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

func NewFileDataSource

func NewFileDataSource(r io.Reader, factoryOptions ...Option) *FileDataSource

func (*FileDataSource) Fetch

func (ds *FileDataSource) Fetch() (types.Req, error)

type InmemDataSource

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

func NewInmemDataSource

func NewInmemDataSource(r io.Reader, factoryOptions ...Option) *InmemDataSource

func (*InmemDataSource) Fetch

func (ds *InmemDataSource) Fetch() (types.Req, error)

func (*InmemDataSource) Init

func (ds *InmemDataSource) Init() error

type MetaMiddleware added in v0.1.2

type MetaMiddleware interface {
	IsAllowed(key string) bool
	WriteAdditional(types.HPackFieldWriter)
}

type Option

type Option interface {
	// contains filtered or unexported methods
}

func WithAdditionalHeader

func WithAdditionalHeader(k, v string) Option

func WithAdditionalHeaders

func WithAdditionalHeaders(headers []string) Option

func WithMetaMiddleware added in v0.1.2

func WithMetaMiddleware(mw MetaMiddleware) Option

func WithTimeout

func WithTimeout(t time.Duration) Option

type RequestAdapter

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

func NewRequestAdapter

func NewRequestAdapter(metaMiddleware MetaMiddleware) *RequestAdapter

func (*RequestAdapter) FullMethodName

func (a *RequestAdapter) FullMethodName() string

func (*RequestAdapter) SetUp

func (a *RequestAdapter) SetUp(
	maxFramePayloadLen int,
	maxHeaderListSize int,
	streamID uint32,
	hpackFieldWriter types.HPackFieldWriter,
) ([]types.Frame, error)

func (*RequestAdapter) Size

func (a *RequestAdapter) Size() int

func (*RequestAdapter) Tag

func (a *RequestAdapter) Tag() string

type RequestAdapterFactory

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

func NewRequestAdapterFactory

func NewRequestAdapterFactory(ops ...Option) *RequestAdapterFactory

func (*RequestAdapterFactory) Build

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL