relayer

package
v1.13.1 Latest Latest
Warning

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

 Go to latest Published: Mar 10, 2026 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewMultiplexedSource 

func NewMultiplexedSource(handler bstream.Handler, sources []SourceAddr, 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) List added in v1.9.9 

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

func (*Relayer) Run 

func (r *Relayer) Run()

func (*Relayer) Watch 

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

type SourceAddr added in v1.13.1 

type SourceAddr struct {
	// URL is the gRPC endpoint address (everything before the '?' separator).
	URL string
	// SecretKey is the value of the "secret" query parameter, or empty when
	// no authentication is required.
	SecretKey string
}

SourceAddr holds a parsed relayer source address, optionally carrying a secret key extracted from the "?secret=<key>" query parameter.

Source Files

View all Source files

Directories

Path Synopsis
app
relayer

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.