client

type Entry struct {
	Labels model.LabelSet
	logproto.Entry
}

type FakeValiClient struct {
	// IsStopped show whether the client is stopped or not
	IsStopped bool
	// IsGracefullyStopped show whether the client is gracefully topped or not
	IsGracefullyStopped bool
	// Entries is slice of all received entries
	Entries []Entry
	Mu      sync.Mutex
}

type NewValiClientFunc func(cfg config.Config, logger log.Logger) (OutputClient, error)

type Options interface {
	// contains filtered or unexported methods
}

type OutputClient interface {
	// Handle processes logs and then sends them to Vali ingester
	Handle(labels any, t time.Time, entry string) error
	// Stop shut down the client immediately without waiting to send the saved logs
	Stop()
	// StopWait stops the client of receiving new logs and waits all saved logs to be sent until shutting down
	StopWait()
	// GetEndPoint returns the target logging backend endpoint
	GetEndPoint() string
}