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

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
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