server

package
v0.0.0-...-6b63850 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 14, 2020 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ChangeEvent

type ChangeEvent struct {
}

type Connection

type Connection struct {
	sync.RWMutex

	// ConID is the connection identifier, used as a key in the connection table.
	// Currently based on the sink id, peer addr and a counter.
	ConID string

	// PeerAddr is the address of the client, from network layer.
	PeerAddr string

	// Time of connection, for debugging
	Connect time.Time

	// LastResponse stores the last response nonce to each sink
	LastResponse map[string]string
	// contains filtered or unexported fields
}

Connection holds information about connected client.

type ConsulMcpServer

type ConsulMcpServer struct {
	GRPCListener net.Listener
	// contains filtered or unexported fields
}

func NewServer

func NewServer(listeningAddress string, consulAddress string) *ConsulMcpServer

func (*ConsulMcpServer) EstablishResourceStream

func (s *ConsulMcpServer) EstablishResourceStream(stream mcp.ResourceSource_EstablishResourceStreamServer) error

func (*ConsulMcpServer) Start

func (s *ConsulMcpServer) Start() error

Start the gRPC MCP server

func (*ConsulMcpServer) Stop

func (s *ConsulMcpServer) Stop()

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL