datasource

Documentation

Index

• type CyclicReader
  • func NewCyclicReader(rs io.ReadSeeker) *CyclicReader
  • func (r *CyclicReader) Read(b []byte) (int, error)
• type FileDataSource
  • func NewFileDataSource(r io.Reader, factoryOptions ...Option) *FileDataSource
  • func (ds *FileDataSource) Fetch() (types.Req, error)
• type InmemDataSource
  • func NewInmemDataSource(r io.Reader, factoryOptions ...Option) *InmemDataSource
  • func (ds *InmemDataSource) Fetch() (types.Req, error)
  • func (ds *InmemDataSource) Init() error
• type MetaMiddleware
• type Option
  • func WithAdditionalHeader(k, v string) Option
  • func WithAdditionalHeaders(headers []string) Option
  • func WithMetaMiddleware(mw MetaMiddleware) Option
  • func WithTimeout(t time.Duration) Option
• type RequestAdapter
  • func NewRequestAdapter(metaMiddleware MetaMiddleware) *RequestAdapter
  • func (a *RequestAdapter) FullMethodName() string
  • func (a *RequestAdapter) SetUp(maxFramePayloadLen int, maxHeaderListSize int, streamID uint32, ...) ([]types.Frame, error)
  • func (a *RequestAdapter) Size() int
  • func (a *RequestAdapter) Tag() string
• type RequestAdapterFactory
  • func NewRequestAdapterFactory(ops ...Option) *RequestAdapterFactory
  • func (f *RequestAdapterFactory) Build() *RequestAdapter

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

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

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

func (f *RequestAdapterFactory) Build() *RequestAdapter