Documentation ¶
Index ¶
- type AMQPConsumer
- type AMQPProducer
- type JWTManager
- func (m *JWTManager) Generate(user *model.User) (*model.TokenPair, error)
- func (m *JWTManager) GetAndVerifyClaims(ctx context.Context) (*model.UserClaims, error)
- func (m *JWTManager) NewRefreshToken(userId uuid.UUID) *model.RefreshToken
- func (m *JWTManager) Verify(accessToken string) (*model.UserClaims, error)
- type JWTManagerProtol
- type RabbitMQConsumer
- type RabbitMQProducer
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AMQPConsumer ¶
type AMQPConsumer interface {
Consume()
}
type AMQPProducer ¶
type AMQPProducer interface {
Produce(*pb.MessageDelivery) error
}
type JWTManager ¶
type JWTManager struct {
// contains filtered or unexported fields
}
func NewJWTManager ¶
func NewJWTManager(secretKey string, tokenDuration, refreshTokenDuration time.Duration) *JWTManager
func (*JWTManager) GetAndVerifyClaims ¶
func (m *JWTManager) GetAndVerifyClaims(ctx context.Context) (*model.UserClaims, error)
func (*JWTManager) NewRefreshToken ¶
func (m *JWTManager) NewRefreshToken(userId uuid.UUID) *model.RefreshToken
func (*JWTManager) Verify ¶
func (m *JWTManager) Verify(accessToken string) (*model.UserClaims, error)
type JWTManagerProtol ¶
type RabbitMQConsumer ¶
type RabbitMQConsumer struct { Channel *amqp.Channel SessionStore repository.SessionStore Queue *amqp.Queue }
func NewRabbitMQConsumer ¶
func NewRabbitMQConsumer(channel *amqp.Channel, sessionStore repository.SessionStore) *RabbitMQConsumer
func (*RabbitMQConsumer) Consume ¶
func (c *RabbitMQConsumer) Consume()
type RabbitMQProducer ¶
func NewRabbitMQManager ¶
func NewRabbitMQManager(channel *amqp.Channel) *RabbitMQProducer
func (*RabbitMQProducer) Produce ¶
func (m *RabbitMQProducer) Produce(delivery *pb.MessageDelivery) error
Click to show internal directories.
Click to hide internal directories.