frameworks

Documentation

Index

• Variables
• func Grpc() (disconnectors []func())
• func Http() (disconnectors []func())
• func RabbitMQ() (disconnectors []func())
• func Tcp() (disconnectors []func())
• func WebSocket() (disconnectors []func())
• type HttpServer
  • func (r *HttpServer) Disconnect()
• type RabbitPublisher
  • func (r *RabbitPublisher) Publish(event types.IEvent) (err error)

Variables

var GrpcConfig types.IGrpcConfig

gRPC framework configurations

var HttpConfig types.IHttpServer

HTTP Configurations

var RabbitMQConfig types.IRabbitMQConfig

Initialize RabbitMQ Configuration.

var TcpConfig types.ITcpConfig

TCP Configurations

var WebSocketConfig types.IWebSocketServer

WebSocket Configurations

Functions

func Grpc

func Grpc() (disconnectors []func())

Run gRPC server and client

func Http

func Http() (disconnectors []func())

Start http service

func RabbitMQ

func RabbitMQ() (disconnectors []func())

Define rabbit service host and port

func Tcp

func Tcp() (disconnectors []func())

Start http service

func WebSocket

func WebSocket() (disconnectors []func())

Start WebSocket service

Types

type HttpServer

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

HTTP service struct

func (*HttpServer) Disconnect

func (r *HttpServer) Disconnect()

type RabbitPublisher

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

RabbitMQ publisher definitions.

func (*RabbitPublisher) Publish

func (r *RabbitPublisher) Publish(event types.IEvent) (err error)