redis

Documentation

Overview

* Copyright 2023 Caio Matheus Marcatti Calimério * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License.

* Copyright 2023 Caio Matheus Marcatti Calimério * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License.

* Copyright 2023 Caio Matheus Marcatti Calimério * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License.

* Copyright 2023 Caio Matheus Marcatti Calimério * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License.

Index

• func Enqueue(queueName string, params map[string]interface{}) bool
• func Get(key string) (string, error)
• func GetDecode[T any](key string, target *T) (*T, error)
• func Remove(key string) error
• func Set(key string, value interface{}, ttl ...int) error
• func StartRedisQueue()
• type RedisCache
  • func StartRedisCache() *RedisCache
• type RedisConsumer
  • func RedisQueueConsumer(consumer RedisQueueConsumerInterface, queueName string) *RedisConsumer
• type RedisQueue
• type RedisQueueConsumerInterface

Functions

func Enqueue

func Enqueue(queueName string, params map[string]interface{}) bool

func Get

func Get(key string) (string, error)

func GetDecode

func GetDecode[T any](key string, target *T) (*T, error)

func Remove

func Remove(key string) error

func Set

func Set(key string, value interface{}, ttl ...int) error

func StartRedisQueue

func StartRedisQueue()

Types

type RedisCache

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

func StartRedisCache

func StartRedisCache() *RedisCache

type RedisConsumer

type RedisConsumer struct {
	Queue *RedisQueue
}

func RedisQueueConsumer

func RedisQueueConsumer(consumer RedisQueueConsumerInterface, queueName string) *RedisConsumer

type RedisQueue

type RedisQueue struct {
	Enqueuer   *work.Enqueuer
	WorkerPool *work.WorkerPool
	// contains filtered or unexported fields
}

var RedisQ *RedisQueue

Variável global para a instância de RedisQueue

type RedisQueueConsumerInterface

type RedisQueueConsumerInterface interface {
	Run(job *work.Job) error
}