gohare

README

gohare

Golang pub-sub framework.

Framework which allows you easliy create pub-sub microsevices infrastrucutre, using GoLang, with consistant api, and concurrent rpc requests where necessary.

Documentation

Works are currently in progress, it will appear soon

Still under developement, if you are interested in contribution, contact with me

Documentation

Index

• func JsonToStruct(rawResponse []byte, jsonResponse interface{})
• type ErrorForm
  • func MakeErrorResponse(message string) (ErrorForm, bool)
• type Event
  • func (eve *Event) Error(errorMessage string)
  • func (eve *Event) GetResponse(response interface{}) []byte
  • func (eve *Event) MakeResponse(response interface{})
  • func (e *Event) Send(routingKey string, messageBody []byte)
• type Handler
• type Rabbit
  • func NewHare(url string, queueName string) *Rabbit
  • func (r *Rabbit) Listen()
  • func (r *Rabbit) Publish(sendR sendRequest)
  • func (r *Rabbit) Request(requests []*RequestForm)
  • func (r *Rabbit) Subscribe(routingKey string, handler func(event *Event), rpc bool)
• type RequestForm
  • func NewRequest(routingKey string, messageBody []byte) *RequestForm

Functions

func JsonToStruct

func JsonToStruct(rawResponse []byte, jsonResponse interface{})

Types

type ErrorForm

type ErrorForm struct {
	ErrorMessage string `json:"error"`
}

func MakeErrorResponse

func MakeErrorResponse(message string) (ErrorForm, bool)

type Event

type Event struct {
	Message *amqp.Delivery
	// contains filtered or unexported fields
}

func (*Event) Error

func (eve *Event) Error(errorMessage string)

func (*Event) GetResponse

func (eve *Event) GetResponse(response interface{}) []byte

func (*Event) MakeResponse

func (eve *Event) MakeResponse(response interface{})

func (*Event) Send

func (e *Event) Send(routingKey string, messageBody []byte)

type Handler

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

type Rabbit

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

func NewHare

func NewHare(url string, queueName string) *Rabbit

func (*Rabbit) Listen

func (r *Rabbit) Listen()

Main listening function

func (*Rabbit) Publish

func (r *Rabbit) Publish(sendR sendRequest)

func (*Rabbit) Request

func (r *Rabbit) Request(requests []*RequestForm)

func (*Rabbit) Subscribe

func (r *Rabbit) Subscribe(routingKey string, handler func(event *Event), rpc bool)

type RequestForm

type RequestForm struct {
	RoutingKey      string
	MessageBody     []byte
	CorrelationId   string
	Response        []byte
	IsResponseError bool
}

func NewRequest

func NewRequest(routingKey string, messageBody []byte) *RequestForm