pubsub

Documentation

Overview

Package pubsub implements pub/sub interfaces defined in package kolide.

Index

• func NewInmemQueryResults() *inmemQueryResults
• func NewRedisPool(server, password string, database int, useTLS bool) *redis.Pool
• func NewRedisQueryResults(pool *redis.Pool) *redisQueryResults
• type Error

Functions

func NewInmemQueryResults

func NewInmemQueryResults() *inmemQueryResults

NewInmemQueryResults initializes a new in-memory implementation of the QueryResultStore interface.

func NewRedisPool

func NewRedisPool(server, password string, database int, useTLS bool) *redis.Pool

NewRedisPool creates a Redis connection pool using the provided server address, password and database.

func NewRedisQueryResults

func NewRedisQueryResults(pool *redis.Pool) *redisQueryResults

NewRedisQueryResults creats a new Redis implementation of the QueryResultStore interface using the provided Redis connection pool.

Types

type Error

type Error interface {
	error
	// NoSubscriber returns true if the error occurred because there are no
	// subscribers on the channel
	NoSubscriber() bool
}

Error defines the interface of errors specific to the pubsub package