Documentation
¶
Index ¶
- Constants
- type Client
- func (c *Client) HandleConsensusNodeRecordStatus(ctx context.Context, status *xatu.ConsensusNodeStatus) error
- func (c *Client) HandleExecutionNodeRecordStatus(ctx context.Context, status *xatu.ExecutionNodeStatus) error
- func (c *Client) HandleNewNodeRecord(ctx context.Context, record *string) error
- func (c *Client) ListStaleConsensusNodeRecords(ctx context.Context) ([]string, error)
- func (c *Client) ListStaleExecutionNodeRecords(ctx context.Context) ([]string, error)
- func (c *Client) Start(ctx context.Context) error
- func (c *Client) Stop(ctx context.Context) error
- func (c *Client) Type() string
- type Config
- type ItemExporter
Constants ¶
View Source
const SinkType = "xatu"
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Client ¶
type Client struct {
// contains filtered or unexported fields
}
func (*Client) HandleConsensusNodeRecordStatus ¶ added in v1.3.0
func (*Client) HandleExecutionNodeRecordStatus ¶
func (*Client) HandleNewNodeRecord ¶
func (*Client) ListStaleConsensusNodeRecords ¶ added in v1.3.0
func (*Client) ListStaleExecutionNodeRecords ¶ added in v1.3.0
type Config ¶
type Config struct {
Address string `yaml:"address"`
Headers map[string]string `yaml:"headers"`
TLS bool `yaml:"tls" default:"false"`
MaxQueueSize int `yaml:"maxQueueSize" default:"51200"`
BatchTimeout time.Duration `yaml:"batchTimeout" default:"5s"`
ExportTimeout time.Duration `yaml:"exportTimeout" default:"30s"`
MaxExportBatchSize int `yaml:"maxExportBatchSize" default:"512"`
ConcurrentExecutionPeers int32 `yaml:"concurrentExecutionPeers" default:"100"`
ConcurrentConsensusPeers int32 `yaml:"concurrentConsensusPeers" default:"100"`
}
type ItemExporter ¶
type ItemExporter struct {
// contains filtered or unexported fields
}
func NewItemExporter ¶
func NewItemExporter(config *Config, log logrus.FieldLogger) (ItemExporter, error)
func (ItemExporter) ExportItems ¶
func (e ItemExporter) ExportItems(ctx context.Context, items []*string) error
Click to show internal directories.
Click to hide internal directories.