Documentation
¶
Overview ¶
Package log implements the log service
Index ¶
Constants ¶
View Source
const Version string = "log/v1"
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type LogService ¶
type LogService struct {
logsv1.UnimplementedLogServiceServer
// contains filtered or unexported fields
}
func NewService ¶
func NewService(opts ...NewServiceOption) *LogService
NewService initializes and returns a LogService instance
func (*LogService) PushLogs ¶
func (s *LogService) PushLogs(stream logsv1.LogService_PushLogsServer) error
PushLogs can be used by clients to push log entries to the server which fans them out to subscribers on the exchange.
func (*LogService) TailLogs ¶
func (s *LogService) TailLogs(req *logsv1.TailLogRequest, srv logsv1.LogService_TailLogsServer) error
TailLogs publishes TailLogStart to subscribers requesting them to start sending entries to the server. TailLogs will then forward the entires, fanning them out to the client(s) making the request in the first place.
type NewServiceOption ¶
type NewServiceOption func(s *LogService)
func WithExchange ¶
func WithExchange(e *events.Exchange) NewServiceOption
func WithLogger ¶
func WithLogger(l logger.Logger) NewServiceOption
Source Files
Click to show internal directories.
Click to hide internal directories.