coordinator

Documentation

Index

• Constants
• type Client
  • func NewClient(ctx context.Context, log logrus.FieldLogger, conf *Config, ...) (*Client, error)
  • func (c *Client) CoordinateExecutionNodeRecords(ctx context.Context, req *xatu.CoordinateExecutionNodeRecordsRequest) (*xatu.CoordinateExecutionNodeRecordsResponse, error)
  • func (c *Client) CreateExecutionNodeRecordStatus(ctx context.Context, req *xatu.CreateExecutionNodeRecordStatusRequest) (*xatu.CreateExecutionNodeRecordStatusResponse, error)
  • func (c *Client) CreateNodeRecords(ctx context.Context, req *xatu.CreateNodeRecordsRequest) (*xatu.CreateNodeRecordsResponse, error)
  • func (c *Client) GetCannonLocation(ctx context.Context, req *xatu.GetCannonLocationRequest) (*xatu.GetCannonLocationResponse, error)
  • func (c *Client) GetDiscoveryNodeRecord(ctx context.Context, req *xatu.GetDiscoveryNodeRecordRequest) (*xatu.GetDiscoveryNodeRecordResponse, error)
  • func (c *Client) ListStalledExecutionNodeRecords(ctx context.Context, req *xatu.ListStalledExecutionNodeRecordsRequest) (*xatu.ListStalledExecutionNodeRecordsResponse, error)
  • func (c *Client) Start(ctx context.Context, grpcServer *grpc.Server) error
  • func (c *Client) Stop(ctx context.Context) error
  • func (c *Client) UpsertCannonLocation(ctx context.Context, req *xatu.UpsertCannonLocationRequest) (*xatu.UpsertCannonLocationResponse, error)
• type Config
  • func (c *Config) Validate() error
• type Metrics
  • func NewMetrics(namespace string) *Metrics
  • func (m *Metrics) AddExecutionNodeRecordStatusReceived(count int, sentryID, result, networkID, forkIDHash string)
  • func (m *Metrics) AddNodeRecordReceived(count int, sentryID string)

Constants

const (
	ServiceType = "coordinator"
)

Types

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) (*Client, error)

func (*Client) CoordinateExecutionNodeRecords

func (c *Client) CoordinateExecutionNodeRecords(ctx context.Context, req *xatu.CoordinateExecutionNodeRecordsRequest) (*xatu.CoordinateExecutionNodeRecordsResponse, 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) GetDiscoveryNodeRecord

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

func (*Client) ListStalledExecutionNodeRecords

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

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)

type Config

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

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) AddExecutionNodeRecordStatusReceived

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

func (*Metrics) AddNodeRecordReceived

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