Documentation
¶
Index ¶
- type LogBroker
- func (lb *LogBroker) ListenSubscriptions(request *api.ListenSubscriptionsRequest, ...) error
- func (lb *LogBroker) PublishLogs(stream api.LogBroker_PublishLogsServer) (err error)
- func (lb *LogBroker) Run(ctx context.Context) error
- func (lb *LogBroker) Stop() error
- func (lb *LogBroker) SubscribeLogs(request *api.SubscribeLogsRequest, stream api.Logs_SubscribeLogsServer) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type LogBroker ¶
type LogBroker struct {
// contains filtered or unexported fields
}
LogBroker coordinates log subscriptions to services and tasks. Clients can publish and subscribe to logs channels.
Log subscriptions are pushed to the work nodes by creating log subscsription tasks. As such, the LogBroker also acts as an orchestrator of these tasks.
func New ¶
func New(store *store.MemoryStore) *LogBroker
New initializes and returns a new LogBroker
func (*LogBroker) ListenSubscriptions ¶
func (lb *LogBroker) ListenSubscriptions(request *api.ListenSubscriptionsRequest, stream api.LogBroker_ListenSubscriptionsServer) error
ListenSubscriptions returns a stream of matching subscriptions for the current node
func (*LogBroker) PublishLogs ¶
func (lb *LogBroker) PublishLogs(stream api.LogBroker_PublishLogsServer) (err error)
PublishLogs publishes log messages for a given subscription
func (*LogBroker) SubscribeLogs ¶
func (lb *LogBroker) SubscribeLogs(request *api.SubscribeLogsRequest, stream api.Logs_SubscribeLogsServer) error
SubscribeLogs creates a log subscription and streams back logs
Source Files
Click to show internal directories.
Click to hide internal directories.