Documentation
¶
Index ¶
- Constants
- func ConsumeShort(ctx context.Context, log *slog.Logger, cfg *config.TrafficWatch, ...) error
- func ConsumeToDir(ctx context.Context, log *slog.Logger, cfg *config.TrafficWatch, ...) error
- func FormatSuffix(cfg *config.TrafficWatch) string
- func GetTrafficWatch(ctx context.Context, cfg *config.TrafficWatch, log *slog.Logger, rk string) (*trafficwatch.TrafficWatch, error)
- func StreamFormatSuffix(cfg *config.TrafficWatch) string
Constants ¶
View Source
const ( MiddlewareName = "trafficwatch" DefaultDirRelative = "traffic/watch" InstrumentationKey = "instrumentation.signadot.com/add-" + MiddlewareName )
Variables ¶
This section is empty.
Functions ¶
func ConsumeShort ¶
func ConsumeShort(ctx context.Context, log *slog.Logger, cfg *config.TrafficWatch, tw *trafficwatch.TrafficWatch) error
func ConsumeToDir ¶
func ConsumeToDir(ctx context.Context, log *slog.Logger, cfg *config.TrafficWatch, tw *trafficwatch.TrafficWatch) error
func FormatSuffix ¶
func FormatSuffix(cfg *config.TrafficWatch) string
func GetTrafficWatch ¶
func GetTrafficWatch(ctx context.Context, cfg *config.TrafficWatch, log *slog.Logger, rk string) (*trafficwatch.TrafficWatch, error)
func StreamFormatSuffix ¶
func StreamFormatSuffix(cfg *config.TrafficWatch) string
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.