plant

package module

v0.1.0 Latest Latest Go to latest Published: Dec 23, 2021 License: MIT Imports: 11 Imported by: 0

Details

View Source

const MiddlewareName = "plant"

This section is empty.

func Consume(ctx context.Context, containers ...interface{}) (abstract.OnceSubscription, bool)

Consume 从生产者处消费数据，请不要对指针类型数据进行修改

func KeepConsume(ctx context.Context, containers ...interface{}) (abstract.Subscription, bool)

KeepConsume 持续从生产者处消费数据，请不要对指针类型数据进行修改

func Put(ctx context.Context, material interface{}) error

func RegisterSetUp(name string, full bool, setUp SetUp)

name the plant name full 是否需要全量权限

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

func (m *Middleware) Init(opt []mist.Option)

func (m *Middleware) Inter(full bool) mist.Interceptor

func (m *Middleware) Run(ctx context.Context, info *mist.ServerInfo) error

type SetUp func() (productor abstract.Productor, materials []interface{}, product interface{})