longpoll

Documentation

Index

• Variables
• type LongPollService
  • func NewLongPollService(redis *redis.Client, key string) *LongPollService
  • func (pa *LongPollService) Push(ctx context.Context, runnerId string, data any) error
  • func (pa *LongPollService) Wait(ctx context.Context, runnerId string) (string, error)

Variables

var ErrCancelled = errors.New("Cancelled")

Types

type LongPollService

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

func NewLongPollService

func NewLongPollService(redis *redis.Client, key string) *LongPollService

func (*LongPollService) Push

func (pa *LongPollService) Push(ctx context.Context, runnerId string, data any) error

func (*LongPollService) Wait

func (pa *LongPollService) Wait(ctx context.Context, runnerId string) (string, error)