DefaultSubjectForAgentFunc returns the default NATS subject for a given agent.

NewAgent will connect to nats in main cluster and proxy connections locally to an http.Handler.

NewAgentResponseBroker returns an initialized AgentResponseBroker that brokers the nats messages stream generated by AgentResponseWriter back into an http response.

NewHTTPProxy returns an instance that proxies http requests through nats to a remote agent.

NewResponseWriter returns an instance of ResponseWriter.

SerializeMap converts golang map to protobuf map.

SetupConnOptions sets up defaults for nats connection.

UnserializeMap converts protobuf map to golang map.

Agent listens for incoming proxy requests for a given agent.

AgentResponseBroker that brokers the nats messages stream generated by AgentResponseWriter back into an http response, use NewAgentResponseBroker to initialize.

HTTPProxy proxies http requests through nats to a remote agent.

RandomSuffix will generate a random suffix for use in Nats Msg.reply field.

ResponseWriter serializes and writes http responses over nats as part of Agent.

Tunnel creates a request that expects 1..n replies from a remote nats client.

RandomSuffixGetter defines interface get a random suffix for a nats message.

SubjectForAgentFunc is function to obtains NATS subject for a given agent ID.