consumerstore

type AppLogConsumeProgress struct {
	ConsumerId string `json:"consumer_id"`
	Offset     string `json:"offset"`
}

type ConsumerEntry struct {
	ID     string
	Offset string `gorm:"type:varchar(100); not null"`
}

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

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

type Store interface {
	LogConsume(ctx context.Context, request *AppLogConsumeProgress) error
	GetLogConsume(ctx context.Context, consumerID string) (*AppLogConsumeProgress, error)
	List(ctx context.Context) ([]*AppLogConsumeProgress, error)
}