timings

Documentation

Index

• type ChannelTimings
  • func (ct *ChannelTimings) ClientPollDelay(noutgoings uint) time.Duration
  • func (ct *ChannelTimings) CountIncomingMessage()
  • func (ct *ChannelTimings) CountIncomingPayload()
  • func (ct *ChannelTimings) CountOutgoingMessage()
  • func (ct *ChannelTimings) CountOutgoingPayload()
  • func (ct *ChannelTimings) IsStaleDuration(past time.Duration) bool
• type RouterTimings
  • func (rt *RouterTimings) ChannelTimings() (*ChannelTimings, error)
• type RouterTimingsBuilder
  • func (b RouterTimingsBuilder) Build() (*RouterTimings, error)
  • func (b RouterTimingsBuilder) WithGarbageCollectionDelay(d time.Duration) RouterTimingsBuilder
  • func (b RouterTimingsBuilder) WithMaxClientPollDelay(d time.Duration) RouterTimingsBuilder
  • func (b RouterTimingsBuilder) WithMinClientPollDelay(d time.Duration) RouterTimingsBuilder
  • func (b RouterTimingsBuilder) WithRouteResumePollDelay(d time.Duration) RouterTimingsBuilder

Types

type ChannelTimings

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

func (*ChannelTimings) ClientPollDelay

func (ct *ChannelTimings) ClientPollDelay(noutgoings uint) time.Duration

NOTE: This function is assumed to be called after outgoing message is popped

func (*ChannelTimings) CountIncomingMessage

func (ct *ChannelTimings) CountIncomingMessage()

func (*ChannelTimings) CountIncomingPayload

func (ct *ChannelTimings) CountIncomingPayload()

func (*ChannelTimings) CountOutgoingMessage

func (ct *ChannelTimings) CountOutgoingMessage()

func (*ChannelTimings) CountOutgoingPayload

func (ct *ChannelTimings) CountOutgoingPayload()

func (*ChannelTimings) IsStaleDuration

func (ct *ChannelTimings) IsStaleDuration(past time.Duration) bool

type RouterTimings

type RouterTimings struct {
	// NOTE: Max delay a route can wait for outgoing message from handler
	RouteResumePollTimeout time.Duration

	GarbageCollectionDelay time.Duration
	// contains filtered or unexported fields
}

func (*RouterTimings) ChannelTimings

func (rt *RouterTimings) ChannelTimings() (*ChannelTimings, error)

type RouterTimingsBuilder

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

func (RouterTimingsBuilder) Build

func (b RouterTimingsBuilder) Build() (*RouterTimings, error)

func (RouterTimingsBuilder) WithGarbageCollectionDelay

func (b RouterTimingsBuilder) WithGarbageCollectionDelay(d time.Duration) RouterTimingsBuilder

func (RouterTimingsBuilder) WithMaxClientPollDelay

func (b RouterTimingsBuilder) WithMaxClientPollDelay(
	d time.Duration,
) RouterTimingsBuilder

func (RouterTimingsBuilder) WithMinClientPollDelay

func (b RouterTimingsBuilder) WithMinClientPollDelay(
	d time.Duration,
) RouterTimingsBuilder

func (RouterTimingsBuilder) WithRouteResumePollDelay

func (b RouterTimingsBuilder) WithRouteResumePollDelay(
	d time.Duration,
) RouterTimingsBuilder