v3io

Documentation

Index

• func GetShardLagsMap(ctx context.Context, accessKey string, logger logger.Logger, ...) (map[string]interface{}, error)
• func GetSingleShardLagDetails(v3ioContext v3iodataplane.Context, streamPath, consumerGroup string, ...) (int, int, error)
• func GetStreamsFromFunctions(functions []platform.Function) (map[string]restful.Attributes, error)
• type StreamInfo

Functions

func GetShardLagsMap

func GetShardLagsMap(ctx context.Context,
	accessKey string,
	logger logger.Logger,
	platformConfig *platformconfig.Config,
	info *StreamInfo,
	consumerGroups []string) (map[string]interface{}, error)

func GetSingleShardLagDetails

func GetSingleShardLagDetails(v3ioContext v3iodataplane.Context,
	streamPath,
	consumerGroup string,
	shardID int,
	dataPlaneInput *v3iodataplane.DataPlaneInput) (int, int, error)

func GetStreamsFromFunctions

func GetStreamsFromFunctions(functions []platform.Function) (map[string]restful.Attributes, error)

Types

type StreamInfo

type StreamInfo struct {
	ConsumerGroup string `json:"consumerGroup,omitempty"`
	ContainerName string `json:"containerName,omitempty"`
	StreamPath    string `json:"streamPath,omitempty"`
}