mq

Documentation

Index

• func NewBlobDeleteMgr(cfg BlobDeleteConfig) (*blobDeleteMgr, error)
• func NewShardRepairMgr(cfg ShardRepairConfig) (*shardRepairMgr, error)
• type BlobDeleteConfig
• type BlobDeleteHandler
• type Producer
• type ShardRepairConfig
• type ShardRepairHandler

Functions

func NewBlobDeleteMgr

func NewBlobDeleteMgr(cfg BlobDeleteConfig) (*blobDeleteMgr, error)

NewBlobDeleteMgr returns blob delete manager to handle delete message

func NewShardRepairMgr

func NewShardRepairMgr(cfg ShardRepairConfig) (*shardRepairMgr, error)

NewShardRepairMgr returns shard repair manager

Types

type BlobDeleteConfig

type BlobDeleteConfig struct {
	Topic        string            `json:"topic"`
	MsgSenderCfg kafka.ProducerCfg `json:"msg_sender_cfg"`
}

BlobDeleteConfig is blob delete config

type BlobDeleteHandler

type BlobDeleteHandler interface {
	SendDeleteMsg(ctx context.Context, info *proxy.DeleteArgs) error
}

BlobDeleteHandler stream http handler

type Producer

type Producer interface {
	kafka.MsgProducer
}

Producer is used to send messages to kafka

type ShardRepairConfig

type ShardRepairConfig struct {
	Topic         string            `json:"topic"`
	PriorityTopic string            `json:"priority_topic"`
	MsgSenderCfg  kafka.ProducerCfg `json:"msg_sender_cfg"`
}

ShardRepairConfig is shard repair config

type ShardRepairHandler

type ShardRepairHandler interface {
	SendShardRepairMsg(ctx context.Context, info *proxy.ShardRepairArgs) error
}

ShardRepairHandler stream http handler