udspubsub

README

udspubsub

pubsub implementation using unix domain socket in golang

Install

go get -u github.com/Sab94/udspubsub

Examples

Check out the example and the test

Project52

It is one of my project 52.

Documentation

Index

• Constants
• Variables
• type Client
• type Message
• type PubSubClient
  • func NewPubSubClient(socketPath string) (*PubSubClient, error)
  • func (p *PubSubClient) Publish(topic string, message []byte) error
  • func (p *PubSubClient) Subscribe(topic string) (chan string, error)
  • func (p *PubSubClient) Unsubscribe(topic string) error
• type PubSubHandler
  • func Listener(socketPath string) *PubSubHandler
  • func (ps *PubSubHandler) GetClientSubscriptions(client *Client) []Subscription
  • func (ps *PubSubHandler) GetTopicSubscriptions(topic string) []Subscription
  • func (ps *PubSubHandler) IsClientSubscribed(topic string, client *Client) bool
• type Subscription

Constants

const (
	PUBLISH     = "publish"
	SUBSCRIBE   = "subscribe"
	UNSUBSCRIBE = "unsubscribe"
)

const MAX_BUFFER = 1024

Variables

var Topics = []string{}

Types

type Client

type Client struct {
	Id         string
	Connection net.Conn
}

type Message

type Message struct {
	Action  string `json:"action"`
	Topic   string `json:"topic"`
	Message []byte `json:"message"`
}

type PubSubClient

type PubSubClient struct {
	ID string
	// contains filtered or unexported fields
}

func NewPubSubClient

func NewPubSubClient(socketPath string) (*PubSubClient, error)

func (*PubSubClient) Publish

func (p *PubSubClient) Publish(topic string, message []byte) error

func (*PubSubClient) Subscribe

func (p *PubSubClient) Subscribe(topic string) (chan string, error)

func (*PubSubClient) Unsubscribe

func (p *PubSubClient) Unsubscribe(topic string) error

type PubSubHandler

type PubSubHandler struct {
	Clients       []Client
	Subscriptions []Subscription
}

func Listener

func Listener(socketPath string) *PubSubHandler

func (*PubSubHandler) GetClientSubscriptions

func (ps *PubSubHandler) GetClientSubscriptions(client *Client) []Subscription

func (*PubSubHandler) GetTopicSubscriptions

func (ps *PubSubHandler) GetTopicSubscriptions(topic string) []Subscription

func (*PubSubHandler) IsClientSubscribed

func (ps *PubSubHandler) IsClientSubscribed(topic string, client *Client) bool

type Subscription

type Subscription struct {
	Topic  string
	Client *Client
}