dispatcher

Documentation

Index

• Constants
• type Dispatcher
  • func NewDispatcher(datahubGrpcCn *grpc.ClientConn, queueConn *amqp.Connection) *Dispatcher
  • func (dispatcher *Dispatcher) Start()

Constants

const (
	UNIT_TYPE_NODE = "NODE"
	UNIT_TYPE_POD  = "POD"
)

Types

type Dispatcher

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

func NewDispatcher

func NewDispatcher(datahubGrpcCn *grpc.ClientConn, queueConn *amqp.Connection) *Dispatcher

func (*Dispatcher) Start

func (dispatcher *Dispatcher) Start()