Documentation
¶
Index ¶
- Constants
- type HealthChecker
- type MonoVertexService
- func (mvs *MonoVertexService) GetMonoVertexErrors(ctx context.Context, request *mvtxdaemon.GetMonoVertexErrorsRequest) (*mvtxdaemon.GetMonoVertexErrorsResponse, 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
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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, monoVertexRuntimeCache runtimePkg.MonoVertexRuntimeCache, ) (*MonoVertexService, error)
NewMoveVertexService returns a new instance of MonoVertexService
func (*MonoVertexService) GetMonoVertexErrors ¶ added in v1.5.0
func (mvs *MonoVertexService) GetMonoVertexErrors(ctx context.Context, request *mvtxdaemon.GetMonoVertexErrorsRequest) (*mvtxdaemon.GetMonoVertexErrorsResponse, error)
GetMonoVertexErrors returns errors for a given mono vertex by accessing the local cache in the runtime service. The errors are persisted in the local cache by the runtime service. Errors are retrieved for all active replicas for a given mono vertex. A list of replica errors for a given mono vertex is returned.
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
Source Files
Directories