v1

Documentation

Overview

Message Queue

Index

• type DataBus
  • func (mq *DataBus) Use(ctx context.Context, log logger.Logger) (MQ, error)
• type MQ

Types

type DataBus

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

DataBus abstract type

func (*DataBus) Use

func (mq *DataBus) Use(ctx context.Context, log logger.Logger) (MQ, error)

Use return implementation of MQ

type MQ

type MQ interface {
	// setting
	Init(context.Context) error
	io.Closer // Closer is the interface that wraps the basic Close method.

	// Pub/Sub a pattern
	Publish(ctx context.Context, target string, message query.Message) error
	Subscribe(target string, message query.Response) error
	UnSubscribe(target string) error
}

MQ - common interface of DataBus