queue

package

v1.6.3 Latest Latest Go to latest Published: Jan 31, 2026 License: Apache-2.0 Imports: 4 Imported by: 26

Details

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

Repository

github.com/go-admin-team/go-admin-core

Links

Open Source Insights

Documentation ¶

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Memory ¶

type Memory struct {
	PoolNum uint
	// contains filtered or unexported fields
}

func NewMemory ¶

func NewMemory(poolNum uint) *Memory

NewMemory 内存模式

func (*Memory) Append ¶

func (m *Memory) Append(message storage.Messager) error

func (*Memory) Register ¶

func (m *Memory) Register(name string, f storage.ConsumerFunc)

func (*Memory) Run ¶

func (m *Memory) Run()

func (*Memory) Shutdown ¶

func (m *Memory) Shutdown()

func (*Memory) String ¶

func (*Memory) String() string

type Message ¶

type Message struct {
	ID         string
	Stream     string
	Values     map[string]interface{}
	ErrorCount int
	// contains filtered or unexported fields
}

func (*Message) GetErrorCount ¶ added in v1.3.10

func (m *Message) GetErrorCount() int

func (*Message) GetID ¶

func (m *Message) GetID() string

func (*Message) GetPrefix ¶

func (m *Message) GetPrefix() (prefix string)

func (*Message) GetStream ¶

func (m *Message) GetStream() string

func (*Message) GetValues ¶

func (m *Message) GetValues() map[string]interface{}

func (*Message) SetErrorCount ¶ added in v1.3.10

func (m *Message) SetErrorCount(count int)

func (*Message) SetID ¶

func (m *Message) SetID(id string)

func (*Message) SetPrefix ¶

func (m *Message) SetPrefix(prefix string)

func (*Message) SetStream ¶

func (m *Message) SetStream(stream string)

func (*Message) SetValues ¶

func (m *Message) SetValues(values map[string]interface{})

Source Files ¶

View all Source files

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