util

Documentation

Index

• type EndpointWatch
  • func (w *EndpointWatch) Propose(ctx context.Context, session *connect.Session) error
  • func (w *EndpointWatch) Rejections() <-chan *connect.SessionRejection
  • func (w *EndpointWatch) StartReceiveRejections(ctx context.Context)
• type SessionProposal
  • func (p *SessionProposal) Reject(ctx context.Context, r *connect.RejectionReason) error
  • func (p *SessionProposal) Session() *connect.Session
  • func (p *SessionProposal) String() string

Types

type EndpointWatch

type EndpointWatch struct {
	ProposeFn      func(ctx context.Context, session *connect.Session) error
	RejectionsChan chan *connect.SessionRejection

	Receive func() (*connect.WatchRequest, error)
}

func (*EndpointWatch) Propose

func (w *EndpointWatch) Propose(ctx context.Context, session *connect.Session) error

func (*EndpointWatch) Rejections

func (w *EndpointWatch) Rejections() <-chan *connect.SessionRejection

func (*EndpointWatch) StartReceiveRejections

func (w *EndpointWatch) StartReceiveRejections(ctx context.Context)

type SessionProposal

type SessionProposal struct {
	Proposal *connect.Session
	RejectFn func(ctx context.Context, r *connect.RejectionReason) error
}

func (*SessionProposal) Reject

func (p *SessionProposal) Reject(ctx context.Context, r *connect.RejectionReason) error

func (*SessionProposal) Session

func (p *SessionProposal) Session() *connect.Session

func (*SessionProposal) String

func (p *SessionProposal) String() string