server

Documentation

Index

• type BlocksPipe
  • func (p *BlocksPipe) Context() context.Context
  • func (p *BlocksPipe) Recv() (*pbfirehose.Response, error)
  • func (p *BlocksPipe) Send(resp *pbfirehose.Response) error
  • func (p *BlocksPipe) SendHeader(metadata.MD) error
  • func (p *BlocksPipe) SetHeader(metadata.MD) error
  • func (p *BlocksPipe) SetTrailer(metadata.MD)
• type ErrSendBlock
  • func NewErrSendBlock(inner error) ErrSendBlock
  • func (e ErrSendBlock) Error() string
• type FirehoseProxyV1ToV2
  • func NewFirehoseProxyV1ToV2(server *Server) *FirehoseProxyV1ToV2
  • func (s *FirehoseProxyV1ToV2) Blocks(req *pbfirehoseV1.Request, streamSrv pbfirehoseV1.Stream_BlocksServer) error
• type Option
  • func WithLeakyBucketLimiter(size int, dripRate time.Duration) Option
• type Server
  • func New(transformRegistry *transform.Registry, streamFactory *firehose.StreamFactory, ...) *Server
  • func (s *Server) Block(ctx context.Context, request *pbfirehose.SingleBlockRequest) (*pbfirehose.SingleBlockResponse, error)
  • func (s *Server) Blocks(request *pbfirehose.Request, streamSrv pbfirehose.Stream_BlocksServer) error
  • func (s *Server) BlocksFromLocal(ctx context.Context, req *pbfirehose.Request) pbfirehose.Stream_BlocksClient
  • func (s *Server) Launch()

Types

type BlocksPipe

type BlocksPipe struct {
	//grpc.ServerStream
	grpc.ClientStream
	// contains filtered or unexported fields
}

func (*BlocksPipe) Context

func (p *BlocksPipe) Context() context.Context

func (*BlocksPipe) Recv

func (p *BlocksPipe) Recv() (*pbfirehose.Response, error)

func (*BlocksPipe) Send

func (p *BlocksPipe) Send(resp *pbfirehose.Response) error

func (*BlocksPipe) SendHeader

func (p *BlocksPipe) SendHeader(metadata.MD) error

func (*BlocksPipe) SetHeader

func (p *BlocksPipe) SetHeader(metadata.MD) error

func (*BlocksPipe) SetTrailer

func (p *BlocksPipe) SetTrailer(metadata.MD)

type ErrSendBlock

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

func NewErrSendBlock

func NewErrSendBlock(inner error) ErrSendBlock

func (ErrSendBlock) Error

func (e ErrSendBlock) Error() string

type FirehoseProxyV1ToV2

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

func NewFirehoseProxyV1ToV2

func NewFirehoseProxyV1ToV2(server *Server) *FirehoseProxyV1ToV2

func (*FirehoseProxyV1ToV2) Blocks

func (s *FirehoseProxyV1ToV2) Blocks(req *pbfirehoseV1.Request, streamSrv pbfirehoseV1.Stream_BlocksServer) error

type Option

type Option func(*Server)

func WithLeakyBucketLimiter

func WithLeakyBucketLimiter(size int, dripRate time.Duration) Option

type Server

type Server struct {
	dgrpcserver.Server
	// contains filtered or unexported fields
}

func New

func New(
	transformRegistry *transform.Registry,
	streamFactory *firehose.StreamFactory,
	blockGetter *firehose.BlockGetter,
	logger *zap.Logger,
	authenticator dauth.Authenticator,
	isReady func(context.Context) bool,
	listenAddr string,
	serviceDiscoveryURL *url.URL,
	opts ...Option,
) *Server

func (*Server) Block

func (s *Server) Block(ctx context.Context, request *pbfirehose.SingleBlockRequest) (*pbfirehose.SingleBlockResponse, error)

func (*Server) Blocks

func (s *Server) Blocks(request *pbfirehose.Request, streamSrv pbfirehose.Stream_BlocksServer) error

func (*Server) BlocksFromLocal

func (s *Server) BlocksFromLocal(ctx context.Context, req *pbfirehose.Request) pbfirehose.Stream_BlocksClient

func (*Server) Launch

func (s *Server) Launch()