api

Documentation

Index

• Constants
• type ApiSpecServer
  • func NewApiSpecServer(r *mux.Router, urlPrefix string, f string) *ApiSpecServer
  • func (s *ApiSpecServer) Routes()
• type ConnectionMediatorV2
  • func NewConnectionMediatorV2(byClientID connection_repository.GetConnectionByClientID, ...) *ConnectionMediatorV2
  • func (this *ConnectionMediatorV2) Routes()
• type ManagementServer
  • func NewManagementServer(byClientID connection_repository.GetConnectionByClientID, ...) *ManagementServer
  • func (s *ManagementServer) Routes()
• type MessageReceiver
  • func NewMessageReceiver(byClientID connection_repository.GetConnectionByClientID, ...) *MessageReceiver
  • func (jr *MessageReceiver) Routes()
• type MonitoringServer
  • func NewMonitoringServer(r *mux.Router, cfg *config.Config) *MonitoringServer
  • func (s *MonitoringServer) Routes()

Constants

const (
	CONNECTED_STATUS     = "connected"
	DISCONNECTED_STATUS  = "disconnected"
	DECODE_ERROR         = "Unable to process json input"
	NEGATIVE_DELAY_ERROR = "Delay field cannot be negative"
	PING_ERROR           = "Ping failed"
)

Types

type ApiSpecServer

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

func NewApiSpecServer

func NewApiSpecServer(r *mux.Router, urlPrefix string, f string) *ApiSpecServer

func (*ApiSpecServer) Routes

func (s *ApiSpecServer) Routes()

type ConnectionMediatorV2

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

func NewConnectionMediatorV2

func NewConnectionMediatorV2(byClientID connection_repository.GetConnectionByClientID, byOrgID connection_repository.GetConnectionsByOrgID, proxyFactory controller.ConnectorClientProxyFactory, r *mux.Router, urlPrefix string, cfg *config.Config) *ConnectionMediatorV2

func (*ConnectionMediatorV2) Routes

func (this *ConnectionMediatorV2) Routes()

type ManagementServer

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

func NewManagementServer

func NewManagementServer(byClientID connection_repository.GetConnectionByClientID, byOrgID connection_repository.GetConnectionsByOrgID, allConnections connection_repository.GetAllConnections, tenantTranslator tenantid.Translator, proxyFactory controller.ConnectorClientProxyFactory, r *mux.Router, urlPrefix string, cfg *config.Config) *ManagementServer

func (*ManagementServer) Routes

func (s *ManagementServer) Routes()

type MessageReceiver

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

func NewMessageReceiver

func NewMessageReceiver(byClientID connection_repository.GetConnectionByClientID, tenantTranslator tenantid.Translator, proxyFactory controller.ConnectorClientProxyFactory, r *mux.Router, urlPrefix string, cfg *config.Config) *MessageReceiver

func (*MessageReceiver) Routes

func (jr *MessageReceiver) Routes()

type MonitoringServer

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

func NewMonitoringServer

func NewMonitoringServer(r *mux.Router, cfg *config.Config) *MonitoringServer

func (*MonitoringServer) Routes

func (s *MonitoringServer) Routes()