api

Documentation

Index

• type Server
  • func NewServer(port string) *Server
  • func (s *Server) AddEventToService()
  • func (s *Server) AddRouter(path string, handler func(w http.ResponseWriter, r *http.Request), ...)
  • func (s *Server) AllRouters()
  • func (s *Server) CreateClients()
  • func (s *Server) CreateServices()
  • func (s *Server) CreateSubscription()
  • func (s *Server) DeleteClients()
  • func (s *Server) DeleteServices()
  • func (s *Server) DeleteSubscription()
  • func (s *Server) GetClients()
  • func (s *Server) GetServices()
  • func (s *Server) GetServicesEvents()
  • func (s *Server) Health()
  • func (s *Server) ListClients()
  • func (s *Server) ListServices()
  • func (s *Server) ListSubscriptions()
  • func (s *Server) Notification()
  • func (s *Server) Run() error
  • func (s *Server) TestNotification()

Types

type Server

type Server struct {

	// LogManager         *producer.LoggerManager
	Dynamo         *infra.DynamodbClient
	Sqs            *infra.SqsClient
	RabbitMQClient *infra.RabbitMQ
	// contains filtered or unexported fields
}

Server is struct for service api

func NewServer

func NewServer(port string) *Server

NewServer return new service api

func (*Server) AddEventToService

func (s *Server) AddEventToService()

AddEventToService execute append the new events to service

func (*Server) AddRouter

func (s *Server) AddRouter(path string, handler func(w http.ResponseWriter, r *http.Request), middlewares ...mux.MiddlewareFunc)

AddRouter add dynamic router for server

func (*Server) AllRouters

func (s *Server) AllRouters()

AllRouters execute all routers the server

func (*Server) CreateClients

func (s *Server) CreateClients()

CreateClients execute creation the clients in table

func (*Server) CreateServices

func (s *Server) CreateServices()

CreateServices execute creation of services

func (*Server) CreateSubscription

func (s *Server) CreateSubscription()

CreateSubscription is function the creation subscriptions

func (*Server) DeleteClients

func (s *Server) DeleteClients()

DeleteClients remove client the service

func (*Server) DeleteServices

func (s *Server) DeleteServices()

DeletServices remove service or single events the service

func (*Server) DeleteSubscription

func (s *Server) DeleteSubscription()

DeleteSubscription remove all or single event the subscription

func (*Server) GetClients

func (s *Server) GetClients()

GetClients return all clients by service

func (*Server) GetServices

func (s *Server) GetServices()

GetServices return service events

func (*Server) GetServicesEvents

func (s *Server) GetServicesEvents()

GetServicesEvents return all events from service

func (*Server) Health

func (s *Server) Health()

Health is function the health server

func (*Server) ListClients

func (s *Server) ListClients()

ListClients return all clients the table

func (*Server) ListServices

func (s *Server) ListServices()

ListServices return all services the table

func (*Server) ListSubscriptions

func (s *Server) ListSubscriptions()

ListSubscription return all subscriptions the client

func (*Server) Notification

func (s *Server) Notification()

TestNotification execute the send message to queue

func (*Server) Run

func (s *Server) Run() error

Run execute router and listen the server

func (*Server) TestNotification

func (s *Server) TestNotification()

TestNotification by client execute the send message to queue