relayer

Documentation

Index

• func NewMultiplexedSource(handler bstream.Handler, sourceAddresses []string, ...) bstream.Source
• type Relayer
  • func NewRelayer(liveSourceFactory bstream.SourceFactory, grpcListenAddr string, ...) *Relayer
  • func (r *Relayer) Check(ctx context.Context, in *pbhealth.HealthCheckRequest) (*pbhealth.HealthCheckResponse, error)
  • func (r *Relayer) Run()
  • func (r *Relayer) Watch(req *pbhealth.HealthCheckRequest, stream pbhealth.Health_WatchServer) error

Functions

func NewMultiplexedSource

func NewMultiplexedSource(handler bstream.Handler, sourceAddresses []string, maxSourceLatency time.Duration, sourceRequestBurst int) bstream.Source

Types

type Relayer

type Relayer struct {
	*shutter.Shutter
	// contains filtered or unexported fields
}

func NewRelayer

func NewRelayer(
	liveSourceFactory bstream.SourceFactory,
	grpcListenAddr string,
	oneBlocksStore dstore.Store,
) *Relayer

func (*Relayer) Check

func (r *Relayer) Check(ctx context.Context, in *pbhealth.HealthCheckRequest) (*pbhealth.HealthCheckResponse, error)

func (*Relayer) Run

func (r *Relayer) Run()

func (*Relayer) Watch

func (r *Relayer) Watch(req *pbhealth.HealthCheckRequest, stream pbhealth.Health_WatchServer) error