message

package
v1.7.1 Latest Latest
Warning

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

Go to latest
Published: Dec 24, 2024 License: Apache-2.0 Imports: 2 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type MsgNormal

type MsgNormal struct {
	Type      string            `json:"type"`
	User      string            `json:"user"`
	Desc      string            `json:"desc"`
	Details   map[string]string `json:"details"`
	CreatedAt int64             `json:"created_at"`
}

type MsgOperateLog

type MsgOperateLog struct {
	When int64             `json:"when"`
	User string            `json:"user"`
	Type string            `json:"type"`
	Info map[string]string `json:"info,omitempty"`
}

type OperateLogPublisher

type OperateLogPublisher interface {
	SendOperateLog(user domain.Account, t string, info map[string]string) error
}

type Publisher

type Publisher interface {
	Publish(topic string, v interface{}, header map[string]string) error
}

type Subscriber

type Subscriber interface {
	SubscribeWithStrategyOfRetry(group string, h kfklib.Handler, topics []string, retryNum int) error
}

type TopicConfig

type TopicConfig struct {
	// Name is the event name
	Name  string `json:"name"   required:"true"`
	Topic string `json:"topic"  required:"true"`
}

Jump to

Keyboard shortcuts

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