org.apache.flink.statefun.flink.core.metrics

Interface FunctionTypeMetrics

All Superinterfaces:

RemoteInvocationMetrics

public interface FunctionTypeMetrics
extends RemoteInvocationMetrics

Method Summary

Modifier and Type	Method and Description
void	appendBacklogMessages(int count)
void	asyncOperationCompleted()
void	asyncOperationRegistered()
void	blockedAddress()
void	consumeBacklogMessages(int count)
Metrics	functionTypeScopedMetrics()
void	incomingMessage()
void	outgoingEgressMessage()
void	outgoingLocalMessage()
void	outgoingRemoteMessage()
void	unblockedAddress()

Methods inherited from interface org.apache.flink.statefun.flink.core.metrics.RemoteInvocationMetrics

remoteInvocationFailures, remoteInvocationLatency

Method Detail

incomingMessage

void incomingMessage()

outgoingLocalMessage

void outgoingLocalMessage()

outgoingRemoteMessage

void outgoingRemoteMessage()

outgoingEgressMessage

void outgoingEgressMessage()

blockedAddress

void blockedAddress()

unblockedAddress

void unblockedAddress()

asyncOperationRegistered

void asyncOperationRegistered()

asyncOperationCompleted

void asyncOperationCompleted()

appendBacklogMessages

void appendBacklogMessages(int count)

consumeBacklogMessages

void consumeBacklogMessages(int count)

functionTypeScopedMetrics

Metrics functionTypeScopedMetrics()