laser_client

package
v0.0.0-...-f3016af Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 8, 2021 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	MOP_ORIGIN mopType = 1
	MOP_DETAIL mopType = 2
)
View Source 
const (
	LASER_CLIENT_MODULE_NAME                        = "laser_client"
	LASER_CLIENT_VERSION                            = "laser_client_version"
	LASER_CLIENT_MAJOR_VERSION                      = "major_version"
	LASER_CLIENT_MINOR_VERSION                      = "minor_version"
	LASER_CLIENT_REVISION                           = "revision"
	LASER_CLIENT_METRIC_CALL_SERVER_TIMES           = "call_server_times"
	LASER_CLIENT_THRIFT_CALL_RS_NOT_FOUND           = "laser_client_thrift_call_rs_not_found"
	LASER_CLIENT_THRIFT_CALL_RS_KEY_EXPIRE          = "laser_client_thrift_call_rs_key_expire"
	LASER_CLIENT_THRIFT_CALL_TIMEOUT                = "laser_client_thrift_call_timeout"
	LASER_CLIENT_THRIFT_CALL_ERROR                  = "laser_client_thrift_call_error"
	LASER_CLIENT_THRIFT_GET_STATUS_ERROR            = "laser_client_thrift_get_status_error"
	LASER_CLIENT_THRIFT_CALL_TIMER                  = "laser_client_thrift_call"
	LASER_CLIENT_SERVICE_ROUTER_DISCOVER_TIMER      = "laser_client_service_router_discover"
	LASER_CLIENT_GET_CONNECTION_TIMER               = "laser_client_get_connection"
	LASER_CLIENT_GET_CONNECTION_ERROR               = "laser_client_get_connection_error"
	LASER_CLIENT_METRIC_COMMAND_DEL_TIMER           = "del_command"
	LASER_CLIENT_METRIC_COMMAND_EXPIRE_TIMER        = "expire_command"
	LASER_CLIENT_METRIC_COMMAND_EXPIREAT_TIMER      = "expireat_command"
	LASER_CLIENT_METRIC_COMMAND_TTL_TIMER           = "ttl_command"
	LASER_CLIENT_METRIC_COMMAND_GET_TIMER           = "get_command"
	LASER_CLIENT_METRIC_COMMAND_SET_TIMER           = "set_command"
	LASER_CLIENT_METRIC_COMMAND_APPEND_TIMER        = "append_command"
	LASER_CLIENT_METRIC_COMMAND_SETX_TIMER          = "setx_command"
	LASER_CLIENT_METRIC_COMMAND_MSET_TIMER          = "mset_command"
	LASER_CLIENT_METRIC_COMMAND_MSET_DETAIL_TIMER   = "mset_detail_command"
	LASER_CLIENT_METRIC_COMMAND_MGET_TIMER          = "mget_command"
	LASER_CLIENT_METRIC_COMMAND_MGET_DETAIL_TIMER   = "mget_detail_command"
	LASER_CLIENT_METRIC_COMMAND_EXIST_TIMER         = "exist_command"
	LASER_CLIENT_METRIC_COMMAND_HSET_TIMER          = "hset_command"
	LASER_CLIENT_METRIC_COMMAND_HGET_TIMER          = "hget_command"
	LASER_CLIENT_METRIC_COMMAND_HDEL_TIMER          = "hdel_command"
	LASER_CLIENT_METRIC_COMMAND_HEXISTS_TIMER       = "hexists_command"
	LASER_CLIENT_METRIC_COMMAND_HGETALL_TIMER       = "hgetall_command"
	LASER_CLIENT_METRIC_COMMAND_HKEYS_TIMER         = "hkeys_command"
	LASER_CLIENT_METRIC_COMMAND_HLEN_TIMER          = "hlen_command"
	LASER_CLIENT_METRIC_COMMAND_HMSET_TIMER         = "hmset_command"
	LASER_CLIENT_METRIC_COMMAND_HMGET_TIMER         = "hmget_command"
	LASER_CLIENT_METRIC_COMMAND_LLEN_TIMER          = "llen_command"
	LASER_CLIENT_METRIC_COMMAND_LPOP_TIMER          = "lpop_command"
	LASER_CLIENT_METRIC_COMMAND_LPUSH_TIMER         = "lpush_command"
	LASER_CLIENT_METRIC_COMMAND_RPOP_TIMER          = "rpop_command"
	LASER_CLIENT_METRIC_COMMAND_RPUSH_TIMER         = "rpush_command"
	LASER_CLIENT_METRIC_COMMAND_LRANGE_TIMER        = "lrange_command"
	LASER_CLIENT_METRIC_COMMAND_LINDEX_TIMER        = "lindex_command"
	LASER_CLIENT_METRIC_COMMAND_DECR_TIMER          = "decr_command"
	LASER_CLIENT_METRIC_COMMAND_INCR_TIMER          = "incr_command"
	LASER_CLIENT_METRIC_COMMAND_DECRBY_TIMER        = "decrby_command"
	LASER_CLIENT_METRIC_COMMAND_INCRBY_TIMER        = "incrby_command"
	LASER_CLIENT_METRIC_COMMAND_ZADD_TIMER          = "zadd_command"
	LASER_CLIENT_METRIC_COMMAND_ZRANGEBYSCORE_TIMER = "zrangebyscore_command"
	LASER_CLIENT_METRIC_COMMAND_SADD_TIMER          = "sadd_command"
	LASER_CLIENT_METRIC_COMMAND_SISMEMBER_TIMER     = "sismember_command"
	LASER_CLIENT_METRIC_COMMAND_SREMOVE_TIMER       = "sremove_command"
	LASER_CLIENT_METRIC_COMMAND_SMEMBERS_TIMER      = "smembers_command"
)
View Source 
const (
	MAJOR_VERSION = 1
	MINOR_VERSION = 0
	REVISION      = 18
)
View Source 
const NIL_ADDRESS = "nil_address"

