pusher

README

Pusher

Simple use of publish/subscribe in web, grpc, graphQL

Contributing

You can commit PR to this repository

Overview

• This is a sample pub/sub library, but useful
• Irregularly updated

How to get it?

go get -u github.com/gobkc/pusher

Quick start

package main

import (
	"fmt"
	"github.com/gobkc/pusher"
	"sync"
)

type User struct {
	Name     string `json:"name"`
	Password string `json:"password"`
}

func main() {
	pushUser := User{
		Name:     "test user",
		Password: "123456",
	}
	topic := "test topic"
	wg := sync.WaitGroup{}
	wg.Add(2)
	pusher.Subs(topic, func(cb pusher.SubsCallback) {
		var user User
		cb.Bind(&user)
		fmt.Println(user)
		wg.Done()
	})
	pusher.Subs(topic, func(cb pusher.SubsCallback) {
		var user User
		cb.Bind(&user)
		fmt.Println(user)
		wg.Done()
	})
	pusher.Push(topic, pushUser)
	wg.Wait()
}

License

© Gobkc, 2022~time.Now

Released under the Apache License

Documentation

Index

• Variables
• func Push[T any](data T)
• func Subs[T Subscriber](receiver any, f func(cb T))
• type GoPusher
  • func (p *GoPusher) Logger() *slog.Logger
  • func (p *GoPusher) Push(data any)
  • func (p *GoPusher) ReportEventCompleted(d any)
  • func (p *GoPusher) ReportEventRegistered(d any)
  • func (p *GoPusher) ReportEventStart(d any)
  • func (p *GoPusher) Subs(ds any, callback func(cdata any))
• type Pusher
  • func New(functions ...func(settings *Setting)) Pusher
• type Setting
• type Subscriber
• type SubscriberCallBackImpl
  • func (s SubscriberCallBackImpl) Bind(data any) error
  • func (s SubscriberCallBackImpl) Set(data any) Subscriber

Variables

var CallBackTypeError = errors.New(`checkIsSlice:dest must be a struct pointer`)

Functions

func Push

func Push[T any](data T)

func Subs

func Subs[T Subscriber](receiver any, f func(cb T))

Types

type GoPusher

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

func (*GoPusher) Logger

func (p *GoPusher) Logger() *slog.Logger

func (*GoPusher) Push

func (p *GoPusher) Push(data any)

func (*GoPusher) ReportEventCompleted

func (p *GoPusher) ReportEventCompleted(d any)

func (*GoPusher) ReportEventRegistered

func (p *GoPusher) ReportEventRegistered(d any)

func (*GoPusher) ReportEventStart

func (p *GoPusher) ReportEventStart(d any)

func (*GoPusher) Subs

func (p *GoPusher) Subs(ds any, callback func(cdata any))

type Pusher

type Pusher interface {
	Push(data any)
	//Subs
	//d: this parameter represents the data used by the Push function.
	Subs(d any, callback func(msg any))
	Logger() *slog.Logger
}

func New

func New(functions ...func(settings *Setting)) Pusher

type Setting

type Setting struct {
	Interval        time.Duration
	ConcurrentLimit int
	EnabledLog      bool
}

type Subscriber

type Subscriber interface {
	Bind(data any) error
	Set(data any) Subscriber
}

type SubscriberCallBackImpl

type SubscriberCallBackImpl struct {
	Data any
}

func (SubscriberCallBackImpl) Bind

func (s SubscriberCallBackImpl) Bind(data any) error

func (SubscriberCallBackImpl) Set

func (s SubscriberCallBackImpl) Set(data any) Subscriber