dispatcher

Documentation

Index

• Constants
• type Dispatcher
  • func New(config *config.Configuration, logger hclog.Logger) *Dispatcher
  • func (d *Dispatcher) AwaitStop() error
  • func (d *Dispatcher) NewNATSServer() (Transport, error)
• type GRPCServer
  • func (rpc *GRPCServer) Close() error
  • func (rpc *GRPCServer) Ping(ctx context.Context, req *dispatcher.PingRequest) (*dispatcher.PingReply, error)
  • func (rpc *GRPCServer) Put(ctx context.Context, req *transport.Message) (*transport.Message, error)
• type MessageBus
• type NATSServer
  • func (nats *NATSServer) Close() error
  • func (nats *NATSServer) Ping(ctx context.Context, req *dispatcher.PingRequest) (*dispatcher.PingReply, error)
  • func (nats *NATSServer) Put(ctx context.Context, req *transport.Message) (*transport.Message, error)
• type Transport
  • func NewGRPCServer(port int, sendChan chan *transport.Message, logger *logrus.Logger) (Transport, error)

Constants

const (
	RecvCache int = 10000
	SendCache int = 10000
)

const RequestsPollerTopic = "requests-poller"

Types

type Dispatcher

type Dispatcher struct {
	ID      string      `json:"id" toml:"id"`
	Name    string      `json:"name" toml:"name"`
	Address net.TCPAddr `json:"address" toml:"address"`
	// contains filtered or unexported fields
}

app

func New

func New(config *config.Configuration, logger hclog.Logger) *Dispatcher

create a new dispatcher app

func (*Dispatcher) AwaitStop

func (d *Dispatcher) AwaitStop() error

AwaitStop start the main program, blocking with sleep loop

func (*Dispatcher) NewNATSServer

func (d *Dispatcher) NewNATSServer() (Transport, error)

type GRPCServer

type GRPCServer struct {
	*grpc.Server
	// contains filtered or unexported fields
}

GRPCServer is the GRPC server for DNC Dispatcher. It handels all the requests comming down to the DNC

func (*GRPCServer) Close

func (rpc *GRPCServer) Close() error

Close the grpc connection

func (*GRPCServer) Ping

func (rpc *GRPCServer) Ping(ctx context.Context, req *dispatcher.PingRequest) (*dispatcher.PingReply, error)

Ping implements the Ping Interface TODO not really needed, made for testing

func (*GRPCServer) Put

func (rpc *GRPCServer) Put(ctx context.Context, req *transport.Message) (*transport.Message, error)

TODO move to domain and this should only call that function some one calls to the DNC to do some polling, add the message to the queue and wait for its return

type MessageBus

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

MessageBus

type NATSServer

type NATSServer struct {
	*nats.Conn
	// contains filtered or unexported fields
}

func (*NATSServer) Close

func (nats *NATSServer) Close() error

func (*NATSServer) Ping

func (nats *NATSServer) Ping(ctx context.Context, req *dispatcher.PingRequest) (*dispatcher.PingReply, error)

func (*NATSServer) Put

func (nats *NATSServer) Put(ctx context.Context, req *transport.Message) (*transport.Message, error)

Mock interface implementation, all logic is in subscription handler function in NewNATSServer method

type Transport

type Transport interface {
	Put(ctx context.Context, request *transport.Message) (*transport.Message, error)
	Ping(ctx context.Context, request *dispatcher.PingRequest) (*dispatcher.PingReply, error)
	Close() error
}

Transport is the interface that creates transportation between the dispatcher and the rest of the world. TODO request should be implemented through other means also: NATS, KAFKA, etc

func NewGRPCServer

func NewGRPCServer(port int, sendChan chan *transport.Message, logger *logrus.Logger) (Transport, error)

NewGRPCServer creates a new GRPC Server and returns the Transport interface