Variables

View Source 
var ErrTimeout = errors.New("request timeout")

Functions

func Version 

func Version() string

Types

type ClientConfig 

type ClientConfig struct {
	Consul           api.Config
	ProjectName      string
	LocalIp          string
	HttpPort         int
	LaserServiceName string
	Multiplexer      service_router.Multiplexer
}

type ClientOption 

type ClientOption struct {
	MaxConnPerServer        int                                    `json:"MaxConnPerServer" toml:"MaxConnPerServer"`
	ConnIdleTimeoutMs       int                                    `json:"ConnIdleTimeoutMs" toml:"ConnIdleTimeoutMs"`
	ReceiveTimeoutMs        int                                    `json:"ReceiveTimeoutMs" toml:"ReceiveTimeoutMs"`
	ConnectionRetry         int                                    `json:"ConnectionRetry" toml:"ConnectionRetry"`
	TimeoutRetry            int                                    `json:"TimeoutRetry" toml:"TimeoutRetry"`
	ThriftTransport         service_router.ThriftTransportType     `json:"ThriftTransport" toml:"ThriftTransport"`
	ThriftCompressionMethod service_router.ThriftCompressionMethod `json:"ThriftCompressionMethod" toml:"ThriftCompressionMethod"`
	LoadBalance             string                                 `json:"LoadBalance" toml:"LoadBalance"`
	IpDiffRange             int                                    `json:"IpDiffRange" toml:"IpDiffRange"`
	ReadMode                ReadMode                               `json:"ReadMode" toml:"ReadMode"`
	TargetServerAddress     service_router.ServerAddress           `json:"TargetServerAddress" toml:"TargetServerAddress"`
}

func NewClientOptionFactory 

func NewClientOptionFactory(loadBalance string, timeoutMs int) ClientOption

func (ClientOption) Validate 

func (co ClientOption) Validate() error

type LaserClient 

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

func NewLaserClient 

func NewLaserClient(config *ClientConfig) *LaserClient

func (*LaserClient) AppendSync 

func (client *LaserClient) AppendSync(clientOption ClientOption, key laser.LaserKey, val string) (laser.Status, int64)

func (*LaserClient) DecrSync 

func (client *LaserClient) DecrSync(clientOption ClientOption, key laser.LaserKey) (laser.Status, int64)

func (*LaserClient) DecrbySync 

func (client *LaserClient) DecrbySync(clientOption ClientOption, key laser.LaserKey, step int64) (laser.Status, int64)

func (*LaserClient) DelSync 

func (client *LaserClient) DelSync(clientOption ClientOption, key laser.LaserKey) laser.Status

func (*LaserClient) ExistSync 

func (client *LaserClient) ExistSync(clientOption ClientOption, key laser.LaserKey) (laser.Status, bool)

func (*LaserClient) ExpireAtSync 

func (client *LaserClient) ExpireAtSync(clientOption ClientOption, key laser.LaserKey, time int64) laser.Status

func (*LaserClient) ExpireSync 

func (client *LaserClient) ExpireSync(clientOption ClientOption, key laser.LaserKey, time int64) laser.Status

func (*LaserClient) GetServiceRouter 

func (client *LaserClient) GetServiceRouter() *service_router.Router

func (*LaserClient) GetShardIdAndParititionId 

func (client *LaserClient) GetShardIdAndParititionId(key laser.LaserKey) (int64, uint32)

func (*LaserClient) GetSync 

func (client *LaserClient) GetSync(clientOption ClientOption, key laser.LaserKey) (laser.Status, string)

func (*LaserClient) GetTableSchema 

func (client *LaserClient) GetTableSchema(databaseName, tableName string) (lib.TableSchema, bool)

func (*LaserClient) HdelSync 

func (client *LaserClient) HdelSync(clientOption ClientOption, key laser.LaserKey, field string) laser.Status

func (*LaserClient) HexistsSync 

func (client *LaserClient) HexistsSync(clientOption ClientOption, key laser.LaserKey, field string) (laser.Status, bool)

func (*LaserClient) HgetAllSync 

func (client *LaserClient) HgetAllSync(clientOption ClientOption, key laser.LaserKey) (laser.Status, map[string]string)

func (*LaserClient) HgetSync 

