Versions in this module Expand all Collapse all v0 v0.2.0 Sep 25, 2026 Changes in this version + var AuthEvents = struct{ ... } + var ChannelEvents = struct{ ... } + var ConnectionEvents = struct{ ... } + var DefaultOption = option.DefaultOption + var WithAPIKey = option.WithAPIKey + var WithAutoConnect = option.WithAutoConnect + type AuthManager interface + Authenticate func(ctx context.Context) (*option.AuthResponse, error) + ClearToken func() + CreateTokenRequest func(ctx context.Context, opts option.TokenOptions) (option.TokenRequest, error) + GenerateToken func(ctx context.Context, opts option.TokenOptions) (string, error) + GetAuthHeaders func() (map[string]string, error) + GetAuthQueryParams func() (string, error) + GetAuthenticateURL func(baseURL string) (string, error) + GetCurrentToken func() string + GetToken func() string + IsAuthenticated func() bool + IssueToken func(ctx context.Context, opts option.TokenOptions) (string, error) + On func(event string, fn func(any)) + RequestToken func(ctx context.Context, request option.TokenRequest) (*option.AuthResponse, error) + Reset func() + ShouldAutoAuthenticate func() bool + type AuthResponse = option.AuthResponse + type Connection interface + Connect func(ctx context.Context) error + Disconnect func() + IsConnected func() bool + IsResetting func() bool + On func(event string, fn func(any)) + Ping func(ctx context.Context) (time.Duration, error) + Reset func() + WaitUntilConnected func(ctx context.Context) error + type EnqueueOptions = protocol.EnqueueOptions + type EnqueueResult = protocol.EnqueueResult + type Message = protocol.Message + type Option = option.Option + type OptionFunc = option.OptionFunc + type OptionManager interface + Get func() option.Option + Reset func() + Set func(partial option.Option) + type Permission = option.Permission + type QueueJob = protocol.QueueJob + type Rest struct + Auth *auth.Manager + Channels *channel.RestManager + OptionManager *option.Manager + Queues *queue.Manager + func NewRest(funcs ...option.OptionFunc) *Rest + func (r *Rest) GetInstanceID() string + func (r *Rest) Reset() + type RestChannel interface + Name func() string + Publish func(ctx context.Context, data interface{}, opts channel.PublishOptions) ([]byte, error) + Reset func() + type RestQueueManager interface + Ack func(ctx context.Context, queueName, jobID string, opts protocol.AckJobOptions) error + CancelJob func(ctx context.Context, queueName, jobID string) error + Enqueue func(ctx context.Context, queueName string, payload interface{}, ...) (protocol.EnqueueResult, error) + GetConfig func(ctx context.Context, queueName string) (protocol.QueueConfig, error) + GetJob func(ctx context.Context, queueName, jobID string) (protocol.QueueJob, error) + Heartbeat func(ctx context.Context, workerID string) (protocol.WorkerRegistration, error) + ListJobs func(ctx context.Context, queueName string, opts protocol.ListJobsOptions) ([]protocol.QueueJob, error) + Nack func(ctx context.Context, queueName, jobID string, opts protocol.NackJobOptions) error + Pull func(ctx context.Context, queueName string, opts protocol.PullJobsOptions) ([]protocol.QueueJob, error) + RegisterWorker func(ctx context.Context, opts protocol.RegisterWorkerOptions) (protocol.WorkerRegistration, error) + Reset func() + RetryJob func(ctx context.Context, queueName, jobID string) error + RunWorker func(ctx context.Context, queueName string, ...) error + StopWorker func() + UpdateConfig func(ctx context.Context, queueName string, opts protocol.UpdateQueueConfigOptions) (protocol.QueueConfig, error) + type Socket struct + Auth *auth.Manager + Channels *channel.SocketManager + Connection *connection.Conn + OptionManager *option.Manager + func NewSocket(funcs ...option.OptionFunc) *Socket + func (s *Socket) GetInstanceID() string + func (s *Socket) Reset() + type SocketChannel interface + ClearBufferedMessages func() + IsPaused func() bool + Name func() string + On func(event string, fn func(any)) + Pause func(bufferMessages bool) + Publish func(ctx context.Context, data interface{}, opts channel.PublishOptions) error + Reset func() + Resume func() + Subscribe func(ctx context.Context, handler channel.MessageHandler, ...) error + Unsubscribe func(ctx context.Context, opts ...channel.UnsubscribeOptions) error + type TokenOptions = option.TokenOptions + type TokenRequest = option.TokenRequest v0.1.0 Sep 25, 2026
Go to main page