redis

Documentation

Index

• type InitOpts
• type RedisLogStorageManager
  • func NewRedisLogStorageManager(opts *InitOpts) (*RedisLogStorageManager, error)
  • func (c *RedisLogStorageManager) ClearLogs(ctx context.Context, path string) error
  • func (c *RedisLogStorageManager) GetID() string
  • func (c *RedisLogStorageManager) PushLogLine(ctx context.Context, path string, log []byte) error
  • func (c *RedisLogStorageManager) ReadLogs(ctx context.Context, opts *logstorage.LogGetOpts, w io.WriteCloser) error
  • func (c *RedisLogStorageManager) StreamLogs(ctx context.Context, opts *logstorage.LogGetOpts, w io.WriteCloser) error

Types

type InitOpts

type InitOpts struct {
	RedisHost     string
	RedisPort     string
	RedisUsername string
	RedisPassword string
	RedisDB       int
}

type RedisLogStorageManager

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

func NewRedisLogStorageManager

func NewRedisLogStorageManager(opts *InitOpts) (*RedisLogStorageManager, error)

func (*RedisLogStorageManager) ClearLogs

func (c *RedisLogStorageManager) ClearLogs(ctx context.Context, path string) error

func (*RedisLogStorageManager) GetID

func (c *RedisLogStorageManager) GetID() string

func (*RedisLogStorageManager) PushLogLine

func (c *RedisLogStorageManager) PushLogLine(ctx context.Context, path string, log []byte) error

func (*RedisLogStorageManager) ReadLogs

func (c *RedisLogStorageManager) ReadLogs(ctx context.Context, opts *logstorage.LogGetOpts, w io.WriteCloser) error

func (*RedisLogStorageManager) StreamLogs

func (c *RedisLogStorageManager) StreamLogs(ctx context.Context, opts *logstorage.LogGetOpts, w io.WriteCloser) error