func (client *LaserClient) HgetSync(clientOption ClientOption, key laser.LaserKey, field string) (laser.Status, string)

func (*LaserClient) HkeysSync 

func (client *LaserClient) HkeysSync(clientOption ClientOption, key laser.LaserKey) (laser.Status, []string)

func (*LaserClient) HlenSync 

func (client *LaserClient) HlenSync(clientOption ClientOption, key laser.LaserKey) (laser.Status, int64)

func (*LaserClient) HmgetSync 

func (client *LaserClient) HmgetSync(clientOption ClientOption, key laser.LaserKey, fields []string) (laser.Status, map[string]string)

func (*LaserClient) HmsetSync 

func (client *LaserClient) HmsetSync(clientOption ClientOption, key laser.LaserKey, val laser.LaserValue) laser.Status

func (*LaserClient) HsetSync 

func (client *LaserClient) HsetSync(clientOption ClientOption, key laser.LaserKey, field, value string) laser.Status

func (*LaserClient) IncrSync 

func (client *LaserClient) IncrSync(clientOption ClientOption, key laser.LaserKey) (laser.Status, int64)

func (*LaserClient) IncrbySync 

func (client *LaserClient) IncrbySync(clientOption ClientOption, key laser.LaserKey, step int64) (laser.Status, int64)

func (*LaserClient) LindexSync 

func (client *LaserClient) LindexSync(clientOption ClientOption, key laser.LaserKey, index int32) (laser.Status, string)

func (*LaserClient) LlenSync 

func (client *LaserClient) LlenSync(clientOption ClientOption, key laser.LaserKey) (laser.Status, int64)

func (*LaserClient) LpopSync 

func (client *LaserClient) LpopSync(clientOption ClientOption, key laser.LaserKey) (laser.Status, string)

func (*LaserClient) LpushSync 

func (client *LaserClient) LpushSync(clientOption ClientOption, key laser.LaserKey, val string) laser.Status

func (*LaserClient) LrangeSync 

func (client *LaserClient) LrangeSync(clientOption ClientOption, key laser.LaserKey, start, end int32) (laser.Status, []string)

func (*LaserClient) MgetDetailSync 

func (client *LaserClient) MgetDetailSync(clientOption ClientOption, keys []laser.LaserKey) (laser.Status, []*laser.EntryValue)

func (*LaserClient) MgetSync 

func (client *LaserClient) MgetSync(clientOption ClientOption, keys []laser.LaserKey) (laser.Status, []laser.LaserValue)

func (*LaserClient) MsetDetailSync 

func (client *LaserClient) MsetDetailSync(clientOption ClientOption, laserSetOpt laser.LaserSetOption, kvs []laser.LaserKV) (laser.Status, []*laser.EntryValue)

func (*LaserClient) MsetSync 

func (client *LaserClient) MsetSync(clientOption ClientOption, kvs []laser.LaserKV) []laser.Status

func (*LaserClient) RpopSync 

func (client *LaserClient) RpopSync(clientOption ClientOption, key laser.LaserKey) (laser.Status, string)

func (*LaserClient) RpushSync 

func (client *LaserClient) RpushSync(clientOption ClientOption, key laser.LaserKey, val string) laser.Status

func (*LaserClient) SaddSync 

func (client *LaserClient) SaddSync(clientOption ClientOption, key laser.LaserKey, member string) laser.Status

func (*LaserClient) SetSync 

func (client *LaserClient) SetSync(clientOption ClientOption, kv laser.LaserKV) laser.Status

func (*LaserClient) SetxSync 

func (client *LaserClient) SetxSync(clientOption ClientOption, kv laser.LaserKV, setOption laser.LaserSetOption) laser.Status

func (*LaserClient) SismemberSync 

func (client *LaserClient) SismemberSync(clientOption ClientOption, key laser.LaserKey, member string) laser.Status

func (*LaserClient) SmembersSync 

func (client *LaserClient) SmembersSync(clientOption ClientOption, key laser.LaserKey) (laser.Status, []string)

func (*LaserClient) SremoveSync 

func (client *LaserClient) SremoveSync(clientOption ClientOption, key laser.LaserKey, member string) laser.Status

func (*LaserClient) TtlSync 

func (client *LaserClient) TtlSync(clientOption ClientOption, key laser.LaserKey) (laser.Status, int64)

func (*LaserClient) ZaddSync 

func (client *LaserClient) ZaddSync(clientOption ClientOption, key laser.LaserKey, member_scores map[string]float64) (laser.Status, int64)

func (*LaserClient) ZrangeByscoreSync 

func (client *LaserClient) ZrangeByscoreSync(clientOption ClientOption, key laser.LaserKey, min float64, max float64) (laser.Status, []laser.LaserFloatScoreMember)

type ReadMode 

type ReadMode int
const (
	LEADER_READ ReadMode = iota
	FOLLOWER_READ
	MIXED_READ
)

type ThriftProcessRequestFunc 

type ThriftProcessRequestFunc func(c *laser.LaserServiceClient) (*laser.LaserResponse, error)

Source Files

View all Source files

Directories

Path Synopsis
if
laser
laser/laser_service-remote

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.