repos

Documentation

Index

• type KafkaRepository
  • func NewKafkaRepository(brokers []string, topic string, groupID string) (*KafkaRepository, error)
  • func (r *KafkaRepository) ReadSolution(ctx context.Context) (*entity.Solution, error)
• type RedisTracebackRepository
  • func NewRedisTracebackRepository(addr, password string, db int) (*RedisTracebackRepository, error)
  • func (r *RedisTracebackRepository) GetTraceback(taskId int, userId int) (string, error)
  • func (r *RedisTracebackRepository) SaveTraceback(taskId int, userId int, traceback string) error
• type TracebackRepository

Types

type KafkaRepository

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

func NewKafkaRepository

func NewKafkaRepository(brokers []string, topic string, groupID string) (*KafkaRepository, error)

func (*KafkaRepository) ReadSolution

func (r *KafkaRepository) ReadSolution(ctx context.Context) (*entity.Solution, error)

type RedisTracebackRepository

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

func NewRedisTracebackRepository

func NewRedisTracebackRepository(addr, password string, db int) (*RedisTracebackRepository, error)

func (*RedisTracebackRepository) GetTraceback

func (r *RedisTracebackRepository) GetTraceback(taskId int, userId int) (string, error)

func (*RedisTracebackRepository) SaveTraceback

func (r *RedisTracebackRepository) SaveTraceback(taskId int, userId int, traceback string) error

type TracebackRepository

type TracebackRepository interface {
	SaveTraceback(taskId int, userId int, traceback string) error
	GetTraceback(taskId int, userId int) (string, error)
}