customer

package

v0.0.0-...-d804a77 Latest Latest Go to latest Published: Mar 10, 2023 License: Apache-2.0 Imports: 16 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/coming-chat/go-sui-indexer

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
type BaseKafkaCustomer
type BaseRedisCustomer
- func NewBaseRedisCustomer(c config.QueueConfig, cache *cache.Redis) BaseRedisCustomer
type Customer
- func NewCustomer(ctx context.Context, db *model.SuiDB, cr *cache.Redis) Customer
type KafkaCustomer
type ObjectCustomer
- func NewObjectCustomer(c config.Config, cc config.QueueConfig, db *model.SuiDB, cr *client.Client, ...) *ObjectCustomer
- func (o *ObjectCustomer) ConsumeRedisMessage(message redis.XMessage) error
- func (o *ObjectCustomer) ProcessRedisFailedMessage(message redis.XMessage, fromErr error) error
type RedisCustomer
type SubCustomer
type TransactionCustomer
- func NewTransactionCustomer(c config.Config, cc config.QueueConfig, db *model.SuiDB, cr *client.Client, ...) *TransactionCustomer
- func (t *TransactionCustomer) ConsumeRedisMessage(message redis.XMessage) error
- func (t *TransactionCustomer) ProcessRedisFailedMessage(message redis.XMessage, fromErr error) error

Constants ¶

View Source

const KafkaFrameType = "Kafka"

View Source

const RedisFrameType = "redis"

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type BaseKafkaCustomer ¶

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

func (*BaseKafkaCustomer) ConsumeMessage ¶

func (b *BaseKafkaCustomer) ConsumeMessage(message interface{}) error

func (*BaseKafkaCustomer) GetCustomerQuantity ¶

func (b *BaseKafkaCustomer) GetCustomerQuantity() int

func (*BaseKafkaCustomer) GetCustomerType ¶

func (b *BaseKafkaCustomer) GetCustomerType() string

func (*BaseKafkaCustomer) GetGroupId ¶

func (b *BaseKafkaCustomer) GetGroupId() string

func (*BaseKafkaCustomer) GetTopic ¶

func (b *BaseKafkaCustomer) GetTopic() string

func (*BaseKafkaCustomer) InitCustomer ¶

func (b *BaseKafkaCustomer) InitCustomer() error

func (*BaseKafkaCustomer) StartConsume ¶

func (b *BaseKafkaCustomer) StartConsume(ctx context.Context)

func (*BaseKafkaCustomer) WaitClose ¶

func (b *BaseKafkaCustomer) WaitClose()

type BaseRedisCustomer ¶

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

func NewBaseRedisCustomer ¶

func NewBaseRedisCustomer(c config.QueueConfig, cache *cache.Redis) BaseRedisCustomer

func (*BaseRedisCustomer) ConsumeMessage ¶

func (r *BaseRedisCustomer) ConsumeMessage(message interface{}) error

func (*BaseRedisCustomer) ConsumePendingMessage ¶

func (r *BaseRedisCustomer) ConsumePendingMessage()

func (*BaseRedisCustomer) GetCustomerQuantity ¶

func (r *BaseRedisCustomer) GetCustomerQuantity() int

func (*BaseRedisCustomer) GetCustomerType ¶

func (r *BaseRedisCustomer) GetCustomerType() string

func (*BaseRedisCustomer) GetGroupId ¶

func (r *BaseRedisCustomer) GetGroupId() string

func (*BaseRedisCustomer) GetTopic ¶

func (r *BaseRedisCustomer) GetTopic() string

func (*BaseRedisCustomer) InitCustomer ¶

func (r *BaseRedisCustomer) InitCustomer() error

func (*BaseRedisCustomer) StartConsume ¶

func (r *BaseRedisCustomer) StartConsume(ctx context.Context)

func (*BaseRedisCustomer) TrimQueueList ¶

func (r *BaseRedisCustomer) TrimQueueList(ctx context.Context)

func (*BaseRedisCustomer) WaitClose ¶

func (r *BaseRedisCustomer) WaitClose()

type Customer ¶

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

func NewCustomer ¶

func NewCustomer(ctx context.Context, db *model.SuiDB, cr *cache.Redis) Customer

func (*Customer) InitCustomers ¶

func (c *Customer) InitCustomers()

func (*Customer) ProcessFailedMessage ¶

func (c *Customer) ProcessFailedMessage()

func (*Customer) RegisterCustomer ¶

func (c *Customer) RegisterCustomer(customers ...SubCustomer)

func (*Customer) StartConsume ¶

func (c *Customer) StartConsume()

func (*Customer) WaitClose ¶

func (c *Customer) WaitClose()

type KafkaCustomer ¶

type KafkaCustomer interface {
	SubCustomer
	ConsumeKafkaMessage(message kafka.Message) error
	ProcessKafkaFailedMessage(message kafka.Message, fromErr error) error
}

type ObjectCustomer ¶

type ObjectCustomer struct {
	BaseRedisCustomer
	// contains filtered or unexported fields
}

func NewObjectCustomer ¶

func NewObjectCustomer(c config.Config, cc config.QueueConfig, db *model.SuiDB, cr *client.Client, rc *cache.Redis) *ObjectCustomer

func (*ObjectCustomer) ConsumeRedisMessage ¶

func (o *ObjectCustomer) ConsumeRedisMessage(message redis.XMessage) error

func (*ObjectCustomer) ProcessRedisFailedMessage ¶

func (o *ObjectCustomer) ProcessRedisFailedMessage(message redis.XMessage, fromErr error) error

type RedisCustomer ¶

type RedisCustomer interface {
	SubCustomer
	ConsumeRedisMessage(message redis.XMessage) error
	ProcessRedisFailedMessage(message redis.XMessage, fromErr error) error
}

type SubCustomer ¶

type SubCustomer interface {
	InitCustomer() error
	GetCustomerType() string
	GetTopic() string
	GetGroupId() string
	GetCustomerQuantity() int
	WaitClose()

	ConsumeMessage(message interface{}) error
	StartConsume(ctx context.Context)
}

type TransactionCustomer ¶

type TransactionCustomer struct {
	BaseRedisCustomer
	// contains filtered or unexported fields
}

func NewTransactionCustomer ¶

func NewTransactionCustomer(c config.Config, cc config.QueueConfig, db *model.SuiDB, cr *client.Client, rc *cache.Redis) *TransactionCustomer

func (*TransactionCustomer) ConsumeRedisMessage ¶

func (t *TransactionCustomer) ConsumeRedisMessage(message redis.XMessage) error

func (*TransactionCustomer) ProcessRedisFailedMessage ¶

func (t *TransactionCustomer) ProcessRedisFailedMessage(message redis.XMessage, fromErr error) error

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL