responsequeue

Documentation

Overview

responsequeue ensures that responses to requests are sent in the order they are received

Index

• type ResponseQueue
  • func CreateResponseQueue(writer io.Writer) *ResponseQueue
  • func (queue *ResponseQueue) Close()
  • func (queue *ResponseQueue) RecordOutgoingRequest(message message.Message)

Types

type ResponseQueue

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

func CreateResponseQueue

func CreateResponseQueue(writer io.Writer) *ResponseQueue

func (*ResponseQueue) Close

func (queue *ResponseQueue) Close()

func (*ResponseQueue) RecordOutgoingRequest

func (queue *ResponseQueue) RecordOutgoingRequest(message message.Message)

RecordOutgoingRequest tracks an outgoing request so that responses to pipelined requests caan be sent in order. It is called only by the goroutine that accepts messages from a client of the proxy