receiver

package

v0.0.0-...-97d4abd Latest Latest Go to latest Published: Apr 2, 2022 License: MIT Imports: 5 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/coder543/roundabout

Links

Open Source Insights

Documentation ¶

Overview ¶

Package receiver contains an actor that receives messages from Postgres and (usually) forwards those messages to the backend manager. This actor is probably the closest analogue to the backend manager on the frontend, but it is simpler than the backend manager, and not truly comparable.

Index ¶

type NewOutChans
type Receiver
- func Launch(closed chan struct{}, closeFrontend func(), ...) *Receiver

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type NewOutChans ¶

type NewOutChans struct {
	Out       chan pgproto3.BackendMessage
	OutSync   *misc.Cond
	Detaching chan struct{}
}

type Receiver ¶

type Receiver struct {
	NewOut chan<- NewOutChans
	// contains filtered or unexported fields
}

func Launch ¶

func Launch(
	closed chan struct{},
	closeFrontend func(),
	receive func() (pgproto3.BackendMessage, error),
) *Receiver

func (*Receiver) AwaitDropRFQChan ¶

func (r *Receiver) AwaitDropRFQChan()

func (*Receiver) RFQSkip ¶

func (r *Receiver) RFQSkip(bmsg pgproto3.BackendMessage) bool

when proxying application_name, we will get an RFQ that the backend doesn't need to know about

func (*Receiver) Send ¶

func (r *Receiver) Send(bmsg pgproto3.BackendMessage) bool

func (*Receiver) SetDropRFQ ¶

func (r *Receiver) SetDropRFQ(val bool)

Source Files ¶

View all Source files

receiver.go

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