coordinator

package
v1.4.13 Latest Latest
Warning

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

 Go to latest Published: Oct 1, 2025 License: GPL-3.0 Imports: 26 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	ServiceType = "coordinator"
)

Variables

This section is empty.

Functions

This section is empty.

Types

type AuthConfig added in v0.0.201 

type AuthConfig struct {
	Enabled *bool  `yaml:"enabled" default:"false"`
	Secret  string `yaml:"secret"`
}

func (*AuthConfig) Validate added in v0.0.201 

func (c *AuthConfig) Validate() error

type Client 

type Client struct {
	xatu.UnimplementedCoordinatorServer
	// contains filtered or unexported fields
}

func NewClient 

func NewClient(ctx context.Context, log logrus.FieldLogger, conf *Config, p *persistence.Client, geoipProvider geoip.Provider, healthServer *health.Server) (*Client, error)

func (*Client) CoordinateConsensusNodeRecords added in v1.3.0 

func (c *Client) CoordinateConsensusNodeRecords(ctx context.Context, req *xatu.CoordinateConsensusNodeRecordsRequest) (*xatu.CoordinateConsensusNodeRecordsResponse, error)

func (*Client) CoordinateExecutionNodeRecords 

func (c *Client) CoordinateExecutionNodeRecords(ctx context.Context, req *xatu.CoordinateExecutionNodeRecordsRequest) (*xatu.CoordinateExecutionNodeRecordsResponse, error)

func (*Client) CreateConsensusNodeRecordStatus added in v1.3.0 

func (c *Client) CreateConsensusNodeRecordStatus(ctx context.Context, req *xatu.CreateConsensusNodeRecordStatusRequest) (*xatu.CreateConsensusNodeRecordStatusResponse, error)

func (*Client) CreateConsensusNodeRecordStatuses added in v1.3.2 

func (c *Client) CreateConsensusNodeRecordStatuses(
	ctx context.Context,
	req *xatu.CreateConsensusNodeRecordStatusesRequest,
) (*xatu.CreateConsensusNodeRecordStatusesResponse, error)

func (*Client) CreateExecutionNodeRecordStatus 

func (c *Client) CreateExecutionNodeRecordStatus(ctx context.Context, req *xatu.CreateExecutionNodeRecordStatusRequest) (*xatu.CreateExecutionNodeRecordStatusResponse, error)

func (*Client) CreateNodeRecords 

func (c *Client) CreateNodeRecords(ctx context.Context, req *xatu.CreateNodeRecordsRequest) (*xatu.CreateNodeRecordsResponse, error)

func (*Client) GetCannonLocation 

func (c *Client) GetCannonLocation(ctx context.Context, req *xatu.GetCannonLocationRequest) (*xatu.GetCannonLocationResponse, error)

func (*Client) GetDiscoveryConsensusNodeRecord added in v1.3.0 

func (c *Client) GetDiscoveryConsensusNodeRecord(ctx context.Context, req *xatu.GetDiscoveryConsensusNodeRecordRequest) (*xatu.GetDiscoveryConsensusNodeRecordResponse, error)

func (*Client) GetDiscoveryExecutionNodeRecord added in v1.3.0 

func (c *Client) GetDiscoveryExecutionNodeRecord(ctx context.Context, req *xatu.GetDiscoveryExecutionNodeRecordRequest) (*xatu.GetDiscoveryExecutionNodeRecordResponse, error)

func (*Client) GetDiscoveryNodeRecord 

func (c *Client) GetDiscoveryNodeRecord(ctx context.Context, req *xatu.GetDiscoveryNodeRecordRequest) (*xatu.GetDiscoveryNodeRecordResponse, error)

func (*Client) GetRelayMonitorLocation added in v1.4.4 

func (c *Client) GetRelayMonitorLocation(ctx context.Context, req *xatu.GetRelayMonitorLocationRequest) (*xatu.GetRelayMonitorLocationResponse, error)

func (*Client) ListStalledConsensusNodeRecords added in v1.3.0 

func (c *Client) ListStalledConsensusNodeRecords(ctx context.Context, req *xatu.ListStalledConsensusNodeRecordsRequest) (*xatu.ListStalledConsensusNodeRecordsResponse, error)

func (*Client) ListStalledExecutionNodeRecords 

func (c *Client) ListStalledExecutionNodeRecords(ctx context.Context, req *xatu.ListStalledExecutionNodeRecordsRequest) (*xatu.ListStalledExecutionNodeRecordsResponse, error)

func (*Client) Name added in v1.0.38 

func (c *Client) Name() string

Name returns the name of this service

func (*Client) Start 

func (c *Client) Start(ctx context.Context, grpcServer *grpc.Server) error

func (*Client) Stop 

func (c *Client) Stop(ctx context.Context) error

func (*Client) UpsertCannonLocation 

func (c *Client) UpsertCannonLocation(ctx context.Context, req *xatu.UpsertCannonLocationRequest) (*xatu.UpsertCannonLocationResponse, error)

func (*Client) UpsertRelayMonitorLocation added in v1.4.4 

func (c *Client) UpsertRelayMonitorLocation(ctx context.Context, req *xatu.UpsertRelayMonitorLocationRequest) (*xatu.UpsertRelayMonitorLocationResponse, error)

type Config 

type Config struct {
	Enabled    bool        `yaml:"enabled" default:"false"`
	NodeRecord node.Config `yaml:"nodeRecord"`
	Auth       AuthConfig  `yaml:"auth"`
}

func (*Config) Validate 

func (c *Config) Validate() error

type Metrics 

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

func NewMetrics 

func NewMetrics(namespace string) *Metrics

func (*Metrics) AddConsensusNodeRecordStatusReceived added in v1.3.0 

func (m *Metrics) AddConsensusNodeRecordStatusReceived(count int, sentryID, result, networkID, forkDigest string)

func (*Metrics) AddExecutionNodeRecordStatusReceived 

func (m *Metrics) AddExecutionNodeRecordStatusReceived(count int, sentryID, result, networkID, forkIDHash string)

func (*Metrics) AddNodeRecordReceived 

func (m *Metrics) AddNodeRecordReceived(count int, sentryID string)

Source Files

View all Source files

Directories

Path Synopsis

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.