repository

Documentation

Index

• Constants
• Variables
• type MessageRepository
  • func NewMessageRepository(redis *redis.Client) *MessageRepository
  • func (r *MessageRepository) PublishMessage(ctx context.Context, message *entity.Message) error
  • func (r *MessageRepository) SubscribeMessage(ctx context.Context, channel chan<- *entity.Message)

Constants

const MessageChannel = "message"

Variables

var Set = wire.NewSet(
	NewMessageRepository,
	wire.Bind(new(usecase.MessageStore), new(*MessageRepository)),
)

Types

type MessageRepository

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

func NewMessageRepository

func NewMessageRepository(redis *redis.Client) *MessageRepository

func (*MessageRepository) PublishMessage

func (r *MessageRepository) PublishMessage(ctx context.Context, message *entity.Message) error

func (*MessageRepository) SubscribeMessage

func (r *MessageRepository) SubscribeMessage(ctx context.Context, channel chan<- *entity.Message)