queue

package

v0.44.0 Latest Latest Go to latest Published: Sep 21, 2023 License: Apache-2.0 Imports: 7 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/donnol/tools

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func RegisterProxyMethod(pctx inject.ProxyContext, cf inject.CtxFunc)
type Consumer
type ConsumerMock
- func (mockRecv *ConsumerMock) Consume(topic Topic, f func(msg Message) error) error
type Element
type MemMessage
- func (msg *MemMessage[T]) Marshal() ([]byte, error)
- func (msg *MemMessage[T]) Unmarshal(data []byte) error
type MemReceipt
- func (receipt *MemReceipt) String() string
type Message
type MessageMock
- func (mockRecv *MessageMock) Marshal() ([]byte, error)
- func (mockRecv *MessageMock) Unmarshal(p0 []byte) error
type Producer
type ProducerMock
- func (mockRecv *ProducerMock) Produce(topic Topic, msg Message) (Receipt, error)
type Queue
- func NewQueue[T Message]() Queue
type Receipt
type ReceiptMock
- func (mockRecv *ReceiptMock) String() string
type Topic
type TopicMock
- func (mockRecv *TopicMock) Name() string

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	MessageMockMarshalProxyContext = func() (pctx inject.ProxyContext) {
		pctx = messageMockCommonProxyContext
		pctx.MethodName = "Marshal"
		return
	}()
	MessageMockUnmarshalProxyContext = func() (pctx inject.ProxyContext) {
		pctx = messageMockCommonProxyContext
		pctx.MethodName = "Unmarshal"
		return
	}()
)

View Source

var (
	ConsumerMockConsumeProxyContext = func() (pctx inject.ProxyContext) {
		pctx = consumerMockCommonProxyContext
		pctx.MethodName = "Consume"
		return
	}()
)

View Source

var (
	ProducerMockProduceProxyContext = func() (pctx inject.ProxyContext) {
		pctx = producerMockCommonProxyContext
		pctx.MethodName = "Produce"
		return
	}()
)

View Source

var (
	ReceiptMockStringProxyContext = func() (pctx inject.ProxyContext) {
		pctx = receiptMockCommonProxyContext
		pctx.MethodName = "String"
		return
	}()
)

View Source

var (
	TopicMockNameProxyContext = func() (pctx inject.ProxyContext) {
		pctx = topicMockCommonProxyContext
		pctx.MethodName = "Name"
		return
	}()
)

Functions ¶

func RegisterProxyMethod ¶

func RegisterProxyMethod(pctx inject.ProxyContext, cf inject.CtxFunc)

Types ¶

type Consumer ¶

type Consumer interface {
	Consume(topic Topic, f func(msg Message) error) error
}

type ConsumerMock ¶

type ConsumerMock struct {
	ConsumeFunc func(topic Topic, f func(msg Message) error) error
}

func (*ConsumerMock) Consume ¶

func (mockRecv *ConsumerMock) Consume(topic Topic, f func(msg Message) error) error

type Element ¶

type Element interface {
	~int | ~string | ~struct{ Name string }
}

type MemMessage ¶

type MemMessage[T Element] struct {
	Id   string       `json:"id"`
	Data map[string]T `json:"data"`
}

func (*MemMessage[T]) Marshal ¶

func (msg *MemMessage[T]) Marshal() ([]byte, error)

func (*MemMessage[T]) Unmarshal ¶

func (msg *MemMessage[T]) Unmarshal(data []byte) error

type MemReceipt ¶

type MemReceipt struct {
	Id string `json:"id"`
}

func (*MemReceipt) String ¶

func (receipt *MemReceipt) String() string

type Message ¶

type Message interface {
	Marshal() ([]byte, error)
	Unmarshal([]byte) error
}

type MessageMock ¶

type MessageMock struct {
	MarshalFunc func() ([]byte, error)

	UnmarshalFunc func([]byte) error
}

func (*MessageMock) Marshal ¶

func (mockRecv *MessageMock) Marshal() ([]byte, error)

func (*MessageMock) Unmarshal ¶

func (mockRecv *MessageMock) Unmarshal(p0 []byte) error

type Producer ¶

type Producer interface {
	Produce(topic Topic, msg Message) (Receipt, error)
}

type ProducerMock ¶

type ProducerMock struct {
	ProduceFunc func(topic Topic, msg Message) (Receipt, error)
}

func (*ProducerMock) Produce ¶

func (mockRecv *ProducerMock) Produce(topic Topic, msg Message) (Receipt, error)

type Queue ¶

type Queue interface {
	AddTopic(name string) Topic
	TopicByName(name string) (Topic, bool)
	Topics() []Topic

	Producer
	Consumer
}

func NewQueue ¶

func NewQueue[T Message]() Queue

type Receipt ¶

type Receipt interface {
	String() string
}

type ReceiptMock ¶

type ReceiptMock struct {
	StringFunc func() string
}

func (*ReceiptMock) String ¶

func (mockRecv *ReceiptMock) String() string

type Topic ¶

type Topic interface {
	Name() string
}

type TopicMock ¶

type TopicMock struct {
	NameFunc func() string
}

func (*TopicMock) Name ¶

func (mockRecv *TopicMock) Name() string

Source Files ¶

View all Source files

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