Documentation ¶
Index ¶
- Variables
- func NewHandler(service *Service) *rpc.Router
- type Config
- type MQConfig
- type Service
- func (s *Service) Alloc(c *rpc.Context)
- func (s *Service) EraseCache(c *rpc.Context)
- func (s *Service) GetCacheDisk(c *rpc.Context)
- func (s *Service) GetCacheVolume(c *rpc.Context)
- func (s *Service) List(c *rpc.Context)
- func (s *Service) SendDeleteMessage(c *rpc.Context)
- func (s *Service) SendRepairMessage(c *rpc.Context)
Constants ¶
This section is empty.
Variables ¶
View Source
var ( // ErrIllegalTopic illegal topic ErrIllegalTopic = errors.New("illegal topic") )
Functions ¶
func NewHandler ¶
Types ¶
type Config ¶
type Config struct { cmd.Config alloc.BlobConfig alloc.VolConfig cacher.ConfigCache HeartbeatIntervalS uint32 `json:"heartbeat_interval_s"` // proxy heartbeat interval to ClusterManager HeartbeatTicks uint32 `json:"heartbeat_ticks"` ExpiresTicks uint32 `json:"expires_ticks"` Clustermgr clustermgr.Config `json:"clustermgr"` MQ MQConfig `json:"mq"` }
type MQConfig ¶
type MQConfig struct { BlobDeleteTopic string `json:"blob_delete_topic"` ShardRepairTopic string `json:"shard_repair_topic"` ShardRepairPriorityTopic string `json:"shard_repair_priority_topic"` MsgSender kafka.ProducerCfg `json:"msg_sender"` }
MQConfig is mq config
type Service ¶
type Service struct { Config // contains filtered or unexported fields }
func (*Service) EraseCache ¶
EraseCache remove cache in cacher.
func (*Service) GetCacheDisk ¶
GetCacheDisk returns disk info in cacher.
func (*Service) GetCacheVolume ¶
GetCacheVolume returns volume in cacher.
func (*Service) SendDeleteMessage ¶
SendDeleteMessage send delete message to kafka 1. message from access because of put object fail 2. message from access because of business side delete
func (*Service) SendRepairMessage ¶
SendRepairMessage send repair message to kafka 1. message from access 2. message from scheduler
Click to show internal directories.
Click to hide internal directories.