service

Documentation

Index

• Constants
• type HealthChecker
  • func NewHealthChecker(monoVertex *v1alpha1.MonoVertex) *HealthChecker
• type MonoVertexService
  • func NewMoveVertexService(monoVtx *v1alpha1.MonoVertex, rater raterPkg.MonoVtxRatable) (*MonoVertexService, error)
  • func (mvs *MonoVertexService) GetMonoVertexMetrics(ctx context.Context, empty *emptypb.Empty) (*mvtxdaemon.GetMonoVertexMetricsResponse, error)
  • func (mvs *MonoVertexService) GetMonoVertexStatus(ctx context.Context, empty *emptypb.Empty) (*mvtxdaemon.GetMonoVertexStatusResponse, error)
  • func (mvs *MonoVertexService) StartHealthCheck(ctx context.Context)

Constants

const MonoVtxPendingMetric = "monovtx_pending"

MonoVtxPendingMetric is the metric emitted from the MonoVtx lag reader for pending stats Note: Please keep consistent with the definitions in rust/monovertex/sc/metrics.rs

Types

type HealthChecker

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

HealthChecker is the struct type for health checker.

func NewHealthChecker

func NewHealthChecker(monoVertex *v1alpha1.MonoVertex) *HealthChecker

NewHealthChecker creates a new object HealthChecker struct type.

type MonoVertexService

type MonoVertexService struct {
	mvtxdaemon.UnimplementedMonoVertexDaemonServiceServer
	// contains filtered or unexported fields
}

func NewMoveVertexService

func NewMoveVertexService(
	monoVtx *v1alpha1.MonoVertex,
	rater raterPkg.MonoVtxRatable,
) (*MonoVertexService, error)

NewMoveVertexService returns a new instance of MonoVertexService

func (*MonoVertexService) GetMonoVertexMetrics

func (mvs *MonoVertexService) GetMonoVertexMetrics(ctx context.Context, empty *emptypb.Empty) (*mvtxdaemon.GetMonoVertexMetricsResponse, error)

func (*MonoVertexService) GetMonoVertexStatus

func (mvs *MonoVertexService) GetMonoVertexStatus(ctx context.Context, empty *emptypb.Empty) (*mvtxdaemon.GetMonoVertexStatusResponse, error)

func (*MonoVertexService) StartHealthCheck

func (mvs *MonoVertexService) StartHealthCheck(ctx context.Context)

StartHealthCheck starts the health check for the MonoVertex using the health checker