gochan

Documentation

Index

• type Proxy
  • func New(poolSize int, encoder ...encoder) *Proxy
  • func (p *Proxy) Close() error
  • func (p *Proxy) Listen(ctx context.Context) error
  • func (p *Proxy) Publisher() Publisher
• type Publisher
  • func (p Publisher) Publish(ctx context.Context, messages ...any) error

Types

type Proxy

type Proxy struct {
	nc.ModelSubscriber
	// contains filtered or unexported fields
}

Proxy object with native implementation of message pools in GO

func New

func New(poolSize int, encoder ...encoder) *Proxy

New proxy object

func (*Proxy) Close

func (p *Proxy) Close() error

Close current proxy pool

func (*Proxy) Listen

func (p *Proxy) Listen(ctx context.Context) error

Listen starts processing queue

func (*Proxy) Publisher

func (p *Proxy) Publisher() Publisher

Publisher writer accessor

type Publisher

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

Publisher writer for GO proxy server

func (Publisher) Publish

func (p Publisher) Publish(ctx context.Context, messages ...any) error

Publish one or more messages to the pub-service