kv

Documentation

Index

• func NewKVProcessor(nc *nats.Conn, dir string) processor.Processor
• type KVProcessor
  • func (p *KVProcessor) Process(cons jetstream.Consumer)
  • func (p *KVProcessor) Start()
  • func (p *KVProcessor) Subscribe()

Functions

func NewKVProcessor

func NewKVProcessor(nc *nats.Conn, dir string) processor.Processor

Types

type KVProcessor

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

func (*KVProcessor) Process

func (p *KVProcessor) Process(cons jetstream.Consumer)

func (*KVProcessor) Start

func (p *KVProcessor) Start()

func (*KVProcessor) Subscribe

func (p *KVProcessor) Subscribe()