up2redis

Documentation

Index

• func IsPathExist(path string) bool
• func RedisClient() *redis.ClusterClient
• type Config
  • func (c *Config) LoadConfig(path string) error
• type LoggerC
• type Pool
  • func New(size int) *Pool
  • func (p *Pool) Add(delta int)
  • func (p *Pool) Done()
  • func (p *Pool) Wait()
• type RedisC
• type Server
  • func (s *Server) Report(ctx context.Context, in *redis.ReportRequest) (*redis.ReportResponse, error)
  • func (s *Server) Start() error

Functions

func IsPathExist

func IsPathExist(path string) bool

func RedisClient

func RedisClient() *redis.ClusterClient

Types

type Config

type Config struct {
	Listen   string
	Logger   LoggerC
	Redis    RedisC
	PoolSize int `json:"pool_size"`
}

func (*Config) LoadConfig

func (c *Config) LoadConfig(path string) error

load config.toml

type LoggerC

type LoggerC struct {
	LogPath    string
	MaxSize    int
	MaxBackups int
	MaxAge     int
	Level      string
}

type Pool

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

func New

func New(size int) *Pool

func (*Pool) Add

func (p *Pool) Add(delta int)

func (*Pool) Done

func (p *Pool) Done()

func (*Pool) Wait

func (p *Pool) Wait()

type RedisC

type RedisC struct {
	DB       int
	Password string
	PoolSize int
	Cluster  []string
}

type Server

type Server struct {
	Config *Config
}

func (*Server) Report

func (s *Server) Report(ctx context.Context, in *redis.ReportRequest) (*redis.ReportResponse, error)

func (*Server) Start

func (s *Server) Start() error