console

package

Go to main page

Versions in this module

v1

v1.6.0

Jun 2, 2026

Changes in this version

+ type LFSConfig struct

+ Enabled bool

+ KafkaBrokers []string

+ PresignTTL int

+ S3AccessKey string

+ S3Bucket string

+ S3Endpoint string

+ S3Region string

+ S3SecretKey string

+ TrackerTopic string

+ type LFSConsumer struct

+ func NewLFSConsumer(ctx context.Context, cfg LFSConsumerConfig, handlers *LFSHandlers, ...) (*LFSConsumer, error)

+ func (c *LFSConsumer) Close() error

+ func (c *LFSConsumer) Start()

+ func (c *LFSConsumer) Status() LFSConsumerStatus

+ type LFSConsumerConfig struct

+ Brokers []string

+ GroupID string

+ Topic string

+ type LFSConsumerStatus struct

+ Connected bool

+ LastError string

+ LastErrorAt string

+ LastPollAt string

+ type LFSEvent struct

+ DurationMs int64

+ ErrorCode string

+ EventID string

+ EventType string

+ Mode string

+ ProxyID string

+ RequestID string

+ S3Key string

+ Size int64

+ Timestamp string

+ Topic string

+ type LFSHandlers struct

+ func NewLFSHandlers(cfg LFSConfig, logger *log.Logger) *LFSHandlers

+ func (h *LFSHandlers) HandleEvents(w http.ResponseWriter, r *http.Request)

+ func (h *LFSHandlers) HandleObjects(w http.ResponseWriter, r *http.Request)

+ func (h *LFSHandlers) HandleOrphans(w http.ResponseWriter, r *http.Request)

+ func (h *LFSHandlers) HandleS3Browse(w http.ResponseWriter, r *http.Request)

+ func (h *LFSHandlers) HandleS3Presign(w http.ResponseWriter, r *http.Request)

+ func (h *LFSHandlers) HandleStatus(w http.ResponseWriter, r *http.Request)

+ func (h *LFSHandlers) HandleTopicDetail(w http.ResponseWriter, r *http.Request)

+ func (h *LFSHandlers) HandleTopics(w http.ResponseWriter, r *http.Request)

+ func (h *LFSHandlers) ProcessEvent(event LFSEvent)

+ func (h *LFSHandlers) ResetStats()

+ func (h *LFSHandlers) SetConsumer(consumer *LFSConsumer)

+ func (h *LFSHandlers) SetS3Client(client *LFSS3Client)

+ type LFSObject struct

+ ContentType string

+ CreatedAt string

+ KafkaOffset int64

+ Partition int32

+ ProxyID string

+ S3Key string

+ SHA256 string

+ Size int64

+ Topic string

+ type LFSObjectsResponse struct

+ NextCursor string

+ Objects []LFSObject

+ TotalCount int64

+ type LFSOrphan struct

+ AgeHours int

+ DetectedAt string

+ Reason string

+ S3Bucket string

+ S3Key string

+ Size int64

+ Topic string

+ type LFSOrphansResponse struct

+ Count int

+ Orphans []LFSOrphan

+ TotalSize int64

+ type LFSS3Client struct

+ func NewLFSS3Client(ctx context.Context, cfg LFSS3Config, logger *log.Logger) (*LFSS3Client, error)

+ func (c *LFSS3Client) HeadObject(ctx context.Context, key string) (*S3Object, error)

+ func (c *LFSS3Client) ListObjects(ctx context.Context, prefix, delimiter string, maxKeys int) ([]S3Object, []string, bool, error)

+ func (c *LFSS3Client) PresignGetObject(ctx context.Context, key string, ttl time.Duration) (string, error)

+ type LFSS3Config struct

+ AccessKey string

+ Bucket string

+ Endpoint string

+ ForcePathStyle bool

+ Region string

+ SecretKey string

+ type LFSStats struct

+ AvgDownloadMs float64

+ AvgUploadMs float64

+ Downloads24h int64

+ Errors24h int64

+ OrphansPending int64

+ TotalBytes int64

+ TotalObjects int64

+ Uploads24h int64

+ type LFSStatusResponse struct

+ ConsumerStatus LFSConsumerStatus

+ Enabled bool

+ ProxyCount int

+ S3Bucket string

+ Stats LFSStats

+ TopicsWithLFS []string

+ TrackerEnabled bool

+ TrackerTopic string

+ type LFSTopicDetailResponse struct

+ Events []LFSEvent

+ Topic LFSTopicStats

+ type LFSTopicStats struct

+ AvgObjectSize int64

+ Downloads24h int64

+ Errors24h int64

+ FirstObject string

+ HasLFS bool

+ LastDownload string

+ LastError string

+ LastEvent string

+ LastObject string

+ LastUpload string

+ Name string

+ ObjectCount int64

+ Orphans int64

+ TotalBytes int64

+ Uploads24h int64

+ type LFSTopicsResponse struct

+ Topics []LFSTopicStats

+ type S3BrowseResponse struct

+ CommonPrefixes []string

+ IsTruncated bool

+ Objects []S3Object

+ type S3Object struct

+ ETag string

+ Key string

+ LastModified string

+ Size int64

+ type S3PresignRequest struct

+ S3Key string

+ TTLSeconds int

+ type S3PresignResponse struct

+ ExpiresAt string

+ URL string

type ServerOptions

+ LFSHandlers *LFSHandlers

v1.5.0

Jan 30, 2026

v1.4.2

Jan 19, 2026

Changes in this version

+ func NewMux(opts ServerOptions) (http.Handler, error)

+ func StartServer(ctx context.Context, addr string, opts ServerOptions) error

+ type AuthConfig struct

+ Password string

+ Username string

+ type BrokerRuntime struct

+ CPUPercent float64

+ MemBytes int64

+ type MetricsProvider interface

+ Snapshot func(ctx context.Context) (*MetricsSnapshot, error)

+ func NewAggregatedPromMetricsClient(store metadata.Store, metricsURL string) MetricsProvider

+ func NewCompositeMetricsProvider(broker MetricsProvider, operatorURL string) MetricsProvider

+ func NewPromMetricsClient(url string) MetricsProvider

+ type MetricsSnapshot struct

+ AdminRequestErrorsTotal float64

+ AdminRequestLatencyMS float64

+ AdminRequestsTotal float64

+ BrokerCPUPercent float64

+ BrokerMemBytes int64

+ BrokerRuntime map[string]BrokerRuntime

+ FetchRPS float64

+ OperatorClusters float64

+ OperatorEtcdSnapshotAccessOK float64

+ OperatorEtcdSnapshotAgeSeconds float64

+ OperatorEtcdSnapshotLastScheduleTS float64

+ OperatorEtcdSnapshotLastSuccessTS float64

+ OperatorEtcdSnapshotStale float64

+ OperatorMetricsAvailable bool

+ ProduceRPS float64

+ S3ErrorRate float64

+ S3LatencyMS int

+ S3State string

+ type ServerOptions struct

+ Auth AuthConfig

+ Logger *log.Logger

+ Metrics MetricsProvider

+ Store metadata.Store

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL