protoserver

Documentation

Index

• Constants
• Variables
• func MakeContactReaderProxy(client protocol.ContactReaderClient) protocol.ContactReaderServer
• func MakeContactWriterProxy(client protocol.ContactWriterClient) protocol.ContactWriterServer
• func MakeMQTTWriterClient(queue queueManager.QueueManager) protocol.ContactWriterClient
• func MakeQueueWriter(queue queueManager.QueueManager, databaseWriter protocol.ContactWriterClient) *queueWriter

Constants

const (
	// Contact Server Reader DSN
	ReaderListen = ":9998"
	// Contact Server Writer DSN
	WriterListen = ":9999"

	// Contact Server Reader DSN
	DatabaseListen = ":8888"

	// Local connection DSN for Reader
	LocalConnectReader = "localhost" + ReaderListen

	// Local connection DSN for Writer
	LocalConnectWriter = "localhost" + WriterListen

	// Local connection DSN for Writer
	LocalConnectDatabase = "localhost" + DatabaseListen
)

Variables

var DialOptions = grpc.WithInsecure()

Dial Options for an client. Defaults to Insecure

Functions

func MakeContactReaderProxy

func MakeContactReaderProxy(client protocol.ContactReaderClient) protocol.ContactReaderServer

func MakeContactWriterProxy

func MakeContactWriterProxy(client protocol.ContactWriterClient) protocol.ContactWriterServer

func MakeMQTTWriterClient

func MakeMQTTWriterClient(queue queueManager.QueueManager) protocol.ContactWriterClient

func MakeQueueWriter

func MakeQueueWriter(queue queueManager.QueueManager, databaseWriter protocol.ContactWriterClient) *queueWriter