relayer

package

v1.13.0 Latest Latest Go to latest Published: Feb 20, 2026 License: Apache-2.0 Imports: 15 Imported by: 0

Details

This section is empty.

This section is empty.

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

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

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

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

func (r *Relayer) List(ctx context.Context, in *pbhealth.HealthListRequest) (*pbhealth.HealthListResponse, error)

func (r *Relayer) Run()

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