longpoll

Documentation

Index

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

Variables

var ErrCancelled = errors.New("Cancelled")

Types

type PollableActionService

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

func New

func New(redis *redis.Client, key string) *PollableActionService

func (*PollableActionService) Push

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

func (*PollableActionService) Wait

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