logstream

Documentation

Index

• type LogStream
• type RedisLogStream
  • func NewRedisClient(url string) (*RedisLogStream, error)
  • func (r *RedisLogStream) HeartBeat(name string, quit chan int)
  • func (r *RedisLogStream) Publish(channel string, stream io.ReadCloser) error
  • func (r *RedisLogStream) Subscribe(channel string) <-chan *redis.Message

Types

type LogStream

type LogStream interface {
	Publish(channel string, stream io.ReadCloser) error
	HeartBeat(name string, quit chan int)
}

type RedisLogStream

type RedisLogStream struct {
	// contains filtered or unexported fields
}

func NewRedisClient

func NewRedisClient(url string) (*RedisLogStream, error)

func (*RedisLogStream) HeartBeat

func (r *RedisLogStream) HeartBeat(name string, quit chan int)

func (*RedisLogStream) Publish

func (r *RedisLogStream) Publish(channel string, stream io.ReadCloser) error

func (*RedisLogStream) Subscribe

func (r *RedisLogStream) Subscribe(channel string) <-chan *redis.Message

TODO: return a generic type to include Subscribe to the interface